Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- advanceReadyOperations() - Method in class software.amazon.lambda.durable.testing.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.
- ALL_COMPLETED - Enum constant in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
- allCompleted() - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
-
All items run regardless of failures.
- allOf(List<DurableFuture<T>>) - Static method in interface software.amazon.lambda.durable.DurableFuture
-
Waits for all provided futures to complete and returns their results in order.
- allOf(DurableFuture<T>...) - Static method in interface software.amazon.lambda.durable.DurableFuture
-
Waits for all provided futures to complete and returns their results in order.
- allSucceeded() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns true if all items succeeded (no failures or not-started items).
- allSuccessful() - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
-
All items must succeed.
- amount() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
-
Returns the value of the
amountrecord component. - anyOf(DurableFuture<?>...) - Static method in interface software.amazon.lambda.durable.DurableFuture
-
Waits for any of the provided futures to complete and returns its result.
- ApiRequestDelayedBatcher<T> - Class in software.amazon.lambda.durable.execution
-
Batches API requests to optimize throughput by grouping individual calls into batch operations.
- ApiRequestDelayedBatcher(int, int, Function<T, Integer>, Consumer<List<T>>) - Constructor for class software.amazon.lambda.durable.execution.ApiRequestDelayedBatcher
-
Creates a new ApiRequestDelayedBatcher with the specified configuration.
- apply(double) - Method in enum class software.amazon.lambda.durable.retry.JitterStrategy
-
Applies jitter to the given base delay.
- apply(I, int, DurableContext) - Method in interface software.amazon.lambda.durable.DurableContext.MapFunction
-
Applies this function to the given item.
- ApprovalRequest - Record Class in software.amazon.lambda.durable.examples.types
-
Input for the approval workflow.
- ApprovalRequest(String, double) - Constructor for record class software.amazon.lambda.durable.examples.types.ApprovalRequest
- ApprovalRequest(String, double, Integer) - Constructor for record class software.amazon.lambda.durable.examples.types.ApprovalRequest
-
Creates an instance of a
ApprovalRequestrecord class. - AsyncExecution<O> - Class in software.amazon.lambda.durable.testing
-
Handle for an asynchronously executing durable function.
- AsyncExecution(String, LambdaClient, TypeToken<O>, Duration, Duration) - Constructor for class software.amazon.lambda.durable.testing.AsyncExecution
- at(Instant) - Static method in class software.amazon.lambda.durable.retry.PollingStrategies
-
Creates a polling strategy that polls at a specific instant in time.
- AT_LEAST_ONCE_PER_RETRY - Enum constant in enum class software.amazon.lambda.durable.config.StepSemantics
-
At-least-once delivery (default).
- AT_MOST_ONCE_PER_RETRY - Enum constant in enum class software.amazon.lambda.durable.config.StepSemantics
-
At-most-once delivery per retry attempt.
- AwsSdkV2Module - Class in software.amazon.lambda.durable.serde
-
Jackson module that registers custom serializers and deserializers for AWS SDK v2 model classes.
- AwsSdkV2Module() - Constructor for class software.amazon.lambda.durable.serde.AwsSdkV2Module
B
- BaseContext - Interface in software.amazon.lambda.durable.context
- BaseContextImpl - Class in software.amazon.lambda.durable.context
- BaseContextImpl(ExecutionManager, DurableConfig, Context, String, String, ThreadType) - Constructor for class software.amazon.lambda.durable.context.BaseContextImpl
-
Creates a new BaseContext instance.
- BaseDurableOperation - Class in software.amazon.lambda.durable.operation
-
Base class for all durable operations (STEP, WAIT, etc.).
- BaseDurableOperation(OperationIdentifier, DurableContextImpl, BaseDurableOperation) - Constructor for class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Constructs a new durable operation.
- branch(String, Class<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
-
Registers and immediately starts a branch (respects maxConcurrency).
- branch(String, Class<T>, Function<DurableContext, T>, ParallelBranchConfig) - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
-
Registers and immediately starts a branch (respects maxConcurrency).
- branch(String, TypeToken<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
-
Registers and immediately starts a branch (respects maxConcurrency).
- branch(String, TypeToken<T>, Function<DurableContext, T>, ParallelBranchConfig) - Method in class software.amazon.lambda.durable.operation.ParallelOperation
- branch(String, TypeToken<T>, Function<DurableContext, T>, ParallelBranchConfig) - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
-
Registers and immediately starts a branch (respects maxConcurrency).
- build() - Method in class software.amazon.lambda.durable.config.CallbackConfig.Builder
-
Builds the
CallbackConfiginstance. - build() - Method in class software.amazon.lambda.durable.config.InvokeConfig.Builder
-
Builds the InvokeConfig instance.
- build() - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
- build() - Method in class software.amazon.lambda.durable.config.ParallelBranchConfig.Builder
-
Builds the ParallelBranchConfig instance.
- build() - Method in class software.amazon.lambda.durable.config.ParallelConfig.Builder
-
Builds the ParallelConfig instance.
- build() - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig.Builder
-
Builds the RunInChildContextConfig instance.
- build() - Method in class software.amazon.lambda.durable.config.StepConfig.Builder
-
Builds the StepConfig instance.
- build() - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig.Builder
-
Builds the WaitForCallbackConfig instance.
- build() - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig.Builder
- build() - Method in class software.amazon.lambda.durable.DurableConfig.Builder
-
Builds the DurableConfig instance.
- builder() - Static method in class software.amazon.lambda.durable.config.CallbackConfig
-
Creates a new builder with default values.
- builder() - Static method in class software.amazon.lambda.durable.config.InvokeConfig
- builder() - Static method in class software.amazon.lambda.durable.config.MapConfig
- builder() - Static method in class software.amazon.lambda.durable.config.ParallelBranchConfig
-
Creates a new builder for ParallelBranchConfig.
- builder() - Static method in class software.amazon.lambda.durable.config.ParallelConfig
-
Creates a new builder for ParallelConfig.
- builder() - Static method in class software.amazon.lambda.durable.config.RunInChildContextConfig
-
Creates a new builder for RunInChildContextConfig.
- builder() - Static method in class software.amazon.lambda.durable.config.StepConfig
-
Creates a new builder for StepConfig.
- builder() - Static method in class software.amazon.lambda.durable.config.WaitForCallbackConfig
-
Creates a new builder.
- builder() - Static method in class software.amazon.lambda.durable.config.WaitForConditionConfig
-
Creates a new builder for
WaitForConditionConfig. - builder() - Static method in class software.amazon.lambda.durable.DurableConfig
-
Creates a new builder for DurableConfig.
- Builder() - Constructor for class software.amazon.lambda.durable.config.WaitForCallbackConfig.Builder
- Builder() - Constructor for class software.amazon.lambda.durable.DurableConfig.Builder
- Builder(Duration, Duration, SerDes) - Constructor for class software.amazon.lambda.durable.config.CallbackConfig.Builder
- Builder(RetryStrategy, StepSemantics, SerDes) - Constructor for class software.amazon.lambda.durable.config.StepConfig.Builder
- Builder(SerDes) - Constructor for class software.amazon.lambda.durable.config.ParallelBranchConfig.Builder
- Builder(SerDes) - Constructor for class software.amazon.lambda.durable.config.RunInChildContextConfig.Builder
- buildErrorObject(Throwable, SerDes) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
-
build an ErrorObject from a Throwable
C
- callbackConfig() - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig
-
Returns the callback configuration for the composite operation.
- callbackConfig(CallbackConfig) - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig.Builder
-
Sets the callback configuration for the composite operation.
- CallbackConfig - Class in software.amazon.lambda.durable.config
-
Configuration for callback operations.
- CallbackConfig.Builder - Class in software.amazon.lambda.durable.config
-
Builder for
CallbackConfig. - CallbackExample - Class in software.amazon.lambda.durable.examples.callback
-
Example demonstrating callback operations for external system integration.
- CallbackExample() - Constructor for class software.amazon.lambda.durable.examples.callback.CallbackExample
- CallbackException - Exception in software.amazon.lambda.durable.exception
-
Thrown when a callback operation encounters an error.
- CallbackException(Operation, String) - Constructor for exception software.amazon.lambda.durable.exception.CallbackException
- CallbackException(Operation, String, Throwable) - Constructor for exception software.amazon.lambda.durable.exception.CallbackException
- CallbackFailedException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when a callback fails due to an error from the external system.
- CallbackFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.CallbackFailedException
- callbackId() - Method in interface software.amazon.lambda.durable.DurableCallbackFuture
-
Returns the unique identifier for this callback.
- callbackId() - Method in class software.amazon.lambda.durable.operation.CallbackOperation
- CallbackOperation<T> - Class in software.amazon.lambda.durable.operation
-
Durable operation for creating and waiting on external callbacks.
- CallbackOperation(OperationIdentifier, TypeToken<T>, CallbackConfig, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.CallbackOperation
- CallbackSubmitterException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when a callback submitter step fails to submit a callback.
- CallbackSubmitterException(Operation, StepException) - Constructor for exception software.amazon.lambda.durable.exception.CallbackSubmitterException
- CallbackTimeoutException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when a callback times out.
- CallbackTimeoutException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.CallbackTimeoutException
- categories - Variable in class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
- checkpoint(String, String, List<OperationUpdate>) - Method in interface software.amazon.lambda.durable.client.DurableExecutionClient
-
Sends a batch of operation updates to the backend.
- checkpoint(String, String, List<OperationUpdate>) - Method in class software.amazon.lambda.durable.client.LambdaDurableFunctionsClient
- checkpoint(String, String, List<OperationUpdate>) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
- checkpointToken() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
-
Returns the value of the
checkpointTokenrecord component. - ChildContextExample - Class in software.amazon.lambda.durable.examples.child
-
Example demonstrating child context workflows with the Durable Execution SDK.
- ChildContextExample() - Constructor for class software.amazon.lambda.durable.examples.child.ChildContextExample
- ChildContextFailedException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when a child context fails and the original exception cannot be reconstructed.
- ChildContextFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.ChildContextFailedException
- ChildContextOperation<T> - Class in software.amazon.lambda.durable.operation
-
Manages the lifecycle of a child execution context.
- ChildContextOperation(OperationIdentifier, Function<DurableContext, T>, TypeToken<T>, RunInChildContextConfig, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.ChildContextOperation
- ChildContextOperation(OperationIdentifier, Function<DurableContext, T>, TypeToken<T>, RunInChildContextConfig, DurableContextImpl, ConcurrencyOperation<?>) - Constructor for class software.amazon.lambda.durable.operation.ChildContextOperation
- close() - Method in interface software.amazon.lambda.durable.context.BaseContext
-
Closes this context.
- close() - Method in class software.amazon.lambda.durable.context.DurableContextImpl
-
Clears the logger's thread properties.
- close() - Method in class software.amazon.lambda.durable.context.StepContextImpl
-
Closes the logger for this context.
- close() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Shutdown the checkpoint batcher.
- close() - Method in class software.amazon.lambda.durable.logging.DurableLogger
-
Clears all MDC entries.
- close() - Method in class software.amazon.lambda.durable.operation.ParallelOperation
-
Calls
ParallelOperation.get()if not already called. - close() - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
-
Calls
DurableFuture.get()if not already called. - 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.LocalDurableTestRunner
-
Complete a callback with success result.
- completeCallback(String, String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Simulate external system completing callback successfully.
- 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.LocalMemoryExecutionClient
-
Completes a chained invoke operation with the given result, simulating a child Lambda response.
- CompletedDurableFuture<T> - Class in software.amazon.lambda.durable.util
-
A
DurableFuturethat is already completed with a value. - CompletedDurableFuture(T) - Constructor for class software.amazon.lambda.durable.util.CompletedDurableFuture
- completionConfig() - Method in class software.amazon.lambda.durable.config.MapConfig
- completionConfig() - Method in class software.amazon.lambda.durable.config.ParallelConfig
- completionConfig(CompletionConfig) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
-
Sets the completion criteria for the map operation.
- completionConfig(CompletionConfig) - Method in class software.amazon.lambda.durable.config.ParallelConfig.Builder
-
Sets the maximum number of branches that can run simultaneously.
- CompletionConfig - Record Class in software.amazon.lambda.durable.config
-
Controls when a concurrent operation (map or parallel) completes.
- CompletionConfig(Integer, Integer, Double) - Constructor for record class software.amazon.lambda.durable.config.CompletionConfig
-
Creates an instance of a
CompletionConfigrecord class. - completionFuture - Variable in class software.amazon.lambda.durable.operation.BaseDurableOperation
- completionReason() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns the value of the
completionReasonrecord component. - completionStatus() - Method in record class software.amazon.lambda.durable.model.ParallelResult
-
Returns the value of the
completionStatusrecord component. - ComplexMapExample - Class in software.amazon.lambda.durable.examples.map
-
Example demonstrating advanced map features: wait operations inside branches, error handling, and early termination.
- ComplexMapExample() - Constructor for class software.amazon.lambda.durable.examples.map.ComplexMapExample
- computeDelay(int) - Method in interface software.amazon.lambda.durable.retry.PollingStrategy
-
Computes the delay before the next polling attempt.
- ConcurrencyCompletionStatus - Enum Class in software.amazon.lambda.durable.model
- ConcurrencyOperation<T> - Class in software.amazon.lambda.durable.operation
-
Abstract base class for concurrent execution of multiple child context operations.
- ConcurrencyOperation(OperationIdentifier, TypeToken<T>, SerDes, DurableContextImpl, int, Integer, Integer) - Constructor for class software.amazon.lambda.durable.operation.ConcurrencyOperation
- ConcurrentWaitForConditionExample - Class in software.amazon.lambda.durable.examples.wait
-
Example demonstrating concurrent waitForCondition operations using map.
- ConcurrentWaitForConditionExample() - Constructor for class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample
- ConcurrentWaitForConditionExample.Input - Record Class in software.amazon.lambda.durable.examples.wait
- CONTEXT - Enum constant in enum class software.amazon.lambda.durable.execution.ThreadType
- continuePolling(T) - Static method in record class software.amazon.lambda.durable.model.WaitForConditionResult
-
Creates a result indicating polling should continue with the given state.
- counts - Variable in class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
- create(Class<I>, BiFunction<I, DurableContext, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Creates a LocalDurableTestRunner with default configuration.
- create(Class<I>, 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<I>, 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<I>, 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<I>, Class<O>, LambdaClient) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
-
Creates a runner with a custom
LambdaClientand Class-based input/output types. - create(String, TypeToken<I>, 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<I>, TypeToken<O>, LambdaClient) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
-
Creates a runner with a custom
LambdaClientand TypeToken-based input/output types. - create(TypeToken<I>, BiFunction<I, DurableContext, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Creates a LocalDurableTestRunner with default configuration.
- create(TypeToken<I>, 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<I>, DurableHandler<I, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Creates a LocalDurableTestRunner from a DurableHandler instance, automatically extracting the configuration.
- createCallback(String, Class<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Creates a callback with default configuration.
- createCallback(String, Class<T>, CallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Creates a callback with custom configuration.
- createCallback(String, TypeToken<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Creates a callback using a
TypeTokenfor generic result types. - createCallback(String, TypeToken<T>, CallbackConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- createCallback(String, TypeToken<T>, CallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Creates a callback operation that suspends execution until an external system completes it.
- createChildContext(String, String) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
-
Creates a child context.
- createConfiguration() - Method in class software.amazon.lambda.durable.DurableHandler
-
Template method for creating configuration.
- createConfiguration() - Method in class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample
- createConfiguration() - Method in class software.amazon.lambda.durable.examples.general.CustomConfigExample
- createConfiguration() - Method in class software.amazon.lambda.durable.examples.general.CustomPollingExample
- createConfiguration() - Method in class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample
- createItem(String, String, Function<DurableContext, R>, TypeToken<R>, SerDes, OperationSubType, DurableContextImpl) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
-
Creates a child context operation for a single item (branch or iteration).
- createRootContext(ExecutionManager, DurableConfig, Context) - Static method in class software.amazon.lambda.durable.context.DurableContextImpl
-
Creates a root context (contextId = null)
- createStepContext(String, String, int) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
-
Creates a step context for executing step operations.
- CustomConfigExample - Class in software.amazon.lambda.durable.examples.general
-
Example demonstrating custom configuration with both custom HTTP client and custom SerDes.
- CustomConfigExample() - Constructor for class software.amazon.lambda.durable.examples.general.CustomConfigExample
- CustomConfigExample.CustomData - Class in software.amazon.lambda.durable.examples.general
-
Custom data class with camelCase field names to demonstrate snake_case serialization.
- CustomData() - Constructor for class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
- CustomData(String, String, int, String) - Constructor for class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
- CustomPollingExample - Class in software.amazon.lambda.durable.examples.general
-
Example demonstrating custom polling strategy configuration.
- CustomPollingExample() - Constructor for class software.amazon.lambda.durable.examples.general.CustomPollingExample
D
- debug(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
- DEFAULT - Static variable in class software.amazon.lambda.durable.retry.PollingStrategies.Presets
-
Default polling strategy: - Base interval: 1 second - Backoff rate: 2x - Jitter: FULL - Max interval 10 second
- DEFAULT - Static variable in class software.amazon.lambda.durable.retry.RetryStrategies.Presets
-
Default retry strategy: - 6 total attempts (1 initial + 5 retries) - Initial delay: 5 seconds - Max delay: 60 seconds - Backoff rate: 2x - Jitter: FULL
- DEFAULT - Static variable in class software.amazon.lambda.durable.retry.WaitStrategies.Presets
-
Default wait strategy: exponential backoff with 60 max attempts, 5s initial delay, 300s max delay, 1.5x backoff rate, and FULL jitter.
- defaultConfig() - Static method in class software.amazon.lambda.durable.DurableConfig
-
Creates a DurableConfig with default settings.
- defaults() - Static method in record class software.amazon.lambda.durable.logging.LoggerConfig
-
Default configuration: suppress logs during replay.
- defaultStrategy() - Static method in class software.amazon.lambda.durable.retry.WaitStrategies
-
Returns the default wait strategy.
- delay() - Method in class software.amazon.lambda.durable.retry.RetryDecision
- deliveries() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
-
Returns the value of the
deliveriesrecord component. - deregisterActiveThread(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Mark a thread as inactive.
- description() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
-
Returns the value of the
descriptionrecord component. - DeserializationFailedMapExample - Class in software.amazon.lambda.durable.examples.map
-
Example demonstrating the map operation with the Durable Execution SDK.
- DeserializationFailedMapExample() - Constructor for class software.amazon.lambda.durable.examples.map.DeserializationFailedMapExample
- DeserializationFailedParallelExample - Class in software.amazon.lambda.durable.examples.parallel
-
Example demonstrating parallel branch execution with the Durable Execution SDK.
- DeserializationFailedParallelExample() - Constructor for class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample
- DeserializationFailedParallelExample.Input - Record Class in software.amazon.lambda.durable.examples.parallel
- DeserializationFailureExample - Class in software.amazon.lambda.durable.examples.step
- DeserializationFailureExample() - Constructor for class software.amazon.lambda.durable.examples.step.DeserializationFailureExample
- deserialize(String, TypeToken<T>) - Method in class software.amazon.lambda.durable.serde.DurableInputOutputSerDes
-
Deserializes a JSON string to DurableExecutionInput object
- deserialize(String, TypeToken<T>) - Method in class software.amazon.lambda.durable.serde.JacksonSerDes
- deserialize(String, TypeToken<T>) - Method in interface software.amazon.lambda.durable.serde.SerDes
-
Deserializes a JSON string to an object of the specified generic type.
- deserializeException(ErrorObject) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
-
Deserializes an
ErrorObjectback into a throwable, reconstructing the original exception type and stack trace when possible. - deserializeResult(String) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
-
Deserializes a result string into the operation's result type.
- deserializeStackTrace(List<String>) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
-
Deserializes a list of pipe-delimited strings back into stack trace elements.
- DurableCallbackFuture<T> - Interface in software.amazon.lambda.durable
-
Result of creating a callback, containing the callback ID and providing access to the result.
- DurableConfig - Class in software.amazon.lambda.durable
-
Configuration for DurableHandler initialization.
- DurableConfig.Builder - Class in software.amazon.lambda.durable
-
Builder for DurableConfig.
- DurableContext - Interface in software.amazon.lambda.durable
- DurableContext.MapFunction<I,
O> - Interface in software.amazon.lambda.durable -
Function applied to each item in a map operation.
- DurableContextImpl - Class in software.amazon.lambda.durable.context
-
User-facing API for defining durable operations within a workflow.
- durableExecutionArn() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
-
Returns the value of the
durableExecutionArnrecord component. - DurableExecutionClient - Interface in software.amazon.lambda.durable.client
-
Client interface for communicating with the Lambda Durable Functions backend.
- DurableExecutionException - Exception in software.amazon.lambda.durable.exception
-
Base exception for all durable execution errors.
- DurableExecutionException(String) - Constructor for exception software.amazon.lambda.durable.exception.DurableExecutionException
- DurableExecutionException(String, Throwable) - Constructor for exception software.amazon.lambda.durable.exception.DurableExecutionException
- DurableExecutionException(String, Throwable, StackTraceElement[]) - Constructor for exception software.amazon.lambda.durable.exception.DurableExecutionException
- DurableExecutionInput - Record Class in software.amazon.lambda.durable.model
-
Input payload received by the Lambda handler from the Durable Functions backend.
- DurableExecutionInput(String, String, CheckpointUpdatedExecutionState) - Constructor for record class software.amazon.lambda.durable.model.DurableExecutionInput
-
Creates an instance of a
DurableExecutionInputrecord class. - DurableExecutionOutput - Record Class in software.amazon.lambda.durable.model
-
Output payload returned by the Lambda handler to the Durable Functions backend.
- DurableExecutionOutput(ExecutionStatus, String, ErrorObject) - Constructor for record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Creates an instance of a
DurableExecutionOutputrecord class. - DurableExecutor - Class in software.amazon.lambda.durable.execution
-
Orchestrates the lifecycle of a durable execution.
- DurableFuture<T> - Interface in software.amazon.lambda.durable
-
A future representing the result of an asynchronous durable operation.
- DurableHandler<I,
O> - Class in software.amazon.lambda.durable -
Abstract base class for Lambda handlers that use durable execution.
- DurableHandler() - Constructor for class software.amazon.lambda.durable.DurableHandler
- DurableInputOutputSerDes - Class in software.amazon.lambda.durable.serde
-
Serializer/Deserializer for Durable Execution Input and Output objects.
- DurableInputOutputSerDes() - Constructor for class software.amazon.lambda.durable.serde.DurableInputOutputSerDes
- DurableLogger - Class in software.amazon.lambda.durable.logging
-
Logger wrapper that adds durable execution context to log entries via MDC and optionally suppresses logs during replay.
- DurableLogger(Logger, BaseContextImpl) - Constructor for class software.amazon.lambda.durable.logging.DurableLogger
-
Creates a DurableLogger wrapping the given SLF4J logger with execution context MDC entries.
- DurableOperationException - Exception in software.amazon.lambda.durable.exception
-
Exception associated with a specific durable operation, carrying the operation and error details.
- DurableOperationException(Operation, ErrorObject) - Constructor for exception software.amazon.lambda.durable.exception.DurableOperationException
- DurableOperationException(Operation, ErrorObject, String) - Constructor for exception software.amazon.lambda.durable.exception.DurableOperationException
- DurableOperationException(Operation, ErrorObject, String, StackTraceElement[], Throwable) - Constructor for exception software.amazon.lambda.durable.exception.DurableOperationException
- DurableOperationException(Operation, ErrorObject, String, Throwable) - Constructor for exception software.amazon.lambda.durable.exception.DurableOperationException
E
- emailAddress - Variable in class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
- empty() - Static method in record class software.amazon.lambda.durable.model.MapResult
-
Returns an empty MapResult with no items.
- enqueueItem(String, Function<DurableContext, R>, TypeToken<R>, SerDes, OperationSubType) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
-
Creates and enqueues an item without starting execution.
- equals(Object) - Method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.execution.ThreadContext
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.model.MapResult
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.model.ParallelResult
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class software.amazon.lambda.durable.testing.OperationResult
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in class software.amazon.lambda.durable.TypeToken
- error() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Returns the value of the
errorrecord component. - error() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Returns the value of the
errorrecord component. - error() - Method in record class software.amazon.lambda.durable.testing.OperationResult
-
Returns the value of the
errorrecord component. - error(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
- error(String, Throwable) - Method in class software.amazon.lambda.durable.logging.DurableLogger
- ErrorHandlingExample - Class in software.amazon.lambda.durable.examples.general
-
Example demonstrating error handling patterns with the Durable Execution SDK.
- ErrorHandlingExample() - Constructor for class software.amazon.lambda.durable.examples.general.ErrorHandlingExample
- ErrorHandlingExample.ServiceUnavailableException - Exception in software.amazon.lambda.durable.examples.general
-
Custom exception to demonstrate that original exception types are preserved across checkpoints.
- errorMessage() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
-
Returns the value of the
errorMessagerecord component. - errorType() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
-
Returns the value of the
errorTyperecord component. - evaluate(T, int) - Method in interface software.amazon.lambda.durable.retry.WaitForConditionWaitStrategy
-
Computes the delay before the next polling attempt based on the current state and attempt number.
- ExceptionHelper - Class in software.amazon.lambda.durable.util
-
Utility class for handling exceptions
- ExceptionHelper() - Constructor for class software.amazon.lambda.durable.util.ExceptionHelper
- execute() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Starts the operation by checking for an existing checkpoint.
- execute(DurableExecutionInput, Context, TypeToken<I>, BiFunction<I, DurableContext, O>, DurableConfig) - Static method in class software.amazon.lambda.durable.execution.DurableExecutor
- executeItems() - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
-
Starts execution of all enqueued items.
- executionManager - Variable in class software.amazon.lambda.durable.operation.BaseDurableOperation
- ExecutionManager - Class in software.amazon.lambda.durable.execution
-
Central manager for durable execution coordination.
- ExecutionManager(DurableExecutionInput, DurableConfig) - Constructor for class software.amazon.lambda.durable.execution.ExecutionManager
- ExecutionStatus - Enum Class in software.amazon.lambda.durable.model
-
Terminal status of a durable execution.
- executionTimeMs() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
-
Returns the value of the
executionTimeMsrecord component. - executionTimeMs() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
-
Returns the value of the
executionTimeMsrecord component. - exponentialBackoff(int, Duration, Duration, double, JitterStrategy) - Static method in class software.amazon.lambda.durable.retry.RetryStrategies
-
Creates an exponential backoff retry strategy.
- exponentialBackoff(int, Duration, Duration, double, JitterStrategy) - Static method in class software.amazon.lambda.durable.retry.WaitStrategies
-
Creates an exponential backoff wait strategy.
- exponentialBackoff(Duration, double, JitterStrategy, Duration) - Static method in class software.amazon.lambda.durable.retry.PollingStrategies
-
Creates an exponential backoff polling strategy.
F
- fail() - Static method in class software.amazon.lambda.durable.retry.RetryDecision
-
Creates a retry decision indicating the operation should not be retried.
- failCallback(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Fail a callback with error.
- failCallback(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Simulate external system failing callback.
- failChainedInvoke(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Fails a chained invoke operation with the given error.
- failed() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
-
Returns the value of the
failedrecord component. - failed() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns errors from items that failed.
- failed() - Method in record class software.amazon.lambda.durable.model.ParallelResult
-
Returns the value of the
failedrecord component. - failed(MapResult.MapError) - Static method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Creates a failed result item.
- FAILED - Enum constant in enum class software.amazon.lambda.durable.model.ExecutionStatus
- FAILED - Enum constant in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
- failure(ErrorObject) - Static method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Creates a failed output with the given error details.
- FAILURE_TOLERANCE_EXCEEDED - Enum constant in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
- faiure() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
-
Returns the value of the
faiurerecord component. - firstSuccessful() - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Complete as soon as the first item succeeds.
- fixedDelay(int, Duration) - Static method in class software.amazon.lambda.durable.retry.RetryStrategies
-
Creates a simple retry strategy that retries a fixed number of times with a fixed delay.
- fixedDelay(int, Duration) - Static method in class software.amazon.lambda.durable.retry.WaitStrategies
-
Creates a fixed delay wait strategy that returns a constant delay regardless of attempt number or state.
- fixedDelay(Duration) - Static method in class software.amazon.lambda.durable.retry.PollingStrategies
-
Creates a fixed-delay polling strategy that uses the same interval for every attempt.
- FULL - Enum constant in enum class software.amazon.lambda.durable.retry.JitterStrategy
-
Full jitter - random delay between 0 and calculated delay.
- fullName - Variable in class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
G
- GenericInputOutputExample - Class in software.amazon.lambda.durable.examples.general
-
Example demonstrating a durable Lambda function that uses generic types in input and output.
- GenericInputOutputExample() - Constructor for class software.amazon.lambda.durable.examples.general.GenericInputOutputExample
- GenericTypesExample - Class in software.amazon.lambda.durable.examples.general
-
Example demonstrating TypeToken support for complex generic types.
- GenericTypesExample() - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample
- GenericTypesExample.Input - Class in software.amazon.lambda.durable.examples.general
- GenericTypesExample.Output - Class in software.amazon.lambda.durable.examples.general
- get() - Method in interface software.amazon.lambda.durable.DurableFuture
-
Blocks until the operation completes and returns the result.
- get() - Method in class software.amazon.lambda.durable.operation.CallbackOperation
- get() - Method in class software.amazon.lambda.durable.operation.ChildContextOperation
- get() - Method in class software.amazon.lambda.durable.operation.InvokeOperation
-
Blocks until the operation completes and returns the result.
- get() - Method in class software.amazon.lambda.durable.operation.MapOperation
- get() - Method in class software.amazon.lambda.durable.operation.ParallelOperation
- get() - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
- get() - Method in class software.amazon.lambda.durable.operation.StepOperation
- get() - Method in class software.amazon.lambda.durable.operation.WaitForConditionOperation
- get() - Method in class software.amazon.lambda.durable.operation.WaitOperation
- get() - Method in class software.amazon.lambda.durable.util.CompletedDurableFuture
- get(Class<U>) - Static method in class software.amazon.lambda.durable.TypeToken
-
Creates a TypeToken for a simple (non-generic) class.
- getAllEvents() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Get all events in order.
- getAllOperations() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Returns all operations currently stored.
- getAttempt() - Method in class software.amazon.lambda.durable.context.StepContextImpl
-
Returns the current retry attempt number (0-based).
- getAttempt() - Method in interface software.amazon.lambda.durable.StepContext
-
Returns the current retry attempt number (0-based).
- getAttempt() - Method in class software.amazon.lambda.durable.testing.TestOperation
-
Returns the current retry attempt number (0-based), defaulting to 0 if not available.
- getBranches() - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
- getCallbackDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
-
Returns the callback details, or null if this is not a callback operation.
- getCallbackId() - Method in exception software.amazon.lambda.durable.exception.CallbackException
-
Returns the callback ID associated with this exception.
- 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.LocalDurableTestRunner
-
Get callback ID for a named callback operation.
- getCallbackId(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
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.
- getCheckpointDelay() - Method in class software.amazon.lambda.durable.DurableConfig
-
Gets the configured checkpoint delay.
- getChildOperations() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Gets the direct child Operations of this context operation
- getChildOperations(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Gets all child operations for a given operationId.
- getCompletionFuture() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
- getConfiguration() - Method in class software.amazon.lambda.durable.DurableHandler
-
Gets the configuration used by this handler.
- getContext() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Gets the parent context.
- getContextDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
-
Returns the context details, or null if this operation is not a context.
- getContextId() - Method in interface software.amazon.lambda.durable.context.BaseContext
-
Gets the context ID for this context.
- getContextId() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
-
Gets the context ID for this context.
- getContextName() - Method in interface software.amazon.lambda.durable.context.BaseContext
-
Gets the context name for this context.
- getContextName() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
-
Gets the context name for this context.
- getCurrentThreadContext() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Returns the current thread's ThreadContext (threadId and threadType), or null if not set.
- getCurrentThreadContext() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Returns the current thread's context from the execution manager.
- getDurableConfig() - Method in interface software.amazon.lambda.durable.context.BaseContext
-
Returns the configuration for durable execution behavior.
- getDurableConfig() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
-
Returns the configuration for durable execution behavior.
- getDurableExecutionArn() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Returns the ARN of the durable execution being managed.
- getDurableExecutionClient() - Method in class software.amazon.lambda.durable.DurableConfig
-
Gets the configured DurableExecutionClient.
- 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.
- getError(int) - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns the error at the given index, or null if that item succeeded or was not started.
- getErrorObject() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
-
Returns the error details from the failed operation.
- getErrorObject() - Method in exception software.amazon.lambda.durable.exception.UnrecoverableDurableExecutionException
-
Returns the error details for this unrecoverable exception.
- 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.LocalMemoryExecutionClient
-
Get events for a specific 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 interface software.amazon.lambda.durable.context.BaseContext
-
Returns the current durable execution arn
- getExecutionArn() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
-
Returns metadata about the current durable execution.
- 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.
- getExecutionManager() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
- getExecutionOperation() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Returns the initial EXECUTION operation from the checkpoint state.
- getExecutionState(String, String, String) - Method in interface software.amazon.lambda.durable.client.DurableExecutionClient
-
Retrieves the current execution state from the backend.
- getExecutionState(String, String, String) - Method in class software.amazon.lambda.durable.client.LambdaDurableFunctionsClient
- getExecutionState(String, String, String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
- getExecutorService() - Method in class software.amazon.lambda.durable.DurableConfig
-
Gets the configured ExecutorService.
- 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.
- getItem(int) - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns the result item at the given index.
- getLambdaContext() - Method in interface software.amazon.lambda.durable.context.BaseContext
-
Returns the AWS Lambda runtime context.
- getLambdaContext() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
-
Returns the AWS Lambda runtime context.
- getLogger() - Method in interface software.amazon.lambda.durable.context.BaseContext
-
Gets a logger with additional information of the current execution context.
- getLogger() - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- getLogger() - Method in class software.amazon.lambda.durable.context.StepContextImpl
- getLoggerConfig() - Method in class software.amazon.lambda.durable.DurableConfig
-
Gets the configured LoggerConfig.
- getName() - Method in class software.amazon.lambda.durable.examples.types.GreetingRequest
- getName() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Gets the operation name (may be null).
- getName() - Method in class software.amazon.lambda.durable.testing.TestOperation
-
Returns the operation name.
- getOperation() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
-
Returns the operation that caused this exception.
- getOperation() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Gets the Operation from ExecutionManager and update the replay state from REPLAY to EXECUTE if operation is not found.
- 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
TestOperationfor the given name from the last execution result. - getOperation(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Returns the
TestOperationfor the given operation name, or null if not found. - getOperation(String) - Method in class software.amazon.lambda.durable.testing.TestResult
-
Returns the
TestOperationwith the given name, or null if not found. - getOperationAndUpdateReplayState(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Gets an operation by its globally unique operationId, and updates replay state.
- getOperationByName(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Returns the operation with the given name, or null if not found.
- getOperationId() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
-
Returns the ID of the operation that caused this exception.
- getOperationId() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Gets the unique identifier for this operation.
- 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.
- getOperationStatus() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
-
Returns the status of the operation that caused this exception.
- getOperationUpdates() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Get all operation updates that have been sent to this client.
- getPollingStrategy() - Method in class software.amazon.lambda.durable.DurableConfig
-
Gets the polling strategy.
- getResult(int) - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns the result at the given index, or null if that item failed or was not started.
- 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.
- getSerDes() - Method in class software.amazon.lambda.durable.DurableConfig
-
Gets the configured SerDes.
- getServiceName() - Method in exception software.amazon.lambda.durable.examples.general.ErrorHandlingExample.ServiceUnavailableException
- 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
- getSubType() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Gets the operation sub-type (e.g.
- getSucceededOperations() - Method in class software.amazon.lambda.durable.testing.TestResult
-
Returns all operations that completed successfully.
- getType() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Gets the operation type.
- getType() - Method in class software.amazon.lambda.durable.testing.TestOperation
-
Returns the operation type (STEP, WAIT, CALLBACK, etc.).
- getType() - Method in class software.amazon.lambda.durable.TypeToken
-
Returns the captured type.
- getValue() - Method in enum class software.amazon.lambda.durable.model.OperationSubType
-
Returns the wire-format string value sent in checkpoint updates.
- getWaitDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
-
Returns the wait details, or null if this is not a wait operation.
- GreetingRequest - Class in software.amazon.lambda.durable.examples.types
- GreetingRequest() - Constructor for class software.amazon.lambda.durable.examples.types.GreetingRequest
- GreetingRequest(String) - Constructor for class software.amazon.lambda.durable.examples.types.GreetingRequest
H
- HALF - Enum constant in enum class software.amazon.lambda.durable.retry.JitterStrategy
-
Half jitter - random delay between 50% and 100% of calculated delay.
- handleCompletion(ConcurrencyCompletionStatus) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
-
Called when the concurrency operation completes.
- handleCompletion(ConcurrencyCompletionStatus) - Method in class software.amazon.lambda.durable.operation.MapOperation
- handleCompletion(ConcurrencyCompletionStatus) - Method in class software.amazon.lambda.durable.operation.ParallelOperation
- handleRequest(I, DurableContext) - Method in class software.amazon.lambda.durable.DurableHandler
-
Handle the durable execution.
- handleRequest(InputStream, OutputStream, Context) - Method in class software.amazon.lambda.durable.DurableHandler
-
Reads the request, executes the durable function handler and writes the response
- handleRequest(Integer, DurableContext) - Method in class software.amazon.lambda.durable.examples.map.ComplexMapExample
- handleRequest(Integer, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitForConditionExample
- handleRequest(Object, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.ErrorHandlingExample
- handleRequest(Object, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.RetryExample
- handleRequest(Object, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.RetryInProcessExample
- handleRequest(String, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.CustomConfigExample
- handleRequest(String, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.DeserializationFailureExample
- handleRequest(Map<String, String>, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.GenericInputOutputExample
- handleRequest(ManyAsyncChildContextExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample
- handleRequest(GenericTypesExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.GenericTypesExample
- handleRequest(DeserializationFailedParallelExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample
- handleRequest(ParallelExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.parallel.ParallelExample
- handleRequest(ParallelFailureToleranceExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample
- handleRequest(ParallelWithWaitExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample
- handleRequest(ManyAsyncStepsExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample
- handleRequest(ApprovalRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.callback.CallbackExample
- handleRequest(ApprovalRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.callback.WaitForCallbackFailedExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.child.ChildContextExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.CustomPollingExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.LoggingExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.NoopExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.invoke.SimpleInvokeExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.map.DeserializationFailedMapExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.map.SimpleMapExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.SimpleStepExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitAsyncExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitAtLeastExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitAtLeastInProcessExample
- handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitExample
- handleRequest(ConcurrentWaitForConditionExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample
- 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.config.CompletionConfig
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.execution.ThreadContext
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.model.ParallelResult
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
-
Returns a hash code value for this object.
- hashCode() - Method in record class software.amazon.lambda.durable.testing.OperationResult
-
Returns a hash code value for this object.
- hashCode() - Method in class software.amazon.lambda.durable.TypeToken
- hashOperationId(String) - Static method in class software.amazon.lambda.durable.execution.OperationIdGenerator
-
Hashes the given string using SHA-256
- hasOperation(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution
-
Check if an operation with the given name exists.
- hasOperationsForContext(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Checks whether there are any cached operations for the given parent context ID.
- heartbeatTimeout() - Method in class software.amazon.lambda.durable.config.CallbackConfig
-
Returns the maximum duration between heartbeats before the callback is considered failed.
- heartbeatTimeout(Duration) - Method in class software.amazon.lambda.durable.config.CallbackConfig.Builder
-
Sets the maximum duration between heartbeats before the callback is considered failed.
- HistoryEventProcessor - Class in software.amazon.lambda.durable.testing
-
Processes execution history events from the GetDurableExecutionHistory API into
TestResultobjects. - HistoryEventProcessor() - Constructor for class software.amazon.lambda.durable.testing.HistoryEventProcessor
- HistoryPoller - Class in software.amazon.lambda.durable.testing
-
Polls the GetDurableExecutionHistory API until execution completes or a timeout is reached.
- HistoryPoller(LambdaClient) - Constructor for class software.amazon.lambda.durable.testing.HistoryPoller
-
Creates a poller backed by the given Lambda client.
I
- IllegalDurableOperationException - Exception in software.amazon.lambda.durable.exception
-
An illegal operation is detected.
- IllegalDurableOperationException(String) - Constructor for exception software.amazon.lambda.durable.exception.IllegalDurableOperationException
- info(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
- initialExecutionState() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
-
Returns the value of the
initialExecutionStaterecord component. - initialState() - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig
-
Returns the initial state object, or null if not specified.
- initialState(T) - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig.Builder
-
Sets the initial state for the waitForCondition operation.
- Input() - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample.Input
- Input(int, int) - Constructor for record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
-
Creates an instance of a
Inputrecord class. - Input(int, int) - Constructor for record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
-
Creates an instance of a
Inputrecord class. - Input(int, int, int) - Constructor for record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
-
Creates an instance of a
Inputrecord class. - Input(String) - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample.Input
- Input(String, String) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
-
Creates an instance of a
Inputrecord class. - Input(List<String>) - Constructor for record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
-
Creates an instance of a
Inputrecord class. - Input(List<String>) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
-
Creates an instance of a
Inputrecord class. - Input(List<String>, Integer, Integer) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
-
Creates an instance of a
Inputrecord class. - invoke(String, String, U, Class<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Invokes another Lambda function by name and blocks until the result is available.
- invoke(String, String, U, Class<T>, InvokeConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Invokes another Lambda function with custom configuration, blocking until the result is available.
- invoke(String, String, U, TypeToken<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Invokes another Lambda function using a
TypeTokenfor generic result types, blocking until complete. - invoke(String, String, U, TypeToken<T>, InvokeConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Invokes another Lambda function using a
TypeTokenand custom configuration, blocking until complete. - invokeAsync(String, String, U, Class<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously invokes another Lambda function, returning a
DurableFuture. - invokeAsync(String, String, U, Class<T>, InvokeConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Invokes another Lambda function using a
TypeTokenand custom configuration, blocking until complete. - invokeAsync(String, String, U, TypeToken<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously invokes another Lambda function using a
TypeTokenfor generic result types. - invokeAsync(String, String, U, TypeToken<T>, InvokeConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- invokeAsync(String, String, U, TypeToken<T>, InvokeConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously invokes another Lambda function using a
TypeTokenand custom configuration. - InvokeConfig - Class in software.amazon.lambda.durable.config
-
Configuration for chained invoke operations.
- InvokeConfig(InvokeConfig.Builder) - Constructor for class software.amazon.lambda.durable.config.InvokeConfig
- InvokeConfig.Builder - Class in software.amazon.lambda.durable.config
-
Builder for creating InvokeConfig instances.
- InvokeException - Exception in software.amazon.lambda.durable.exception
-
Base exception for chained invoke operation failures.
- InvokeException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.InvokeException
- InvokeFailedException - Exception in software.amazon.lambda.durable.exception
-
Thrown when a chained invoke operation fails with an error in the invoked function.
- InvokeFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.InvokeFailedException
- InvokeOperation<T,
I> - Class in software.amazon.lambda.durable.operation -
Durable operation that invokes another Lambda function and waits for its result.
- InvokeOperation(OperationIdentifier, String, I, TypeToken<T>, InvokeConfig, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.InvokeOperation
- InvokeStoppedException - Exception in software.amazon.lambda.durable.exception
-
Thrown when a chained invoke operation is stopped before completion.
- InvokeStoppedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.InvokeStoppedException
- InvokeTimedOutException - Exception in software.amazon.lambda.durable.exception
-
Thrown when a chained invoke operation exceeds its timeout.
- InvokeTimedOutException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.InvokeTimedOutException
- 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).
- isDone() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
-
Returns the value of the
isDonerecord component. - isExecutionCompletedExceptionally() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
returns
trueif the execution is terminated exceptionally (with aSuspendExecutionExceptionor an unrecoverable error). - isFailed() - Method in class software.amazon.lambda.durable.testing.TestResult
-
Returns true if the execution failed.
- isJoined - Variable in class software.amazon.lambda.durable.operation.ConcurrencyOperation
- isOperationCompleted() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Returns true if this operation has completed (successfully or exceptionally).
- isReplaying() - Method in interface software.amazon.lambda.durable.context.BaseContext
-
Returns whether this context is currently in replay mode.
- isReplaying() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
-
Returns whether this context is currently in replay mode.
- isReplaying() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Returns
trueif the execution is currently replaying completed operations. - isStepInterruptedException(ErrorObject) - Static method in exception software.amazon.lambda.durable.exception.StepInterruptedException
- isSucceeded() - Method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
- isSucceeded() - Method in class software.amazon.lambda.durable.testing.TestResult
-
Returns true if the execution completed successfully.
- isTerminalStatus(OperationStatus) - Static method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Returns
trueif the given status represents a terminal (final) operation state. - items - Variable in class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
- items() - Method in record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
-
Returns the value of the
itemsrecord component. - items() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
-
Returns the value of the
itemsrecord component. - items() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns the value of the
itemsrecord component.
J
- JacksonSerDes - Class in software.amazon.lambda.durable.serde
-
Jackson-based implementation of
SerDes. - JacksonSerDes() - Constructor for class software.amazon.lambda.durable.serde.JacksonSerDes
-
Creates a new JacksonSerDes with default ObjectMapper configuration.
- JacksonSerDes(ObjectMapper) - Constructor for class software.amazon.lambda.durable.serde.JacksonSerDes
-
Creates a new JacksonSerDes with a custom ObjectMapper configuration.
- JitterStrategy - Enum Class in software.amazon.lambda.durable.retry
-
Jitter strategy for retry delays to prevent thundering herd problems.
- join() - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
-
Blocks the calling thread until the concurrency operation reaches a terminal state.
L
- LambdaDurableFunctionsClient - Class in software.amazon.lambda.durable.client
-
Default implementation of
DurableExecutionClientbacked by the AWS Lambda SDK client. - LambdaDurableFunctionsClient(LambdaClient) - Constructor for class software.amazon.lambda.durable.client.LambdaDurableFunctionsClient
-
Creates a LambdaDurableFunctionsClient with the provided LambdaClient.
- 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
-
In-memory implementation of
DurableExecutionClientfor local testing. - LocalMemoryExecutionClient() - Constructor for class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
- LoggerConfig - Record Class in software.amazon.lambda.durable.logging
-
Configuration for DurableLogger behavior.
- LoggerConfig(boolean) - Constructor for record class software.amazon.lambda.durable.logging.LoggerConfig
-
Creates an instance of a
LoggerConfigrecord class. - LoggingExample - Class in software.amazon.lambda.durable.examples.general
-
Example demonstrating DurableLogger usage for structured logging with execution context.
- LoggingExample() - Constructor for class software.amazon.lambda.durable.examples.general.LoggingExample
M
- makeRetryDecision(Throwable, int) - Method in interface software.amazon.lambda.durable.retry.RetryStrategy
-
Determines whether to retry a failed operation and calculates the retry delay.
- ManyAsyncChildContextExample - Class in software.amazon.lambda.durable.examples.child
-
Performance test example demonstrating concurrent async child contexts.
- ManyAsyncChildContextExample() - Constructor for class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample
- ManyAsyncChildContextExample.Input - Record Class in software.amazon.lambda.durable.examples.child
- ManyAsyncChildContextExample.Output - Record Class in software.amazon.lambda.durable.examples.child
- ManyAsyncStepsExample - Class in software.amazon.lambda.durable.examples.step
-
Performance test example demonstrating concurrent async steps.
- ManyAsyncStepsExample() - Constructor for class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample
- ManyAsyncStepsExample.Input - Record Class in software.amazon.lambda.durable.examples.step
- ManyAsyncStepsExample.Output - Record Class in software.amazon.lambda.durable.examples.step
- map(String, Collection<I>, Class<O>, DurableContext.MapFunction<I, O>) - Method in interface software.amazon.lambda.durable.DurableContext
- map(String, Collection<I>, Class<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in interface software.amazon.lambda.durable.DurableContext
- map(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>) - Method in interface software.amazon.lambda.durable.DurableContext
- map(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in interface software.amazon.lambda.durable.DurableContext
- MAP - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
- MAP_ITERATION - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
- mapAsync(String, Collection<I>, Class<O>, DurableContext.MapFunction<I, O>) - Method in interface software.amazon.lambda.durable.DurableContext
- mapAsync(String, Collection<I>, Class<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in interface software.amazon.lambda.durable.DurableContext
- mapAsync(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>) - Method in interface software.amazon.lambda.durable.DurableContext
- mapAsync(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- mapAsync(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in interface software.amazon.lambda.durable.DurableContext
- MapConfig - Class in software.amazon.lambda.durable.config
-
Configuration for map operations.
- MapConfig.Builder - Class in software.amazon.lambda.durable.config
-
Builder for creating MapConfig instances.
- MapError(String, String, List<String>) - Constructor for record class software.amazon.lambda.durable.model.MapResult.MapError
-
Creates an instance of a
MapErrorrecord class. - MapIterationFailedException - Exception in software.amazon.lambda.durable.exception
-
Thrown when a map iteration fails and deserialization of the original exception also fails.
- MapIterationFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.MapIterationFailedException
- MapOperation<I,
O> - Class in software.amazon.lambda.durable.operation -
Executes a map operation: applies a function to each item in a collection concurrently, with each item running in its own child context.
- MapOperation(OperationIdentifier, List<I>, DurableContext.MapFunction<I, O>, TypeToken<O>, MapConfig, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.MapOperation
- MapResult<T> - Record Class in software.amazon.lambda.durable.model
-
Result container for map operations.
- MapResult(List<MapResult.MapResultItem<T>>, ConcurrencyCompletionStatus) - Constructor for record class software.amazon.lambda.durable.model.MapResult
-
Compact constructor that applies defensive copy and defaults.
- MapResult.MapError - Record Class in software.amazon.lambda.durable.model
-
Error details for a failed map item.
- MapResult.MapResultItem<T> - Record Class in software.amazon.lambda.durable.model
-
Represents the outcome of a single item in a map operation.
- MapResult.MapResultItem.Status - Enum Class in software.amazon.lambda.durable.model
-
Status of an individual map item.
- MapResultItem(MapResult.MapResultItem.Status, T, MapResult.MapError) - Constructor for record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Creates an instance of a
MapResultItemrecord class. - markAlreadyCompleted() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Marks the operation as already completed (in replay).
- MAX_OPERATION_NAME_LENGTH - Static variable in class software.amazon.lambda.durable.util.ParameterValidator
- maxConcurrency() - Method in class software.amazon.lambda.durable.config.MapConfig
- maxConcurrency() - Method in class software.amazon.lambda.durable.config.ParallelConfig
- maxConcurrency() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
-
Returns the value of the
maxConcurrencyrecord component. - maxConcurrency(Integer) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
- maxConcurrency(Integer) - Method in class software.amazon.lambda.durable.config.ParallelConfig.Builder
-
Sets the maximum number of branches that can run simultaneously.
- message() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
-
Returns the value of the
messagerecord component. - MIN_SUCCESSFUL_REACHED - Enum constant in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
- minSuccessful() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Returns the value of the
minSuccessfulrecord component. - minSuccessful() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
-
Returns the value of the
minSuccessfulrecord component. - minSuccessful(int) - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Complete when the specified number of items have succeeded.
- multiplier() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
-
Returns the value of the
multiplierrecord component. - multiplier() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
-
Returns the value of the
multiplierrecord component.
N
- name() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Returns the value of the
namerecord component. - nextOperationId() - Method in class software.amazon.lambda.durable.execution.OperationIdGenerator
-
Returns the next globally unique operation ID.
- NO_RETRY - Static variable in class software.amazon.lambda.durable.retry.RetryStrategies.Presets
-
No retry strategy - fails immediately on first error.
- NonDeterministicExecutionException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when non-deterministic code is detected during replay.
- NonDeterministicExecutionException(String) - Constructor for exception software.amazon.lambda.durable.exception.NonDeterministicExecutionException
- NONE - Enum constant in enum class software.amazon.lambda.durable.retry.JitterStrategy
-
No jitter - use exact calculated delay.
- NoopExample - Class in software.amazon.lambda.durable.examples.general
-
Simple example demonstrating a durable function doesn't have any durable operation
- NoopExample() - Constructor for class software.amazon.lambda.durable.examples.general.NoopExample
O
- of(String, String, OperationType) - Static method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Creates an identifier without a sub-type.
- of(String, String, OperationType, OperationSubType) - Static method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Creates an identifier with a sub-type.
- of(Throwable) - Static method in record class software.amazon.lambda.durable.model.MapResult.MapError
- onCheckpointComplete(Operation) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Receives operation updates from ExecutionManager.
- operationId() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Returns the value of the
operationIdrecord component. - OperationIdentifier - Record Class in software.amazon.lambda.durable.model
-
Identifies a durable operation by its unique ID, human-readable name, type, and optional sub-type.
- OperationIdentifier(String, String, OperationType, OperationSubType) - Constructor for record class software.amazon.lambda.durable.model.OperationIdentifier
-
Creates an instance of a
OperationIdentifierrecord class. - OperationIdGenerator - Class in software.amazon.lambda.durable.execution
-
Generates operation IDs for the durable operations.
- OperationIdGenerator(String) - Constructor for class software.amazon.lambda.durable.execution.OperationIdGenerator
- OperationResult - Record Class in software.amazon.lambda.durable.testing
-
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.OperationResult
-
Creates an instance of a
OperationResultrecord class. - operationStatus() - Method in record class software.amazon.lambda.durable.testing.OperationResult
-
Returns the value of the
operationStatusrecord component. - OperationSubType - Enum Class in software.amazon.lambda.durable.model
-
Fine-grained classification of durable operations beyond the basic operation types.
- operationType() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Returns the value of the
operationTyperecord component. - Output() - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
- Output(int, int) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
-
Creates an instance of a
Outputrecord class. - Output(long, long, long) - Constructor for record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
-
Creates an instance of a
Outputrecord class. - Output(long, long, long) - Constructor for record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
-
Creates an instance of a
Outputrecord class. - Output(List<String>, int) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
-
Creates an instance of a
Outputrecord class. - Output(List<String>, int, int) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
-
Creates an instance of a
Outputrecord class. - Output(List<String>, Map<String, Integer>, Map<String, List<String>>) - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
P
- parallel(String) - Method in interface software.amazon.lambda.durable.DurableContext
-
Creates a
ParallelDurableFuturefor executing multiple branches concurrently with default config - parallel(String, ParallelConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- parallel(String, ParallelConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Creates a
ParallelDurableFuturefor executing multiple branches concurrently. - PARALLEL - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
- PARALLEL_BRANCH - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
- ParallelBranchConfig - Class in software.amazon.lambda.durable.config
-
Configuration options for parallel branch in durable executions.
- ParallelBranchConfig.Builder - Class in software.amazon.lambda.durable.config
-
Builder for creating StepConfig instances.
- ParallelBranchFailedException - Exception in software.amazon.lambda.durable.exception
-
Thrown when a parallel branch fails and deserialization of the original exception also fails.
- ParallelBranchFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.ParallelBranchFailedException
- ParallelConfig - Class in software.amazon.lambda.durable.config
-
Configuration options for parallel operations in durable executions.
- ParallelConfig.Builder - Class in software.amazon.lambda.durable.config
-
Builder for creating ParallelConfig instances.
- ParallelDurableFuture - Interface in software.amazon.lambda.durable
-
User-facing context for managing parallel branch execution within a durable function.
- ParallelExample - Class in software.amazon.lambda.durable.examples.parallel
-
Example demonstrating parallel branch execution with the Durable Execution SDK.
- ParallelExample() - Constructor for class software.amazon.lambda.durable.examples.parallel.ParallelExample
- ParallelExample.Input - Record Class in software.amazon.lambda.durable.examples.parallel
- ParallelExample.Output - Record Class in software.amazon.lambda.durable.examples.parallel
- ParallelFailureToleranceExample - Class in software.amazon.lambda.durable.examples.parallel
-
Example demonstrating parallel execution with failure tolerance.
- ParallelFailureToleranceExample() - Constructor for class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample
- ParallelFailureToleranceExample.Input - Record Class in software.amazon.lambda.durable.examples.parallel
- ParallelFailureToleranceExample.Output - Record Class in software.amazon.lambda.durable.examples.parallel
- ParallelOperation - Class in software.amazon.lambda.durable.operation
-
Manages parallel execution of multiple branches as child context operations.
- ParallelOperation(OperationIdentifier, SerDes, DurableContextImpl, ParallelConfig) - Constructor for class software.amazon.lambda.durable.operation.ParallelOperation
- ParallelResult - Record Class in software.amazon.lambda.durable.model
-
Summary result of a parallel operation.
- ParallelResult(int, int, int, ConcurrencyCompletionStatus) - Constructor for record class software.amazon.lambda.durable.model.ParallelResult
-
Creates an instance of a
ParallelResultrecord class. - ParallelWithWaitExample - Class in software.amazon.lambda.durable.examples.parallel
-
Example demonstrating parallel branches where some branches include wait operations.
- ParallelWithWaitExample() - Constructor for class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample
- ParallelWithWaitExample.Input - Record Class in software.amazon.lambda.durable.examples.parallel
- ParallelWithWaitExample.Output - Record Class in software.amazon.lambda.durable.examples.parallel
- ParameterValidator - Class in software.amazon.lambda.durable.util
-
Utility class for validating input parameters in the Durable Execution SDK.
- parentOperation - Variable in class software.amazon.lambda.durable.operation.BaseDurableOperation
- payloadSerDes() - Method in class software.amazon.lambda.durable.config.InvokeConfig
- payloadSerDes(SerDes) - Method in class software.amazon.lambda.durable.config.InvokeConfig.Builder
-
Sets a custom serializer for the invoke operation payload.
- pending() - Static method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Creates a pending output indicating the execution was suspended.
- PENDING - Enum constant in enum class software.amazon.lambda.durable.model.ExecutionStatus
- pollForOperationUpdates() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Polls the backend for updates to this operation.
- pollForOperationUpdates(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
- pollForOperationUpdates(String, Instant) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Pools for operation updates at a specific time
- pollForOperationUpdates(Instant) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Polls the backend for updates to this operation at a specific time.
- PollingStrategies - Class in software.amazon.lambda.durable.retry
-
Factory class for creating common polling strategies.
- PollingStrategies() - Constructor for class software.amazon.lambda.durable.retry.PollingStrategies
- PollingStrategies.Presets - Class in software.amazon.lambda.durable.retry
-
Preset polling strategies for common use cases.
- PollingStrategy - Interface in software.amazon.lambda.durable.retry
-
Functional interface for computing polling delays between attempts.
- 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.HistoryPoller
-
Polls execution history until a terminal event is found or the timeout is exceeded.
- Presets() - Constructor for class software.amazon.lambda.durable.retry.PollingStrategies.Presets
- Presets() - Constructor for class software.amazon.lambda.durable.retry.RetryStrategies.Presets
- Presets() - Constructor for class software.amazon.lambda.durable.retry.WaitStrategies.Presets
- processEvents(List<Event>, TypeToken<O>) - Method in class software.amazon.lambda.durable.testing.HistoryEventProcessor
-
Processes a list of execution history events into a structured
TestResult.
R
- registerActiveThread(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Registers a thread as active.
- registerActiveThread(String) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Registers a thread as active in the execution manager.
- registerOperation(BaseDurableOperation) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Registers an operation so it can receive checkpoint completion notifications.
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Replays the operation from an existing checkpoint.
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.CallbackOperation
-
Replays the operation.
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.ChildContextOperation
-
Replays the operation.
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.InvokeOperation
-
Replays the operation.
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.MapOperation
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.ParallelOperation
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.StepOperation
-
Replays the operation.
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.WaitForConditionOperation
- replay(Operation) - Method in class software.amazon.lambda.durable.operation.WaitOperation
-
Replays the operation.
- replayTimeMs() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
-
Returns the value of the
replayTimeMsrecord component. - replayTimeMs() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
-
Returns the value of the
replayTimeMsrecord component. - reset() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Clears all operations and events, resetting the client to its initial state.
- resetCheckpointToStarted(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Resets a named step operation to STARTED status, simulating a checkpoint failure.
- resetCheckpointToStarted(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Simulate checkpoint failure by forcing an operation into STARTED state
- result() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
-
Returns the value of the
resultrecord component. - result() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
-
Returns the value of the
resultrecord component. - result() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Returns the value of the
resultrecord component. - result() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Returns the value of the
resultrecord component. - result() - Method in record class software.amazon.lambda.durable.testing.OperationResult
-
Returns the value of the
resultrecord component. - results() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
-
Returns the value of the
resultsrecord component. - results() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns all results as an unmodifiable list (nulls for failed/not-started items).
- retry(Duration) - Static method in class software.amazon.lambda.durable.retry.RetryDecision
-
Creates a retry decision indicating the operation should be retried after the specified delay.
- RetryDecision - Class in software.amazon.lambda.durable.retry
-
Represents a decision about whether to retry a failed operation and how long to wait.
- RetryExample - Class in software.amazon.lambda.durable.examples.step
-
Simple example demonstrating retry strategies with a flaky API.
- RetryExample() - Constructor for class software.amazon.lambda.durable.examples.step.RetryExample
- RetryInProcessExample - Class in software.amazon.lambda.durable.examples.step
-
Example demonstrating in-process retry behavior with concurrent operations.
- RetryInProcessExample() - Constructor for class software.amazon.lambda.durable.examples.step.RetryInProcessExample
- RetryStrategies - Class in software.amazon.lambda.durable.retry
-
Factory class for creating common retry strategies.
- RetryStrategies() - Constructor for class software.amazon.lambda.durable.retry.RetryStrategies
- RetryStrategies.Presets - Class in software.amazon.lambda.durable.retry
-
Preset retry strategies for common use cases.
- retryStrategy() - Method in class software.amazon.lambda.durable.config.StepConfig
-
Returns the retry strategy for this step, or the default strategy if not specified.
- retryStrategy(RetryStrategy) - Method in class software.amazon.lambda.durable.config.StepConfig.Builder
-
Sets the retry strategy for the step.
- RetryStrategy - Interface in software.amazon.lambda.durable.retry
-
Functional interface for determining retry behavior when operations fail.
- 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).
- RUN_IN_CHILD_CONTEXT - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
- runInChildContext(String, Class<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Runs a function in a child context, blocking until it completes.
- runInChildContext(String, Class<T>, Function<DurableContext, T>, RunInChildContextConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Runs a function in a child context, blocking until it completes.
- runInChildContext(String, TypeToken<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Runs a function in a child context using a
TypeTokenfor generic result types, blocking until complete. - runInChildContext(String, TypeToken<T>, Function<DurableContext, T>, RunInChildContextConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Runs a function in a child context, blocking until it completes.
- runInChildContextAsync(String, Class<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Runs a function in a child context, blocking until it completes.
- runInChildContextAsync(String, Class<T>, Function<DurableContext, T>, RunInChildContextConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Runs a function in a child context, blocking until it completes.
- runInChildContextAsync(String, TypeToken<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Runs a function in a child context, blocking until it completes.
- runInChildContextAsync(String, TypeToken<T>, Function<DurableContext, T>, RunInChildContextConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
-
Runs a function in a child context, blocking until it completes.
- runInChildContextAsync(String, TypeToken<T>, Function<DurableContext, T>, RunInChildContextConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Runs a function in a child context, blocking until it completes.
- RunInChildContextConfig - Class in software.amazon.lambda.durable.config
-
Configuration options for RunInChildContext operations in durable executions.
- RunInChildContextConfig.Builder - Class in software.amazon.lambda.durable.config
-
Builder for creating StepConfig instances.
- 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.
- runUntilCompleteOrSuspend(CompletableFuture<T>) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
return a future that completes when userFuture completes successfully or the execution is terminated or suspended.
- runUserHandler(Runnable, String, ThreadType) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
S
- semantics() - Method in class software.amazon.lambda.durable.config.StepConfig
-
Returns the delivery semantics for this step, defaults to AT_LEAST_ONCE_PER_RETRY if not specified.
- semantics(StepSemantics) - Method in class software.amazon.lambda.durable.config.StepConfig.Builder
-
Sets the delivery semantics for the step.
- sendOperationUpdate(OperationUpdate) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
- sendOperationUpdate(OperationUpdate.Builder) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Sends an operation update synchronously (blocks until the update is acknowledged).
- sendOperationUpdateAsync(OperationUpdate.Builder) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Sends an operation update asynchronously.
- serDes() - Method in class software.amazon.lambda.durable.config.CallbackConfig
-
Returns the custom serializer for this callback, or null if not specified (uses default SerDes).
- serDes() - Method in class software.amazon.lambda.durable.config.InvokeConfig
- serDes() - Method in class software.amazon.lambda.durable.config.MapConfig
- serDes() - Method in class software.amazon.lambda.durable.config.ParallelBranchConfig
-
Returns the custom serializer for this step, or null if not specified (uses default SerDes).
- serDes() - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig
-
Returns the custom serializer for this RunInChildContext operation, or null if not specified (uses default SerDes).
- serDes() - Method in class software.amazon.lambda.durable.config.StepConfig
-
Returns the custom serializer for this step, or null if not specified (uses default SerDes).
- serDes() - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig
-
Returns the custom serializer, or null if not specified (uses default SerDes).
- serDes(SerDes) - Method in class software.amazon.lambda.durable.config.CallbackConfig.Builder
-
Sets a custom serializer for the callback.
- serDes(SerDes) - Method in class software.amazon.lambda.durable.config.InvokeConfig.Builder
-
Sets a custom serializer for the invoke result.
- serDes(SerDes) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
-
Sets the custom serializer to use for serializing map items and results.
- serDes(SerDes) - Method in class software.amazon.lambda.durable.config.ParallelBranchConfig.Builder
-
Sets a custom serializer for the step.
- serDes(SerDes) - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig.Builder
-
Sets a custom serializer for the step.
- serDes(SerDes) - Method in class software.amazon.lambda.durable.config.StepConfig.Builder
-
Sets a custom serializer for the step.
- serDes(SerDes) - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig.Builder
-
Sets a custom serializer for the waitForCondition operation.
- SerDes - Interface in software.amazon.lambda.durable.serde
-
Interface for serialization and deserialization of objects.
- SerDesException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when serialization or deserialization fails.
- SerDesException(String) - Constructor for exception software.amazon.lambda.durable.exception.SerDesException
- SerDesException(String, Throwable) - Constructor for exception software.amazon.lambda.durable.exception.SerDesException
- SerializableDurableOperation<T> - Class in software.amazon.lambda.durable.operation
-
Base class for all durable operations (STEP, WAIT, etc.).
- SerializableDurableOperation(OperationIdentifier, TypeToken<T>, SerDes, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.SerializableDurableOperation
-
Constructs a new durable operation.
- SerializableDurableOperation(OperationIdentifier, TypeToken<T>, SerDes, DurableContextImpl, BaseDurableOperation) - Constructor for class software.amazon.lambda.durable.operation.SerializableDurableOperation
- serialize(Object) - Method in class software.amazon.lambda.durable.serde.DurableInputOutputSerDes
-
Serializes an object to a JSON string.
- serialize(Object) - Method in class software.amazon.lambda.durable.serde.JacksonSerDes
- serialize(Object) - Method in interface software.amazon.lambda.durable.serde.SerDes
-
Serializes an object to a JSON string.
- serializeException(Throwable) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
-
Serializes a throwable into an
ErrorObjectfor checkpointing. - serializeResult(T) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
-
Serializes the result to a string.
- serializeStackTrace(StackTraceElement[]) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
-
Serializes a stack trace to a list of pipe-delimited strings in the format
className|methodName|fileName|lineNumber. - services() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
-
Returns the value of the
servicesrecord component. - ServiceUnavailableException() - Constructor for exception software.amazon.lambda.durable.examples.general.ErrorHandlingExample.ServiceUnavailableException
-
Default constructor required for Jackson deserialization.
- ServiceUnavailableException(String, String) - Constructor for exception software.amazon.lambda.durable.examples.general.ErrorHandlingExample.ServiceUnavailableException
- setCurrentThreadContext(ThreadContext) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Sets the current thread's ThreadContext (threadId and threadType).
- setExecutionMode() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
-
Transitions this context from replay to execution mode.
- setName(String) - Method in class software.amazon.lambda.durable.examples.types.GreetingRequest
- shouldRetry() - Method in class software.amazon.lambda.durable.retry.RetryDecision
- SimpleInvokeExample - Class in software.amazon.lambda.durable.examples.invoke
-
Simple example demonstrating basic invoke execution with the Durable Execution SDK.
- SimpleInvokeExample() - Constructor for class software.amazon.lambda.durable.examples.invoke.SimpleInvokeExample
- SimpleMapExample - Class in software.amazon.lambda.durable.examples.map
-
Example demonstrating the map operation with the Durable Execution SDK.
- SimpleMapExample() - Constructor for class software.amazon.lambda.durable.examples.map.SimpleMapExample
- SimpleStepExample - Class in software.amazon.lambda.durable.examples.step
-
Simple example demonstrating basic step execution with the Durable Execution SDK.
- SimpleStepExample() - Constructor for class software.amazon.lambda.durable.examples.step.SimpleStepExample
- 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.
- simulateFireAndForgetCheckpointLoss(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Simulate fire-and-forget checkpoint loss by removing the operation entirely
- size() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns the number of items in this result.
- size() - Method in record class software.amazon.lambda.durable.model.ParallelResult
-
Returns the value of the
sizerecord component. - skipped() - Static method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Creates a skipped result item.
- SKIPPED - Enum constant in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
- sneakyThrow(Throwable) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
-
Throws any exception as if it were unchecked using type erasure.
- software.amazon.lambda.durable - package software.amazon.lambda.durable
- software.amazon.lambda.durable.client - package software.amazon.lambda.durable.client
- software.amazon.lambda.durable.config - package software.amazon.lambda.durable.config
- software.amazon.lambda.durable.context - package software.amazon.lambda.durable.context
- software.amazon.lambda.durable.examples.callback - package software.amazon.lambda.durable.examples.callback
- software.amazon.lambda.durable.examples.child - package software.amazon.lambda.durable.examples.child
- software.amazon.lambda.durable.examples.general - package software.amazon.lambda.durable.examples.general
- software.amazon.lambda.durable.examples.invoke - package software.amazon.lambda.durable.examples.invoke
- software.amazon.lambda.durable.examples.map - package software.amazon.lambda.durable.examples.map
- software.amazon.lambda.durable.examples.parallel - package software.amazon.lambda.durable.examples.parallel
- software.amazon.lambda.durable.examples.step - package software.amazon.lambda.durable.examples.step
- software.amazon.lambda.durable.examples.types - package software.amazon.lambda.durable.examples.types
- software.amazon.lambda.durable.examples.wait - package software.amazon.lambda.durable.examples.wait
- software.amazon.lambda.durable.exception - package software.amazon.lambda.durable.exception
- software.amazon.lambda.durable.execution - package software.amazon.lambda.durable.execution
- software.amazon.lambda.durable.logging - package software.amazon.lambda.durable.logging
- software.amazon.lambda.durable.model - package software.amazon.lambda.durable.model
- software.amazon.lambda.durable.operation - package software.amazon.lambda.durable.operation
- software.amazon.lambda.durable.retry - package software.amazon.lambda.durable.retry
- software.amazon.lambda.durable.serde - package software.amazon.lambda.durable.serde
- software.amazon.lambda.durable.testing - package software.amazon.lambda.durable.testing
- software.amazon.lambda.durable.util - package software.amazon.lambda.durable.util
- stackTrace() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
-
Returns the value of the
stackTracerecord component. - start() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Starts the operation on first execution (no existing checkpoint).
- start() - Method in class software.amazon.lambda.durable.operation.CallbackOperation
-
Starts the operation.
- start() - Method in class software.amazon.lambda.durable.operation.ChildContextOperation
-
Starts the operation.
- start() - Method in class software.amazon.lambda.durable.operation.InvokeOperation
-
Starts the operation.
- start() - Method in class software.amazon.lambda.durable.operation.MapOperation
- start() - Method in class software.amazon.lambda.durable.operation.ParallelOperation
- start() - Method in class software.amazon.lambda.durable.operation.StepOperation
-
Starts the operation.
- start() - Method in class software.amazon.lambda.durable.operation.WaitForConditionOperation
- start() - Method in class software.amazon.lambda.durable.operation.WaitOperation
-
Starts the operation.
- startAsync(I) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
-
Start an asynchronous execution and return a handle for incremental polling.
- status() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Returns the value of the
statusrecord component. - status() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Returns the value of the
statusrecord component. - step(String, Class<T>, Function<StepContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Executes a durable step with the given name and blocks until it completes.
- step(String, Class<T>, Function<StepContext, T>, StepConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Executes a durable step with the given name and configuration, blocking until it completes.
- step(String, Class<T>, Supplier<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Deprecated.use the variants accepting StepContext instead
- step(String, Class<T>, Supplier<T>, StepConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Deprecated.use the variants accepting StepContext instead
- step(String, TypeToken<T>, Function<StepContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Executes a durable step using a
TypeTokenfor generic result types, blocking until it completes. - step(String, TypeToken<T>, Function<StepContext, T>, StepConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Executes a durable step using a
TypeTokenand configuration, blocking until it completes. - step(String, TypeToken<T>, Supplier<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Deprecated.use the variants accepting StepContext instead
- step(String, TypeToken<T>, Supplier<T>, StepConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Deprecated.use the variants accepting StepContext instead
- STEP - Enum constant in enum class software.amazon.lambda.durable.execution.ThreadType
- stepAsync(String, Class<T>, Function<StepContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously executes a durable step, returning a
DurableFuturethat can be composed or blocked on. - stepAsync(String, Class<T>, Function<StepContext, T>, StepConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously executes a durable step using custom configuration.
- stepAsync(String, Class<T>, Supplier<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Deprecated.use the variants accepting StepContext instead
- stepAsync(String, Class<T>, Supplier<T>, StepConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Deprecated.use the variants accepting StepContext instead
- stepAsync(String, TypeToken<T>, Function<StepContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously executes a durable step using a
TypeTokenfor generic result types. - stepAsync(String, TypeToken<T>, Function<StepContext, T>, StepConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- stepAsync(String, TypeToken<T>, Function<StepContext, T>, StepConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously executes a durable step using a
TypeTokenand custom configuration. - stepAsync(String, TypeToken<T>, Supplier<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Deprecated.use the variants accepting StepContext instead
- stepAsync(String, TypeToken<T>, Supplier<T>, StepConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Deprecated.use the variants accepting StepContext instead
- stepConfig() - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig
-
Returns the step configuration for the composite operation.
- stepConfig(StepConfig) - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig.Builder
-
Sets the step configuration for the composite operation.
- StepConfig - Class in software.amazon.lambda.durable.config
-
Configuration options for step operations in durable executions.
- StepConfig.Builder - Class in software.amazon.lambda.durable.config
-
Builder for creating StepConfig instances.
- StepContext - Interface in software.amazon.lambda.durable
- StepContextImpl - Class in software.amazon.lambda.durable.context
-
Context available inside a step operation's user function.
- StepContextImpl(ExecutionManager, DurableConfig, Context, String, String, int) - Constructor for class software.amazon.lambda.durable.context.StepContextImpl
-
Creates a new StepContext instance for use in step operations.
- StepException - Exception in software.amazon.lambda.durable.exception
-
Base exception for step operation failures.
- StepException(Operation, ErrorObject, String) - Constructor for exception software.amazon.lambda.durable.exception.StepException
- StepFailedException - Exception in software.amazon.lambda.durable.exception
-
Thrown when a step operation fails after exhausting all retry attempts.
- StepFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.StepFailedException
- StepInterruptedException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when a step with AT_MOST_ONCE_PER_RETRY semantics was started but interrupted before completion.
- StepInterruptedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.StepInterruptedException
- StepOperation<T> - Class in software.amazon.lambda.durable.operation
-
Durable operation that executes a user-provided function with retry support.
- StepOperation(OperationIdentifier, Function<StepContext, T>, TypeToken<T>, StepConfig, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.StepOperation
- steps() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
-
Returns the value of the
stepsrecord component. - steps() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
-
Returns the value of the
stepsrecord component. - StepSemantics - Enum Class in software.amazon.lambda.durable.config
-
Delivery semantics for step operations.
- stopChainedInvoke(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Stops a chained invoke operation with the given error.
- stopPolling(T) - Static method in record class software.amazon.lambda.durable.model.WaitForConditionResult
-
Creates a result indicating the condition is met and polling should stop.
- subType() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Returns the value of the
subTyperecord component. - succeeded() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
-
Returns the value of the
succeededrecord component. - succeeded() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns results from items that succeeded (includes null results from successful items).
- succeeded() - Method in record class software.amazon.lambda.durable.model.ParallelResult
-
Returns the value of the
succeededrecord component. - succeeded(T) - Static method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Creates a successful result item.
- SUCCEEDED - Enum constant in enum class software.amazon.lambda.durable.model.ExecutionStatus
- SUCCEEDED - Enum constant in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
- success() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
-
Returns the value of the
successrecord component. - success(String) - Static method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Creates a successful output with the given serialized result.
- suppressReplayLogs() - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
-
Returns the value of the
suppressReplayLogsrecord component. - suspendExecution() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Suspends the execution by completing the execution exception future with a
SuspendExecutionException. - SuspendExecutionException - Exception in software.amazon.lambda.durable.execution
-
Exception thrown to suspend execution during wait operations.
- SuspendExecutionException() - Constructor for exception software.amazon.lambda.durable.execution.SuspendExecutionException
T
- tenantId() - Method in class software.amazon.lambda.durable.config.InvokeConfig
- tenantId(String) - Method in class software.amazon.lambda.durable.config.InvokeConfig.Builder
-
Sets the tenant ID for the invoke operation.
- terminateExecution(UnrecoverableDurableExecutionException) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
-
Terminates the execution immediately with an unrecoverable error.
- terminateExecution(UnrecoverableDurableExecutionException) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Terminates the execution with the given exception.
- terminateExecutionWithIllegalDurableOperationException(String) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Terminates the execution with an
IllegalDurableOperationException. - TestOperation - Class in software.amazon.lambda.durable.testing
-
Wrapper for AWS SDK Operation providing convenient access methods.
- 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.
- ThreadContext - Record Class in software.amazon.lambda.durable.execution
-
Holds the current thread's execution context.
- ThreadContext(String, ThreadType) - Constructor for record class software.amazon.lambda.durable.execution.ThreadContext
-
Creates an instance of a
ThreadContextrecord class. - threadId() - Method in record class software.amazon.lambda.durable.execution.ThreadContext
-
Returns the value of the
threadIdrecord component. - threadType() - Method in record class software.amazon.lambda.durable.execution.ThreadContext
-
Returns the value of the
threadTyperecord component. - ThreadType - Enum Class in software.amazon.lambda.durable.execution
-
Thread type enum for tracking conceptual threads in durable execution.
- threshold() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
-
Returns the value of the
thresholdrecord component. - timeout() - Method in class software.amazon.lambda.durable.config.CallbackConfig
-
Returns the maximum duration to wait for the callback to complete.
- timeout(Duration) - Method in class software.amazon.lambda.durable.config.CallbackConfig.Builder
-
Sets the maximum duration to wait for the callback to complete before timing out.
- timeoutCallback(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Timeout a callback.
- timeoutCallback(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Simulate callback timeout.
- timeoutChainedInvoke(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
-
Marks a chained invoke operation as timed out.
- timeoutSeconds() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
-
Returns the value of the
timeoutSecondsrecord component. - toBuilder() - Method in class software.amazon.lambda.durable.config.CallbackConfig
-
Creates a new builder pre-populated with this config's values.
- toBuilder() - Method in class software.amazon.lambda.durable.config.InvokeConfig
- toBuilder() - Method in class software.amazon.lambda.durable.config.MapConfig
- toBuilder() - Method in class software.amazon.lambda.durable.config.ParallelBranchConfig
- toBuilder() - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig
- toBuilder() - Method in class software.amazon.lambda.durable.config.StepConfig
- toBuilder() - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig
-
Creates a builder pre-populated with this instance's values.
- toBuilder() - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig
-
Returns a new builder initialized with the values from this config.
- toleratedFailureCount() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Returns the value of the
toleratedFailureCountrecord component. - toleratedFailureCount(int) - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Complete when more than the specified number of failures have occurred.
- toleratedFailurePercentage() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Returns the value of the
toleratedFailurePercentagerecord component. - toleratedFailurePercentage(double) - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Complete when the failure percentage exceeds the specified threshold (0.0 to 1.0).
- toleratedFailures() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
-
Returns the value of the
toleratedFailuresrecord component. - toString() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.execution.ThreadContext
-
Returns a string representation of this record class.
- toString() - Method in enum class software.amazon.lambda.durable.execution.ThreadType
- toString() - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
-
Returns a string representation of this record class.
- toString() - Method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
- toString() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
-
Returns a string representation of this record class.
- toString() - Method in enum class software.amazon.lambda.durable.model.ExecutionStatus
- toString() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.model.MapResult
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
-
Returns a string representation of this record class.
- toString() - Method in enum class software.amazon.lambda.durable.model.OperationSubType
- toString() - Method in record class software.amazon.lambda.durable.model.ParallelResult
-
Returns a string representation of this record class.
- toString() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
-
Returns a string representation of this record class.
- toString() - Method in class software.amazon.lambda.durable.retry.RetryDecision
- toString() - Method in record class software.amazon.lambda.durable.testing.OperationResult
-
Returns a string representation of this record class.
- toString() - Method in class software.amazon.lambda.durable.TypeToken
- totalOperations() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
-
Returns the value of the
totalOperationsrecord component. - totalProcessed() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
-
Returns the value of the
totalProcessedrecord component. - toTestResult(DurableExecutionOutput) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
-
Build TestResult from current state.
- trace(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
- TypeToken<T> - Class in software.amazon.lambda.durable
-
Framework-agnostic type token for capturing generic type information at runtime.
- TypeToken() - Constructor for class software.amazon.lambda.durable.TypeToken
-
Constructs a new TypeToken.
U
- UnrecoverableDurableExecutionException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when the execution is not recoverable.
- UnrecoverableDurableExecutionException(ErrorObject) - Constructor for exception software.amazon.lambda.durable.exception.UnrecoverableDurableExecutionException
- unwrapCompletableFuture(Throwable) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
-
unwrap the exception that is wrapped by CompletionException
- userAge - Variable in class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
- userId - Variable in class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
- userId - Variable in class software.amazon.lambda.durable.examples.general.GenericTypesExample.Input
- userId() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
-
Returns the value of the
userIdrecord component.
V
- validateConfiguration() - Method in class software.amazon.lambda.durable.DurableConfig
- validateDuration(Duration, String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
-
Validates that a duration is at least 1 second.
- validateOperationName(String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
- validateOperationName(String, int) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
- validateOptionalDuration(Duration, String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
-
Validates that an optional duration (if provided) is at least 1 second.
- validateOptionalPositiveInteger(Integer, String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
-
Validates that an optional integer value (if provided) is positive (greater than 0).
- validateOrderedCollection(Collection<?>) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
-
Validates that a collection has deterministic iteration order.
- validatePositiveInteger(Integer, String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
-
Validates that an integer value is positive (greater than 0).
- validateReplay(Operation) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Validates that current operation matches checkpointed operation during replay.
- value() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
-
Returns the value of the
valuerecord component. - valueOf(String) - Static method in enum class software.amazon.lambda.durable.config.StepSemantics
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class software.amazon.lambda.durable.execution.ThreadType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class software.amazon.lambda.durable.model.ExecutionStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class software.amazon.lambda.durable.model.OperationSubType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class software.amazon.lambda.durable.retry.JitterStrategy
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class software.amazon.lambda.durable.config.StepSemantics
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class software.amazon.lambda.durable.execution.ThreadType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class software.amazon.lambda.durable.model.ExecutionStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class software.amazon.lambda.durable.model.OperationSubType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class software.amazon.lambda.durable.retry.JitterStrategy
-
Returns an array containing the constants of this enum class, in the order they are declared.
W
- wait(String, Duration) - Method in interface software.amazon.lambda.durable.DurableContext
-
Suspends execution for the specified duration without consuming compute resources.
- WAIT_FOR_CALLBACK - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
- WAIT_FOR_CONDITION - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
- waitAsync(String, Duration) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- waitAsync(String, Duration) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously suspends execution for the specified duration.
- WaitAsyncExample - Class in software.amazon.lambda.durable.examples.wait
-
Example demonstrating non-blocking wait with waitAsync().
- WaitAsyncExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitAsyncExample
- WaitAtLeastExample - Class in software.amazon.lambda.durable.examples.wait
-
Example demonstrating concurrent stepAsync() with wait() operations.
- WaitAtLeastExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitAtLeastExample
- WaitAtLeastInProcessExample - Class in software.amazon.lambda.durable.examples.wait
-
Example demonstrating concurrent stepAsync() with wait() operations where no suspension occurs.
- WaitAtLeastInProcessExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitAtLeastInProcessExample
- WaitExample - Class in software.amazon.lambda.durable.examples.wait
-
Example demonstrating step execution with wait operations.
- WaitExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitExample
- waitForCallback(String, Class<T>, BiConsumer<String, StepContext>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Executes a submitter function and waits for an external callback, blocking until the callback completes.
- waitForCallback(String, Class<T>, BiConsumer<String, StepContext>, WaitForCallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Executes a submitter and waits for an external callback with custom configuration, blocking until complete.
- waitForCallback(String, TypeToken<T>, BiConsumer<String, StepContext>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Executes a submitter and waits for an external callback using a
TypeToken, blocking until complete. - waitForCallback(String, TypeToken<T>, BiConsumer<String, StepContext>, WaitForCallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Executes a submitter and waits for an external callback using a
TypeTokenand custom configuration. - waitForCallbackAsync(String, Class<T>, BiConsumer<String, StepContext>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously executes a submitter and waits for an external callback.
- waitForCallbackAsync(String, Class<T>, BiConsumer<String, StepContext>, WaitForCallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously executes a submitter and waits for an external callback with custom configuration.
- waitForCallbackAsync(String, TypeToken<T>, BiConsumer<String, StepContext>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously executes a submitter and waits for an external callback using a
TypeToken. - waitForCallbackAsync(String, TypeToken<T>, BiConsumer<String, StepContext>, WaitForCallbackConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- waitForCallbackAsync(String, TypeToken<T>, BiConsumer<String, StepContext>, WaitForCallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously executes a submitter and waits for an external callback using a
TypeTokenand custom configuration. - WaitForCallbackConfig - Class in software.amazon.lambda.durable.config
-
Configuration for the
waitForCallbackcomposite operation. - WaitForCallbackConfig.Builder - Class in software.amazon.lambda.durable.config
-
Builder for
WaitForCallbackConfig. - WaitForCallbackFailedExample - Class in software.amazon.lambda.durable.examples.callback
- WaitForCallbackFailedExample() - Constructor for class software.amazon.lambda.durable.examples.callback.WaitForCallbackFailedExample
- waitForCondition(String, Class<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Polls a condition function until it signals done, blocking until complete.
- waitForCondition(String, Class<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>, WaitForConditionConfig<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Polls a condition function until it signals done, using a custom configuration, blocking until complete.
- waitForCondition(String, TypeToken<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Polls a condition function until it signals done, using a
TypeToken, blocking until complete. - waitForCondition(String, TypeToken<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>, WaitForConditionConfig<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Polls a condition function until it signals done, using a
TypeTokenand custom configuration, blocking until complete. - waitForConditionAsync(String, Class<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously polls a condition function until it signals done.
- waitForConditionAsync(String, Class<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>, WaitForConditionConfig<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously polls a condition function until it signals done, using custom configuration.
- waitForConditionAsync(String, TypeToken<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously polls a condition function until it signals done, using a
TypeToken. - waitForConditionAsync(String, TypeToken<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>, WaitForConditionConfig<T>) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
- waitForConditionAsync(String, TypeToken<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>, WaitForConditionConfig<T>) - Method in interface software.amazon.lambda.durable.DurableContext
-
Asynchronously polls a condition function until it signals done, using a
TypeTokenand custom configuration. - WaitForConditionConfig<T> - Class in software.amazon.lambda.durable.config
-
Configuration for
waitForConditionoperations. - WaitForConditionConfig.Builder<T> - Class in software.amazon.lambda.durable.config
- WaitForConditionExample - Class in software.amazon.lambda.durable.examples.wait
-
Example demonstrating the waitForCondition operation.
- WaitForConditionExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitForConditionExample
- WaitForConditionFailedException - Exception in software.amazon.lambda.durable.exception
-
Exception thrown when a
waitForConditionoperation fails. - WaitForConditionFailedException(String) - Constructor for exception software.amazon.lambda.durable.exception.WaitForConditionFailedException
- WaitForConditionFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.WaitForConditionFailedException
- WaitForConditionOperation<T> - Class in software.amazon.lambda.durable.operation
-
Durable operation that periodically checks a user-supplied condition function, using a configurable wait strategy to determine polling intervals and termination.
- WaitForConditionOperation(String, String, BiFunction<T, StepContext, WaitForConditionResult<T>>, TypeToken<T>, WaitForConditionConfig<T>, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.WaitForConditionOperation
- WaitForConditionResult<T> - Record Class in software.amazon.lambda.durable.model
-
Result returned by a WaitForCondition check function to signal whether the condition is met.
- WaitForConditionResult(T, boolean) - Constructor for record class software.amazon.lambda.durable.model.WaitForConditionResult
-
Creates an instance of a
WaitForConditionResultrecord class. - WaitForConditionWaitStrategy<T> - Interface in software.amazon.lambda.durable.retry
-
Strategy that computes the delay before the next polling attempt in a
waitForConditionoperation. - waitForOperationCompletion() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
-
Waits for the operation to complete.
- WaitOperation - Class in software.amazon.lambda.durable.operation
-
Durable operation that suspends execution for a specified duration without consuming compute.
- WaitOperation(OperationIdentifier, Duration, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.WaitOperation
- WaitStrategies - Class in software.amazon.lambda.durable.retry
-
Factory class for creating common
WaitForConditionWaitStrategyimplementations. - WaitStrategies() - Constructor for class software.amazon.lambda.durable.retry.WaitStrategies
- WaitStrategies.Presets - Class in software.amazon.lambda.durable.retry
-
Preset wait strategies for common use cases.
- waitStrategy() - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig
-
Returns the wait strategy that controls polling behavior.
- waitStrategy(WaitForConditionWaitStrategy<T>) - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig.Builder
-
Sets the wait strategy for the waitForCondition operation.
- warn(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
- withCheckpointDelay(Duration) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
-
Sets how often the SDK checkpoints updates to backend.
- withDurableExecutionClient(DurableExecutionClient) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
-
Sets a custom DurableExecutionClient.
- withExecutorService(ExecutorService) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
-
Sets a custom ExecutorService for running user-defined operations.
- withInvocationType(InvocationType) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
-
Returns a new runner with the specified Lambda invocation type.
- withLambdaClientBuilder(LambdaClientBuilder) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
-
Sets a custom LambdaClient for production use.
- withLoggerConfig(LoggerConfig) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
-
Sets a custom LoggerConfig.
- withPollingStrategy(PollingStrategy) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
-
Sets the polling strategy.
- withPollInterval(Duration) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
-
Returns a new runner with the specified poll interval between history checks.
- withReplayLogging() - Static method in record class software.amazon.lambda.durable.logging.LoggerConfig
-
Configuration that allows logs during replay.
- withSerDes(SerDes) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
-
Sets a custom SerDes implementation.
- withTimeout(Duration) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
-
Returns a new runner with the specified maximum wait time for execution completion.
- wrap(TypeToken<I>, BiFunction<I, DurableContext, O>, DurableConfig) - Static method in class software.amazon.lambda.durable.execution.DurableExecutor
-
Wraps a user handler in a RequestHandler that can be used by the Lambda runtime.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form