summaryrefslogtreecommitdiff
path: root/opendc-serverless/opendc-serverless-service/src/test
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-serverless/opendc-serverless-service/src/test')
-rw-r--r--opendc-serverless/opendc-serverless-service/src/test/kotlin/org/opendc/serverless/service/ServerlessServiceTest.kt22
1 files changed, 11 insertions, 11 deletions
diff --git a/opendc-serverless/opendc-serverless-service/src/test/kotlin/org/opendc/serverless/service/ServerlessServiceTest.kt b/opendc-serverless/opendc-serverless-service/src/test/kotlin/org/opendc/serverless/service/ServerlessServiceTest.kt
index d9f5ee81..6b2e8223 100644
--- a/opendc-serverless/opendc-serverless-service/src/test/kotlin/org/opendc/serverless/service/ServerlessServiceTest.kt
+++ b/opendc-serverless/opendc-serverless-service/src/test/kotlin/org/opendc/serverless/service/ServerlessServiceTest.kt
@@ -45,7 +45,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientState() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = assertDoesNotThrow { service.newClient() }
assertDoesNotThrow { client.close() }
@@ -60,7 +60,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientInvokeUnknown() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -70,7 +70,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientFunctionCreation() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -82,7 +82,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientFunctionQuery() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -96,7 +96,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientFunctionFindById() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -110,7 +110,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientFunctionFindByName() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -124,7 +124,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientFunctionDuplicateName() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -136,7 +136,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientFunctionDelete() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = service.newClient()
val function = client.newFunction("test", 128)
@@ -151,7 +151,7 @@ internal class ServerlessServiceTest {
@Test
fun testClientFunctionCannotInvokeDeleted() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
- val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, mockk(), mockk(), mockk())
val client = service.newClient()
val function = client.newFunction("test", 128)
@@ -165,9 +165,9 @@ internal class ServerlessServiceTest {
fun testClientFunctionInvoke() = runBlockingSimulation {
val meter = MeterProvider.noop().get("opendc-serverless")
val deployer = mockk<FunctionDeployer>()
- val service = ServerlessService(coroutineContext, clock, meter, deployer, mockk())
+ val service = ServerlessService(coroutineContext, clock, meter, deployer, mockk(), mockk(relaxUnitFun = true))
- every { deployer.deploy(any()) } answers {
+ every { deployer.deploy(any(), any()) } answers {
object : FunctionInstance {
override val state: FunctionInstanceState = FunctionInstanceState.Idle
override val function: FunctionObject = it.invocation.args[0] as FunctionObject