Class CloudDurableTestRunner<I,O>

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

public class CloudDurableTestRunner<I,O> extends Object
  • 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, Class<I> inputType, Class<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)