Index (AWS Lambda Durable Execution SDK Testing Utilities 1.1.0 API)

A C E F G H I L O P R S T W
All Classes and Interfaces|All Packages

A

advanceTime() - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Advance all operations (simulates time passing for retries/waits).
advanceTime() - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Advances all pending operations, simulating time passing for retries and waits.
applyResult(Operation, OperationResult) - Static method in class software.amazon.lambda.durable.testing.local.OperationProcessor: Applies the result of an operation to the existing operation, returning a new operation.
AsyncExecution<O> - Class in software.amazon.lambda.durable.testing: Handle for an asynchronously executing durable function.
AsyncExecution(String, LambdaClient, TypeToken<O>, SerDes, Duration, Duration) - Constructor for class software.amazon.lambda.durable.testing.AsyncExecution

C

checkpoint(String, String, List<OperationUpdate>) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient
CloudDurableTestRunner<I,O> - Class in software.amazon.lambda.durable.testing: Test runner for durable Lambda functions deployed to AWS.
completeCallback(String, String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution: calls sendDurableExecutionCallbackSuccess with the given callbackId and result
completeCallback(String, String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Complete a callback with success result.
completeCallback(String, OperationResult) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Simulate external system completing callback.
completeChainedInvoke(String, String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Completes a chained invoke operation with a successful result.
completeChainedInvoke(String, OperationResult) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Completes a chained invoke operation with the given result, simulating a child Lambda response.
create(Class, BiFunction<I, DurableContext, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Creates a LocalDurableTestRunner with default configuration.
create(Class, BiFunction<I, DurableContext, O>, DurableConfig) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Creates a LocalDurableTestRunner that uses a custom configuration.
create(Class, DurableHandler<I, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Creates a LocalDurableTestRunner from a DurableHandler instance, automatically extracting the configuration.
create(String, Class, Class<O>) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Creates a runner for the given function ARN with Class-based input/output types.
create(String, Class, Class<O>, LambdaClient) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Creates a runner with a custom LambdaClient and Class-based input/output types.
create(String, TypeToken, TypeToken<O>) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Creates a runner for the given function ARN with TypeToken-based input/output types.
create(String, TypeToken, TypeToken<O>, LambdaClient) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Creates a runner with a custom LambdaClient and TypeToken-based input/output types.
create(TypeToken, BiFunction<I, DurableContext, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Creates a LocalDurableTestRunner with default configuration.
create(TypeToken, BiFunction<I, DurableContext, O>, DurableConfig) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Creates a LocalDurableTestRunner that uses a custom configuration.
create(TypeToken, DurableHandler<I, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Creates a LocalDurableTestRunner from a DurableHandler instance, automatically extracting the configuration.

E

equals(Object) - Method in record class software.amazon.lambda.durable.testing.local.OperationResult: Indicates whether some other object is "equal to" this one.
error() - Method in record class software.amazon.lambda.durable.testing.local.OperationResult: Returns the value of the error record component.

F

failCallback(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.AsyncExecution: calls sendDurableExecutionCallbackFailure with the give callbackId and error
failCallback(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Fail a callback with error.
failChainedInvoke(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Fails a chained invoke operation with the given error.
failed(ErrorObject) - Static method in record class software.amazon.lambda.durable.testing.local.OperationResult

G

getAllOperations() - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Returns all operations currently stored.
getAttempt() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the current retry attempt number (0-based), defaulting to 0 if not available.
getCallbackDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the callback details, or null if this is not a callback operation.
getCallbackId(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Get the callback ID for a callback operation.
getCallbackId(String) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Get callback ID for a named callback operation.
getCallbackId(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Get callback ID for a named callback operation.
getChainedInvokeDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the chained invoke details, or null if this is not a chained invoke operation.
getContextDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the context details, or null if this operation is not a context.
getDuration() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the duration of the operation
getError() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the step error, or null if the step succeeded or this is not a step operation.
getError() - Method in class software.amazon.lambda.durable.testing.TestResult: Returns the execution error, if present.
getEvents() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the raw history events associated with this operation.
getEventsForOperation(String) - Method in class software.amazon.lambda.durable.testing.TestResult: Returns the raw history events for the given operation name, or an empty list if not found.
getExecutionArn() - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Get the execution ARN.
getExecutionDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the execution details, or null if this operation is not an EXECUTION operation.
getExecutionState(String, String, String) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient
getFailedOperations() - Method in class software.amazon.lambda.durable.testing.TestResult: Returns all operations that failed, were cancelled, timed out, or stopped.
getHistoryEvents() - Method in class software.amazon.lambda.durable.testing.TestResult: Returns all raw history events from the execution.
getId() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the operation ID.
getName() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the operation name.
getOperation(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Get details for a specific operation.
getOperation(String) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Returns the TestOperation for the given name from the last execution result.
getOperation(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Returns the TestOperation for the given operation name, or null if not found.
getOperation(String) - Method in class software.amazon.lambda.durable.testing.TestResult: Returns the TestOperation with the given name, or null if not found.
getOperationByName(String) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Returns the operation with the given name, or null if not found.
getOperations() - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Get all operations in the execution.
getOperations() - Method in class software.amazon.lambda.durable.testing.TestResult: Returns all operations from the execution.
getOperationUpdates() - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Get all operation updates that have been sent to this client.
getResult() - Method in class software.amazon.lambda.durable.testing.TestResult: Deserializes and returns the execution output if the result type is known.
getResult(Class<T>) - Method in class software.amazon.lambda.durable.testing.TestResult: Deserializes and returns the execution output, throwing if the execution did not succeed.
getResult(TypeToken<T>) - Method in class software.amazon.lambda.durable.testing.TestResult: Deserializes and returns the execution output using a TypeToken for generic types.
getStatus() - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Get current execution status.
getStatus() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the current status of this operation (e.g.
getStatus() - Method in class software.amazon.lambda.durable.testing.TestResult: Returns the execution status (SUCCEEDED, FAILED, or PENDING).
getStepDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the step details, or null if this is not a step operation.
getStepResult(Class<T>) - Method in class software.amazon.lambda.durable.testing.TestOperation: Deserializes and returns the step result as the given type.
getStepResult(TypeToken<T>) - Method in class software.amazon.lambda.durable.testing.TestOperation: Deserializes and returns the step result using a TypeToken for generic types.
getSubtype() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the operation's subtype
getSucceededOperations() - Method in class software.amazon.lambda.durable.testing.TestResult: Returns all operations that completed successfully.
getType() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the operation type (STEP, WAIT, CALLBACK, etc.).
getWaitDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns the wait details, or null if this is not a wait operation.

H

hasCallback(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Check if a callback operation with the given name exists and is started.
hashCode() - Method in record class software.amazon.lambda.durable.testing.local.OperationResult: Returns a hash code value for this object.
hasOperation(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Check if an operation with the given name exists.
heartbeatCallback(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution: call sendDurableExecutionCallbackHeartbeat API with the give callbackId
HistoryEventProcessor - Class in software.amazon.lambda.durable.testing.cloud: Processes execution history events from the GetDurableExecutionHistory API into TestResult objects.
HistoryEventProcessor() - Constructor for class software.amazon.lambda.durable.testing.cloud.HistoryEventProcessor
HistoryPoller - Class in software.amazon.lambda.durable.testing.cloud: Polls the GetDurableExecutionHistory API until execution completes or a timeout is reached.
HistoryPoller(LambdaClient) - Constructor for class software.amazon.lambda.durable.testing.cloud.HistoryPoller: Creates a poller backed by the given Lambda client.

I

isComplete() - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Check if execution has completed (succeeded or failed).
isCompleted() - Method in class software.amazon.lambda.durable.testing.TestOperation: Returns true if the operation has completed (either succeeded or failed).
isFailed() - Method in class software.amazon.lambda.durable.testing.TestResult: Returns true if the execution failed.
isSucceeded() - Method in class software.amazon.lambda.durable.testing.TestResult: Returns true if the execution completed successfully.

L

LocalDurableTestRunner<I,O> - Class in software.amazon.lambda.durable.testing: In-memory test runner for durable Lambda functions.
LocalMemoryExecutionClient - Class in software.amazon.lambda.durable.testing.local: In-memory implementation of DurableExecutionClient for local testing.
LocalMemoryExecutionClient() - Constructor for class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient

O

OperationProcessor - Class in software.amazon.lambda.durable.testing.local
OperationProcessor() - Constructor for class software.amazon.lambda.durable.testing.local.OperationProcessor
OperationResult - Record Class in software.amazon.lambda.durable.testing.local: The operation status and result/error from Step, Context, Callback and ChainedInvoke operations
OperationResult(OperationStatus, String, ErrorObject) - Constructor for record class software.amazon.lambda.durable.testing.local.OperationResult: Creates an instance of a OperationResult record class.
operationStatus() - Method in record class software.amazon.lambda.durable.testing.local.OperationResult: Returns the value of the operationStatus record component.

P

pollUntil(Predicate<AsyncExecution<O>>) - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Poll execution history until the given condition is met.
pollUntilComplete() - Method in class software.amazon.lambda.durable.testing.AsyncExecution: Poll until execution completes and return the final result.
pollUntilComplete(String, Duration, Duration) - Method in class software.amazon.lambda.durable.testing.cloud.HistoryPoller: Polls execution history until a terminal event is found or the timeout is exceeded.
processEvents(List<Event>, TypeToken<O>, SerDes) - Method in class software.amazon.lambda.durable.testing.cloud.HistoryEventProcessor: Processes a list of execution history events into a structured TestResult.

R

ready() - Static method in record class software.amazon.lambda.durable.testing.local.OperationResult
resetCheckpointToStarted(String) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Simulate checkpoint failure by forcing an operation into STARTED state
resetCheckpointToStarted(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Resets a named step operation to STARTED status, simulating a checkpoint failure.
result() - Method in record class software.amazon.lambda.durable.testing.local.OperationResult: Returns the value of the result record component.
run(I) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Invokes the Lambda function, polls execution history until completion, and returns the result.
run(I) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Run a single invocation (may return PENDING if waiting/retrying).
runUntilComplete(I) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Invokes the Lambda function, polls execution history until completion, and returns the result.
runUntilComplete(I) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Run until completion (SUCCEEDED or FAILED) or pending manual intervention, simulating Lambda re-invocations.

S

simulateFireAndForgetCheckpointLoss(String) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Simulate fire-and-forget checkpoint loss by removing the operation entirely
simulateFireAndForgetCheckpointLoss(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Removes a named step operation entirely, simulating loss of a fire-and-forget checkpoint.
software.amazon.lambda.durable.testing - package software.amazon.lambda.durable.testing
software.amazon.lambda.durable.testing.cloud - package software.amazon.lambda.durable.testing.cloud
software.amazon.lambda.durable.testing.local - package software.amazon.lambda.durable.testing.local
startAsync(I) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Start an asynchronous execution and return a handle for incremental polling.
stopChainedInvoke(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Stops a chained invoke operation with the given error.
stopped(ErrorObject) - Static method in record class software.amazon.lambda.durable.testing.local.OperationResult
succeeded(String) - Static method in record class software.amazon.lambda.durable.testing.local.OperationResult

T

TestOperation - Class in software.amazon.lambda.durable.testing: Wrapper for AWS SDK Operation providing convenient access methods.
TestOperation(Operation, List<Event>, SerDes) - Constructor for class software.amazon.lambda.durable.testing.TestOperation
TestOperation(Operation, SerDes) - Constructor for class software.amazon.lambda.durable.testing.TestOperation
TestResult<O> - Class in software.amazon.lambda.durable.testing: Represents the result of a durable execution, providing access to the execution status, output, operations, and history events.
TestResult(ExecutionStatus, String, ErrorObject, List<TestOperation>, List<Event>, TypeToken<O>, SerDes) - Constructor for class software.amazon.lambda.durable.testing.TestResult
timedout() - Static method in record class software.amazon.lambda.durable.testing.local.OperationResult
timeoutCallback(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Timeout a callback.
timeoutChainedInvoke(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Marks a chained invoke operation as timed out.
toString() - Method in record class software.amazon.lambda.durable.testing.local.OperationResult: Returns a string representation of this record class.
toTestResult(DurableExecutionOutput, TypeToken<O>, SerDes) - Method in class software.amazon.lambda.durable.testing.local.LocalMemoryExecutionClient: Build TestResult from current state.

W

withDurableConfig(DurableConfig) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Overrides the DurableConfig for this test runner.
withInvocationType(InvocationType) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Returns a new runner with the specified Lambda invocation type.
withLambdaClient(LambdaClient) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Returns a new runner with the specified lambda client.
withOutputType(Class<O>) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Overrides the output type for this test runner.
withOutputType(TypeToken<O>) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner: Overrides the output type for this test runner.
withPollInterval(Duration) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Returns a new runner with the specified poll interval between history checks.
withSerDes(SerDes) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
withTimeout(Duration) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner: Returns a new runner with the specified maximum wait time for execution completion.

A C E F G H I L O P R S T W
All Classes and Interfaces|All Packages