Package software.amazon.lambda.durable.testing

Class CloudDurableTestRunner<I,O>

java.lang.Object

software.amazon.lambda.durable.testing.CloudDurableTestRunner<I,O>

public class CloudDurableTestRunner<I,O>
extends Object

Method Summary

Modifier and Type	Method	Description
static <I, O> CloudDurableTestRunner<I,O>	create(String functionArn, Class<I> inputType, Class<O> outputType)
static <I, O> CloudDurableTestRunner<I,O>	create(String functionArn, Class<I> inputType, Class<O> outputType, software.amazon.awssdk.services.lambda.LambdaClient lambdaClient)
static <I, O> CloudDurableTestRunner<I,O>	create(String functionArn, TypeToken<I> inputType, TypeToken<O> outputType)
static <I, O> CloudDurableTestRunner<I,O>	create(String functionArn, TypeToken<I> inputType, TypeToken<O> outputType, software.amazon.awssdk.services.lambda.LambdaClient lambdaClient)
TestOperation	getOperation(String name)
TestResult<O>	run(I input)
AsyncExecution<O>	startAsync(I input)	Start an asynchronous execution and return a handle for incremental polling.
CloudDurableTestRunner<I,O>	withInvocationType(software.amazon.awssdk.services.lambda.model.InvocationType type)
CloudDurableTestRunner<I,O>	withPollInterval(Duration interval)
CloudDurableTestRunner<I,O>	withTimeout(Duration timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static <I,
O> CloudDurableTestRunner<I,O> create(String functionArn,
 Class<I> inputType,
 Class<O> outputType)

create

public static <I,
O> CloudDurableTestRunner<I,O> create(String functionArn,
 TypeToken<I> inputType,
 TypeToken<O> outputType)

create

public static <I,
O> CloudDurableTestRunner<I,O> create(String functionArn,
 Class<I> inputType,
 Class<O> outputType,
 software.amazon.awssdk.services.lambda.LambdaClient lambdaClient)

create

public static <I,
O> CloudDurableTestRunner<I,O> create(String functionArn,
 TypeToken<I> inputType,
 TypeToken<O> outputType,
 software.amazon.awssdk.services.lambda.LambdaClient lambdaClient)

withPollInterval

public CloudDurableTestRunner<I,O> withPollInterval(Duration interval)

withTimeout

public CloudDurableTestRunner<I,O> withTimeout(Duration timeout)

withInvocationType

public CloudDurableTestRunner<I,O> withInvocationType(software.amazon.awssdk.services.lambda.model.InvocationType type)

run

public TestResult<O> run(I input)

startAsync

public AsyncExecution<O> startAsync(I input)

Start an asynchronous execution and return a handle for incremental polling. Use this for callback-based tests where you need to interact with the execution while it's running.

Parameters:

input - the input to the function

Returns:

execution handle for polling and inspection

getOperation

public TestOperation getOperation(String name)