Index

A B C D E F G H I J L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

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.
allCompleted() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
 
allItemsRegistered() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Returns the value of the allItemsRegistered record component.
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.
anyOf(DurableFuture<?>...) - Static method in interface software.amazon.lambda.durable.DurableFuture
Waits for any of the provided futures to complete and returns its result.
API_VERSION - Static variable in interface software.amazon.lambda.durable.plugin.DurableExecutionPluginProvider
Current version of the dynamic plugin provider contract.
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.
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.
attachContext() - Static method in class software.amazon.lambda.durable.logging.DurableLogger
 
attempt() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the attempt record component.
attempt() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the attempt record component.
attempt() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the attempt record component.
attempt() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns the value of the attempt record component.
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
 
BaseDurableOperation(OperationIdentifier, DurableContextImpl, BaseDurableOperation, boolean) - 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 CallbackConfig instance.
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.config.WithRetryConfig.Builder
Builds the WithRetryConfig instance.
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.config.WithRetryConfig
Creates a new builder for WithRetryConfig.
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
 
buildErrorObject(Throwable, SerDes) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
build an ErrorObject from a Throwable

C

CALLBACK - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
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.
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
 
CHAINED_INVOKE - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
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
 
checkpointToken() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
Returns the value of the checkpointToken record component.
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
 
classifyException(AwsServiceException) - Static method in class software.amazon.lambda.durable.util.DurableApiErrorClassifier
Classifies the given exception and returns the appropriate exception to throw.
close() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Shutdown the checkpoint batcher.
close() - Method in interface software.amazon.lambda.durable.model.SafeCloseable
 
close() - Method in class software.amazon.lambda.durable.operation.ParallelOperation
Calls ParallelOperation.get() if not already called.
complete(ConcurrencyCompletionStatus) - Static method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionDecision
 
completed() - Method in record class software.amazon.lambda.durable.operation.ConcurrencyOperation.ExpectedCompletionStatus
Returns the value of the completed record component.
completedCount() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Returns the value of the completedCount record component.
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
 
CompletionConfig(Integer, Integer, Double, Function<CompletionConfig.CompletionStatus, CompletionConfig.CompletionDecision>) - Constructor for record class software.amazon.lambda.durable.config.CompletionConfig
Creates an instance of a CompletionConfig record class.
CompletionConfig.CompletionDecision - Record Class in software.amazon.lambda.durable.config
The completion decision returned by CompletionConfig.completionDecisionFunction().
CompletionConfig.CompletionStatus - Record Class in software.amazon.lambda.durable.config
Live completion progress for a map or parallel operation.
completionDecision() - Method in record class software.amazon.lambda.durable.operation.ConcurrencyOperation.ExpectedCompletionStatus
Returns the value of the completionDecision record component.
CompletionDecision(boolean, ConcurrencyCompletionStatus) - Constructor for record class software.amazon.lambda.durable.config.CompletionConfig.CompletionDecision
Creates an instance of a CompletionDecision record class.
completionDecisionFunction() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
Returns the completion decision function.
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 completionReason record component.
completionStatus() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionDecision
Returns the value of the completionStatus record component.
completionStatus() - Method in record class software.amazon.lambda.durable.model.ParallelResult
Returns the value of the completionStatus record component.
CompletionStatus(int, int, int, int) - Constructor for record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
 
CompletionStatus(int, int, int, int, boolean) - Constructor for record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Creates an instance of a CompletionStatus record class.
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, Function<CompletionConfig.CompletionStatus, CompletionConfig.CompletionDecision>, NestingType) - Constructor for class software.amazon.lambda.durable.operation.ConcurrencyOperation
 
ConcurrencyOperation.ExpectedCompletionStatus - Record Class in software.amazon.lambda.durable.operation
 
CONTEXT - Enum constant in enum class software.amazon.lambda.durable.execution.ThreadType
 
CONTEXT - Static variable in interface software.amazon.lambda.durable.context.BaseContext
 
continueExecution() - Static method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionDecision
 
continuePolling(T) - Static method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Creates a result indicating polling should continue with the given state.
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 TypeToken for 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, boolean) - 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.
createItem(String, String, Function<DurableContext, R>, TypeToken<R>, SerDes, OperationSubType) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
Creates a child context operation for a single item (branch or iteration).
createPlugin() - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPluginProvider
Creates the plugin instance.
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.
CUSTOM_COMPLETION_FAILED - Enum constant in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
 
CUSTOM_COMPLETION_SUCCEEDED - Enum constant in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
 

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
 
deregisterActiveThread(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Mark a thread as inactive.
deregisterActiveThread(String) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
 
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.
deserialized() - Method in record class software.amazon.lambda.durable.operation.SerializableDurableOperation.SerializedResult
Returns the value of the deserialized record component.
DeserializedOperationResult<T> - Record Class in software.amazon.lambda.durable.model
 
DeserializedOperationResult(OperationStatus, T, Throwable) - Constructor for record class software.amazon.lambda.durable.model.DeserializedOperationResult
Creates an instance of a DeserializedOperationResult record class.
deserializeException(ErrorObject) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
Deserializes an ErrorObject back 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.
detachContext() - Static method in class software.amazon.lambda.durable.logging.DurableLogger
 
DurableApiErrorClassifier - Class in software.amazon.lambda.durable.util
Classifies AWS service exceptions from Durable Execution API calls as non-retryable or retryable.
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 durableExecutionArn record component.
durableExecutionArn() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the durableExecutionArn record component.
durableExecutionArn() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns the value of the durableExecutionArn record component.
durableExecutionArn() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeInfo
Returns the value of the durableExecutionArn record component.
DurableExecutionClient - Interface in software.amazon.lambda.durable.client
Client interface for communicating with the Lambda Durable Functions backend.
DurableExecutionError - Error in software.amazon.lambda.durable.execution
A throwable error that can be used internally by Durable Execution SDK.
DurableExecutionError(String) - Constructor for error software.amazon.lambda.durable.execution.DurableExecutionError
 
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
Constructor that defaults updatedOperationIds to empty list.
DurableExecutionInput(String, String, CheckpointUpdatedExecutionState, List<String>) - Constructor for record class software.amazon.lambda.durable.model.DurableExecutionInput
Creates an instance of a DurableExecutionInput record 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 DurableExecutionOutput record class.
DurableExecutionPlugin - Interface in software.amazon.lambda.durable.plugin
Plugin interface for instrumenting durable execution lifecycle events.
DurableExecutionPluginProvider - Interface in software.amazon.lambda.durable.plugin
Service provider interface for dynamically loading DurableExecutionPlugin implementations.
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
 
DurableHandler(TypeToken<I>) - Constructor for class software.amazon.lambda.durable.DurableHandler
Constructs a handler with an explicitly provided input type.
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) - 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

empty() - Static method in record class software.amazon.lambda.durable.model.MapResult
Returns an empty MapResult with no items.
endTimestamp() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the endTimestamp record component.
endTimestamp() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the endTimestamp record component.
endTimestamp() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the endTimestamp record component.
endTimestamp() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the endTimestamp record component.
enqueueItem(String, Function<DurableContext, R>, TypeToken<R>, SerDes, OperationSubType, boolean) - 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.CompletionDecision
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Indicates whether some other object is "equal to" this one.
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.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.DeserializedOperationResult
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.operation.ConcurrencyOperation.ExpectedCompletionStatus
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.operation.SerializableDurableOperation.SerializedResult
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.plugin.OperationChangeInfo
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
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 error record component.
error() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Returns the value of the error record component.
error() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the error record component.
error() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the error record component.
error() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the error record 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
 
errorMessage() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
Returns the value of the errorMessage record component.
errorType() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
Returns the value of the errorType record 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.
executeItems(ConcurrencyOperation.ExpectedCompletionStatus) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
Starts execution of all enqueued items until the expectedCompletionStatus is met.
executionError() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the executionError record component.
executionInput() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the executionInput record component.
executionInput() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns the value of the executionInput record component.
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, Context) - Constructor for class software.amazon.lambda.durable.execution.ExecutionManager
 
executionResult() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the executionResult record component.
executionStartTime() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the executionStartTime record component.
executionStartTime() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns the value of the executionStartTime record component.
ExecutionStatus - Enum Class in software.amazon.lambda.durable.model
Terminal status of a durable execution.
ExpectedCompletionStatus(int, CompletionConfig.CompletionDecision) - Constructor for record class software.amazon.lambda.durable.operation.ConcurrencyOperation.ExpectedCompletionStatus
Creates an instance of a ExpectedCompletionStatus record class.
Experimental - Annotation Interface in software.amazon.lambda.durable.annotations
Marks a public API as experimental.
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.
extractErrorFromOperation(Operation) - Static method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Extracts the error from a terminal operation as a Throwable.

F

fail() - Static method in class software.amazon.lambda.durable.retry.RetryDecision
Creates a retry decision indicating the operation should not be retried.
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 failed record component.
failed(Throwable) - Static method in record class software.amazon.lambda.durable.model.DeserializedOperationResult
 
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
 
FAILED - Enum constant in enum class software.amazon.lambda.durable.model.ParallelResult.Status
 
FAILED - Enum constant in enum class software.amazon.lambda.durable.plugin.InvocationStatus
Execution failed permanently in this invocation.
FAILED - Enum constant in enum class software.amazon.lambda.durable.plugin.UserFunctionOutcome
The user function threw an error.
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
 
failureCount() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Returns the value of the failureCount record component.
fireOnOperationEnd(Operation, Throwable, boolean) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Fires onOperationEnd plugin hook when an operation reaches terminal status.
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.
FLAT - Enum constant in enum class software.amazon.lambda.durable.config.NestingType
Skip CONTEXT operations for branches/iterations using virtual contexts.
FULL - Enum constant in enum class software.amazon.lambda.durable.retry.JitterStrategy
Full jitter - random delay between 0 and calculated delay.

G

get() - Method in interface software.amazon.lambda.durable.DurableFuture
Blocks until the operation completes and returns the result.
get() - Method in record class software.amazon.lambda.durable.model.DeserializedOperationResult
 
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(Class<U>) - Static method in class software.amazon.lambda.durable.TypeToken
Creates a TypeToken for a simple (non-generic) class.
getApiVersion() - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPluginProvider
Returns the provider API version this implementation supports.
getAttempt() - Method in class software.amazon.lambda.durable.context.StepContextImpl
Returns the current retry attempt number (1-based).
getAttempt() - Method in interface software.amazon.lambda.durable.StepContext
Returns the current retry attempt number (1-based).
getBranches() - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
 
getCallbackId() - Method in exception software.amazon.lambda.durable.exception.CallbackException
Returns the callback ID associated with this exception.
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.
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.
getCurrentContext() - Static method in interface software.amazon.lambda.durable.context.BaseContext
Gets the current context (DurableContext or StepContext) for this thread.
getCurrentContext() - Static method in interface software.amazon.lambda.durable.DurableContext
 
getCurrentContext() - Static method in interface software.amazon.lambda.durable.StepContext
 
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.
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.
getErrorObject(Operation) - Static method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Extracts the ErrorObject from an operation based on its type.
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.
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
 
getExecutorService() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the configured ExecutorService.
getInitialOperationIds() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns the ids of the operations delivered in this invocation's initial state.
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.BaseContextImpl
Returns a durable logger for this context.
getLogger(Logger) - Method in interface software.amazon.lambda.durable.context.BaseContext
Gets a logger with additional information of the current execution context.
getLogger(Logger) - Method in class software.amazon.lambda.durable.context.BaseContextImpl
Returns a durable logger for this context.
getLoggerConfig() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the configured LoggerConfig.
getName() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the operation name (may be null).
getName() - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPluginProvider
Returns the stable name used to select this provider.
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.
getOperationAndUpdateReplayState(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Gets an operation by its globally unique operationId, and updates replay state.
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.
getOperationsSnapshot() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns an immutable snapshot of the operations currently tracked for this execution, including the initial EXECUTION operation.
getOperationStatus() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
Returns the status of the operation that caused this exception.
getOperationType() - Method in enum class software.amazon.lambda.durable.model.OperationSubType
Returns the parent OperationType for this subtype.
getParentId() - Method in class software.amazon.lambda.durable.context.DurableContextImpl
Get the parent context ID for its child operations, which always points to a non-virtual context
getPluginRunner() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the plugin runner that dispatches lifecycle events to registered plugins.
getPlugins() - Method in class software.amazon.lambda.durable.plugin.PluginRunner
Returns the list of registered plugins.
getPluginType() - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPluginProvider
Returns the concrete plugin type created by this provider.
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.
getRunningUserHandler() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
 
getSerDes() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the configured SerDes.
getSubType() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the operation sub-type (e.g.
getType() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the operation type.
getType() - Method in class software.amazon.lambda.durable.TypeToken
Returns the captured type.
getUpdatedOperationsSnapshot() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns the subset of ExecutionManager.getOperationsSnapshot() whose ids the backend reported as updated since the last successful invocation.
getValue() - Method in enum class software.amazon.lambda.durable.model.OperationSubType
Returns the wire-format string value sent in checkpoint updates.

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(CompletionConfig.CompletionDecision) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
Called when the concurrency operation completes.
handleCompletion(CompletionConfig.CompletionDecision) - Method in class software.amazon.lambda.durable.operation.MapOperation
 
handleCompletion(CompletionConfig.CompletionDecision) - 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
hasCustomShouldComplete() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
 
hashCode() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionDecision
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Returns a hash code value for this object.
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.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.DeserializedOperationResult
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.operation.ConcurrencyOperation.ExpectedCompletionStatus
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.operation.SerializableDurableOperation.SerializedResult
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeInfo
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
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
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.

I

id() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the id record component.
id() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the id record component.
id() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the id record component.
id() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the id record component.
id() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns the value of the id record component.
IllegalDurableOperationException - Exception in software.amazon.lambda.durable.exception
An illegal operation is detected.
IllegalDurableOperationException(String) - Constructor for exception software.amazon.lambda.durable.exception.IllegalDurableOperationException
 
INCOMPLETE - Enum constant in enum class software.amazon.lambda.durable.plugin.UserFunctionOutcome
The user function exited before completing, for example when the durable execution suspended.
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 initialExecutionState record 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.
INSTANCE - Static variable in class software.amazon.lambda.durable.logging.DurableLogger
 
InvocationEndInfo - Record Class in software.amazon.lambda.durable.plugin
Information provided at the end of a Lambda invocation.
InvocationEndInfo(String, String, boolean, Instant, Map<String, OperationChangeItemInfo>, InvocationStatus, Throwable, Object, Object) - Constructor for record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Creates an instance of a InvocationEndInfo record class.
InvocationEndInfo(String, String, boolean, InvocationStatus, Throwable) - Constructor for record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Creates invocation-end information without execution payloads or operation state.
InvocationEndInfo(String, String, boolean, InvocationStatus, Throwable, Object, Object) - Constructor for record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Creates invocation-end information without execution start time or operation state.
InvocationInfo - Record Class in software.amazon.lambda.durable.plugin
Invocation-level information available to plugin hooks.
InvocationInfo(String, String, boolean, Instant) - Constructor for record class software.amazon.lambda.durable.plugin.InvocationInfo
Creates invocation information without payload or operation snapshots.
InvocationInfo(String, String, boolean, Instant, Object) - Constructor for record class software.amazon.lambda.durable.plugin.InvocationInfo
Creates invocation information without operation snapshots.
InvocationInfo(String, String, boolean, Instant, Object, Map<String, OperationChangeItemInfo>, Map<String, OperationChangeItemInfo>) - Constructor for record class software.amazon.lambda.durable.plugin.InvocationInfo
Creates an instance of a InvocationInfo record class.
InvocationInfo(String, String, boolean, Instant, Map<String, OperationChangeItemInfo>, Map<String, OperationChangeItemInfo>) - Constructor for record class software.amazon.lambda.durable.plugin.InvocationInfo
Creates invocation information without an execution input.
invocationStatus() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the invocationStatus record component.
InvocationStatus - Enum Class in software.amazon.lambda.durable.plugin
Status of a Lambda invocation at the end of its execution.
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 TypeToken for 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 TypeToken and 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 TypeToken and 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 TypeToken for 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 TypeToken and 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
 
isDone() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Returns the value of the isDone record component.
isEmpty() - Method in class software.amazon.lambda.durable.plugin.PluginRunner
Returns true if no plugins are registered.
isExecutionCompletedExceptionally() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
returns true if the execution is terminated exceptionally (with a SuspendExecutionException or an unrecoverable error).
isFirstInvocation() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the isFirstInvocation record component.
isFirstInvocation() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns the value of the isFirstInvocation record component.
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).
isOperationUpdatedSinceLastInvocation(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns true if the given operation was updated since the last successful invocation.
isReplay() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the isReplay record component.
isReplay() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the isReplay record component.
isReplay() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the isReplay record component.
isReplay() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the isReplay record component.
isReplay() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns the value of the isReplay record component.
isReplaying() - Method in class software.amazon.lambda.durable.context.DurableContextImpl
Returns whether this context is currently in replay mode.
isReplaying() - Method in interface software.amazon.lambda.durable.DurableContext
Returns whether this context is currently replaying checkpointed durable operations.
isReplaying() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns true if the execution is currently replaying completed operations.
isRetryable() - Method in exception software.amazon.lambda.durable.exception.UnrecoverableDurableExecutionException
Returns true if the execution can be retried.
isStepInterruptedException(ErrorObject) - Static method in exception software.amazon.lambda.durable.exception.StepInterruptedException
 
isSucceeded() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionDecision
 
isSucceeded() - Method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
 
isTerminalStatus(OperationStatus) - Static method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns true if the given status represents a terminal (final) operation state.
isVirtual - Variable in class software.amazon.lambda.durable.operation.BaseDurableOperation
 
isVirtual() - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig
Returns true if the context operation will not be checkpointed, false otherwise.
isVirtual(Boolean) - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig.Builder
Sets whether the context is virtual (not checkpointed) or not.
itemNamer() - Method in class software.amazon.lambda.durable.config.MapConfig
Returns the function used to name map iterations.
itemNamer(Class<I>, BiFunction<? super I, Integer, String>) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
Sets a function that names each nested map iteration, typed to the map's item class.
itemNamer(BiFunction<Object, Integer, String>) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
Sets a function that names each nested map iteration.
items() - Method in record class software.amazon.lambda.durable.model.MapResult
Returns the value of the items record 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 DurableExecutionClient backed by the AWS Lambda SDK client.
LambdaDurableFunctionsClient(LambdaClient) - Constructor for class software.amazon.lambda.durable.client.LambdaDurableFunctionsClient
Creates a LambdaDurableFunctionsClient with the provided LambdaClient.
LINEAR - Static variable in class software.amazon.lambda.durable.retry.RetryStrategies.Presets
Linear retry strategy: - 6 total attempts (1 initial + 5 retries) - Initial delay: 1 second - Max delay: 5 seconds - Increment: 1 second - Jitter: NONE
linearBackoff(int, Duration, Duration) - Static method in class software.amazon.lambda.durable.retry.RetryStrategies
Creates a linear backoff retry strategy.
linearBackoff(int, Duration, Duration, Duration, JitterStrategy) - Static method in class software.amazon.lambda.durable.retry.RetryStrategies
Creates a linear backoff retry strategy.
LoggerConfig - Record Class in software.amazon.lambda.durable.logging
Configuration for DurableLogger behavior.
LoggerConfig(boolean, boolean) - Constructor for record class software.amazon.lambda.durable.logging.LoggerConfig
Creates an instance of a LoggerConfig record class.

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.
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 MapError record 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, List<String>, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.MapOperation
 
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 MapResultItem record 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(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.
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 minSuccessful record component.
minSuccessful(int) - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
Complete when the specified number of items have succeeded.

N

name() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns the value of the name record component.
name() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the name record component.
name() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the name record component.
name() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the name record component.
name() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the name record component.
name() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns the value of the name record component.
NESTED - Enum constant in enum class software.amazon.lambda.durable.config.NestingType
Create CONTEXT operations for each branch/iteration with full checkpointing.
nestingType - Variable in class software.amazon.lambda.durable.config.MapConfig.Builder
 
nestingType() - Method in class software.amazon.lambda.durable.config.MapConfig
 
nestingType() - Method in class software.amazon.lambda.durable.config.ParallelConfig
 
nestingType(NestingType) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
Sets the nesting type for the map operation.
nestingType(NestingType) - Method in class software.amazon.lambda.durable.config.ParallelConfig.Builder
Sets the nesting type for the parallel operation.
NestingType - Enum Class in software.amazon.lambda.durable.config
 
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.
noOp() - Static method in class software.amazon.lambda.durable.plugin.PluginRunner
Returns a no-op runner that does nothing.

O

of(String, String, OperationSubType) - Static method in record class software.amazon.lambda.durable.model.OperationIdentifier
Creates an identifier with the given sub-type.
of(Throwable) - Static method in record class software.amazon.lambda.durable.model.MapResult.MapError
 
oldKeyNames() - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
Returns the value of the oldKeyNames record component.
onCheckpointComplete(Operation) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Receives operation updates from ExecutionManager.
onInvocationEnd(InvocationEndInfo) - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPlugin
Called at the end of each Lambda invocation.
onInvocationEnd(InvocationEndInfo) - Method in class software.amazon.lambda.durable.plugin.PluginRunner
Called at the end of each invocation.
onInvocationStart(InvocationInfo) - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPlugin
Called at the start of each Lambda invocation.
onInvocationStart(InvocationInfo) - Method in class software.amazon.lambda.durable.plugin.PluginRunner
 
onOperationChange(OperationChangeInfo) - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPlugin
Called when a checkpoint response changes the status of one or more operations.
onOperationChange(OperationChangeInfo) - Method in class software.amazon.lambda.durable.plugin.PluginRunner
 
onOperationEnd(OperationEndInfo) - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPlugin
Called once when an operation's terminal status is first observed.
onOperationEnd(OperationEndInfo) - Method in class software.amazon.lambda.durable.plugin.PluginRunner
 
onOperationStart(OperationInfo) - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPlugin
Called when an operation starts (including replay).
onOperationStart(OperationInfo) - Method in class software.amazon.lambda.durable.plugin.PluginRunner
 
onUserFunctionEnd(UserFunctionEndInfo) - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPlugin
Called when a user-provided function finishes executing.
onUserFunctionEnd(UserFunctionEndInfo) - Method in class software.amazon.lambda.durable.plugin.PluginRunner
 
onUserFunctionStart(UserFunctionStartInfo) - Method in interface software.amazon.lambda.durable.plugin.DurableExecutionPlugin
Called when a user-provided function starts executing.
onUserFunctionStart(UserFunctionStartInfo) - Method in class software.amazon.lambda.durable.plugin.PluginRunner
 
OperationChangeInfo - Record Class in software.amazon.lambda.durable.plugin
Information provided when a checkpoint response changes one or more operations.
OperationChangeInfo(String, String, Map<String, OperationChangeItemInfo>, Map<String, OperationChangeItemInfo>) - Constructor for record class software.amazon.lambda.durable.plugin.OperationChangeInfo
Creates an instance of a OperationChangeInfo record class.
OperationChangeItemInfo - Record Class in software.amazon.lambda.durable.plugin
Operation-level information for an OperationChangeInfo and invocation operation snapshot.
OperationChangeItemInfo(String, String, String, String, String, Instant, Instant, OperationStatus, Integer, boolean, Throwable, String) - Constructor for record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Creates an instance of a OperationChangeItemInfo record class.
OperationEndInfo - Record Class in software.amazon.lambda.durable.plugin
Extended operation information for operation end events.
OperationEndInfo(String, String, String, String, String, Instant, Instant, String, Integer, boolean, Throwable) - Constructor for record class software.amazon.lambda.durable.plugin.OperationEndInfo
Creates operation-end information without a result.
OperationEndInfo(String, String, String, String, String, Instant, Instant, String, Integer, boolean, Throwable, String) - Constructor for record class software.amazon.lambda.durable.plugin.OperationEndInfo
Creates an instance of a OperationEndInfo record class.
operationId() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns the value of the operationId record component.
OperationIdentifier - Record Class in software.amazon.lambda.durable.model
Identifies a durable operation by its unique ID, human-readable name, type and sub-type.
OperationIdentifier(String, String, OperationSubType) - Constructor for record class software.amazon.lambda.durable.model.OperationIdentifier
Creates an instance of a OperationIdentifier record 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
 
OperationInfo - Record Class in software.amazon.lambda.durable.plugin
Operation-level information available to plugin hooks.
OperationInfo(String, String, String, String, String, Instant, Instant, String, boolean) - Constructor for record class software.amazon.lambda.durable.plugin.OperationInfo
Creates an instance of a OperationInfo record class.
operations() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the operations record component.
operations() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns the value of the operations record component.
operations() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeInfo
Returns the value of the operations record component.
OperationSubType - Enum Class in software.amazon.lambda.durable.model
Fine-grained classification of durable operations that pairs each subtype with its parent OperationType.
operationType() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns the operation type derived from the sub-type.
outcome() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the outcome record component.

P

parallel(String) - Method in interface software.amazon.lambda.durable.DurableContext
Creates a ParallelDurableFuture for 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 ParallelDurableFuture for 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.
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, int, ConcurrencyCompletionStatus, List<ParallelResult.Status>) - Constructor for record class software.amazon.lambda.durable.model.ParallelResult
Creates an instance of a ParallelResult record class.
ParallelResult.Status - Enum Class in software.amazon.lambda.durable.model
Status of an individual parallel branch.
ParameterValidator - Class in software.amazon.lambda.durable.util
Utility class for validating input parameters in the Durable Execution SDK.
parentId() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the parentId record component.
parentId() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the parentId record component.
parentId() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the parentId record component.
parentId() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the parentId record component.
parentId() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns the value of the parentId record component.
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
 
PENDING - Enum constant in enum class software.amazon.lambda.durable.plugin.InvocationStatus
Execution suspended — will resume in a future invocation.
PluginInfoConverter - Class in software.amazon.lambda.durable.plugin
Utility methods for converting SDK internal types to plugin info records.
PluginRunner - Class in software.amazon.lambda.durable.plugin
Composes multiple DurableExecutionPlugin instances into a single dispatcher.
PluginRunner(List<DurableExecutionPlugin>) - Constructor for class software.amazon.lambda.durable.plugin.PluginRunner
 
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.
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
 
processCheckpointUpdate(Operation, Runnable) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Publishes a checkpoint update and notifies this operation under the same lock used by operation waiters.

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.
replayCompletedOperation - Variable in class software.amazon.lambda.durable.operation.BaseDurableOperation
 
requestId() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns the value of the requestId record component.
requestId() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns the value of the requestId record component.
requestId() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeInfo
Returns the value of the requestId record component.
resolveIterationNames(String, List<?>, MapConfig) - Static method in class software.amazon.lambda.durable.operation.MapOperation
Resolves the operation name for every iteration of a map, applying the config's item namer when present and the default "<mapName>-iteration-N" naming otherwise.
result() - Method in record class software.amazon.lambda.durable.model.DeserializedOperationResult
Returns the value of the result record component.
result() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Returns the value of the result record component.
result() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Returns the value of the result record component.
result() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the result record component.
result() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the result record 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.
RETRYING - Enum constant in enum class software.amazon.lambda.durable.plugin.InvocationStatus
Execution failed but will be retried by the backend in a new invocation.
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() - Method in class software.amazon.lambda.durable.config.WithRetryConfig
Returns the retry strategy, 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(RetryStrategy) - Method in class software.amazon.lambda.durable.config.WithRetryConfig.Builder
Sets the retry strategy.
RetryStrategy - Interface in software.amazon.lambda.durable.retry
Functional interface for determining retry behavior when operations fail.
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 TypeToken for 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.
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.
runUserFunction(Integer, Supplier<T>) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Runs a user-provided function inside the plugin user-function hook boundary.
runUserHandler(Runnable, ThreadType) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Runs an operation's handler on a user-executor thread, managing thread registration and suspension.

S

SafeCloseable - Interface in software.amazon.lambda.durable.model
A resource that can be safely closed, similar to Closeable but without throwing IOException.
semanticsPerRetry() - Method in class software.amazon.lambda.durable.config.StepConfig
Returns the delivery semantics per retry for this step.
semanticsPerRetry(StepSemantics) - Method in class software.amazon.lambda.durable.config.StepConfig.Builder
Sets the delivery semantics per retry 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, boolean) - Constructor for class software.amazon.lambda.durable.operation.SerializableDurableOperation
Constructs a new durable operation.
SerializableDurableOperation.SerializedResult<T> - Record Class in software.amazon.lambda.durable.operation
 
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.
serializeAndDeserializeResult(T) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
Serializes the result and returns the value that should be exposed to callers.
serialized() - Method in record class software.amazon.lambda.durable.operation.SerializableDurableOperation.SerializedResult
Returns the value of the serialized record component.
SerializedResult(String, T) - Constructor for record class software.amazon.lambda.durable.operation.SerializableDurableOperation.SerializedResult
Creates an instance of a SerializedResult record class.
serializeException(Throwable) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
Serializes a throwable into an ErrorObject for checkpointing.
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.
setCurrentContext(BaseContext) - Static method in class software.amazon.lambda.durable.context.BaseContextImpl
 
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.DurableContextImpl
Transitions this context from replay to execution mode.
shouldCheckpointEmptyMap() - Method in class software.amazon.lambda.durable.DurableConfig
Whether an empty map operation should emit START and SUCCEED checkpoints.
shouldComplete() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionDecision
Returns the value of the shouldComplete record component.
shouldComplete() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
Returns the value of the shouldComplete record component.
shouldComplete(Function<CompletionConfig.CompletionStatus, CompletionConfig.CompletionDecision>) - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
Complete when the function returns a completing decision.
shouldDeserializeAfterSerialization() - Method in class software.amazon.lambda.durable.DurableConfig
Gets whether serialized operation data should be deserialized immediately after serialization.
shouldRetry() - Method in class software.amazon.lambda.durable.retry.RetryDecision
 
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 size record component.
skipped() - Static method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Creates a skipped result item.
skipped() - Method in record class software.amazon.lambda.durable.model.ParallelResult
Returns the value of the skipped record component.
SKIPPED - Enum constant in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
 
SKIPPED - Enum constant in enum class software.amazon.lambda.durable.model.ParallelResult.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.annotations - package software.amazon.lambda.durable.annotations
 
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.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.plugin - package software.amazon.lambda.durable.plugin
 
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.util - package software.amazon.lambda.durable.util
 
stackTrace() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
Returns the value of the stackTrace record 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.
startTimestamp() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the startTimestamp record component.
startTimestamp() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the startTimestamp record component.
startTimestamp() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the startTimestamp record component.
startTimestamp() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the startTimestamp record component.
startTimestamp() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns the value of the startTimestamp record component.
status() - Method in record class software.amazon.lambda.durable.model.DeserializedOperationResult
Returns the value of the status record component.
status() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Returns the value of the status record component.
status() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Returns the value of the status record component.
status() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the status record component.
status() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the status record component.
status() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the status record component.
statuses() - Method in record class software.amazon.lambda.durable.model.ParallelResult
Returns the value of the statuses record 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 TypeToken for 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 TypeToken and 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
 
STEP - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
stepAsync(String, Class<T>, Function<StepContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
Asynchronously executes a durable step, returning a DurableFuture that 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 TypeToken for 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 TypeToken and 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
 
StepSemantics - Enum Class in software.amazon.lambda.durable.config
Delivery semantics for step operations.
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 subType record component.
subType() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the subType record component.
subType() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the subType record component.
subType() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the subType record component.
subType() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the subType record component.
subType() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns the value of the subType record 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 succeeded record component.
succeeded(T) - Static method in record class software.amazon.lambda.durable.model.DeserializedOperationResult
 
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
 
SUCCEEDED - Enum constant in enum class software.amazon.lambda.durable.model.ParallelResult.Status
 
SUCCEEDED - Enum constant in enum class software.amazon.lambda.durable.plugin.InvocationStatus
Execution completed successfully in this invocation.
SUCCEEDED - Enum constant in enum class software.amazon.lambda.durable.plugin.UserFunctionOutcome
The user function returned normally.
success(String) - Static method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Creates a successful output with the given serialized result.
successCount() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Returns the value of the successCount record component.
suppressReplayLogs() - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
Returns the value of the suppressReplayLogs record component.
suspendExecution() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Suspends the execution by completing the execution exception future with a SuspendExecutionException.
SuspendExecutionException - Error in software.amazon.lambda.durable.execution
Exception thrown to suspend execution during wait operations.
SuspendExecutionException() - Constructor for error 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.
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 ThreadContext record class.
threadId() - Method in record class software.amazon.lambda.durable.execution.ThreadContext
Returns the value of the threadId record component.
threadType() - Method in record class software.amazon.lambda.durable.execution.ThreadContext
Returns the value of the threadType record component.
ThreadType - Enum Class in software.amazon.lambda.durable.execution
Thread type enum for tracking conceptual threads in durable execution.
throwable() - Method in record class software.amazon.lambda.durable.model.DeserializedOperationResult
Returns the value of the throwable record 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.
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.ParallelConfig
 
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 toleratedFailureCount record 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 toleratedFailurePercentage record 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).
toOperationChangeInfo(String, String, Collection<Operation>, Collection<Operation>, Set<String>) - Static method in class software.amazon.lambda.durable.plugin.PluginInfoConverter
Creates an OperationChangeInfo from the durable operations whose status changed in a checkpoint response and a snapshot of all operations tracked for the execution.
toOperationEndInfo(Operation, OperationIdentifier, String, boolean, Throwable) - Static method in class software.amazon.lambda.durable.plugin.PluginInfoConverter
Creates an OperationEndInfo from an SDK Operation, an OperationIdentifier, and an optional error.
toOperationInfo(Operation, OperationIdentifier, String) - Static method in class software.amazon.lambda.durable.plugin.PluginInfoConverter
Converts an SDK Operation to an OperationInfo using an OperationIdentifier.
toOperationItemMap(Collection<Operation>, Set<String>) - Static method in class software.amazon.lambda.durable.plugin.PluginInfoConverter
Converts durable operations to an unmodifiable map of OperationChangeItemInfo, keyed by operation ID.
toString() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionDecision
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Returns a string representation of this record class.
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.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.DeserializedOperationResult
Returns a string representation of this record class.
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 record class software.amazon.lambda.durable.operation.ConcurrencyOperation.ExpectedCompletionStatus
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.operation.SerializableDurableOperation.SerializedResult
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.plugin.InvocationEndInfo
Returns a representation that omits execution payloads and operation snapshots.
toString() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns a representation that omits execution payloads and operation snapshots.
toString() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeInfo
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns a representation that omits the operation result payload.
toString() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns a representation that omits result.
toString() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns a string representation of this record class.
toString() - Method in class software.amazon.lambda.durable.retry.RetryDecision
 
toString() - Method in class software.amazon.lambda.durable.TypeToken
 
totalCount() - Method in record class software.amazon.lambda.durable.config.CompletionConfig.CompletionStatus
Returns the value of the totalCount record component.
toUserFunctionEndInfo(UserFunctionStartInfo, UserFunctionOutcome, Throwable) - Static method in class software.amazon.lambda.durable.plugin.PluginInfoConverter
Creates a UserFunctionEndInfo from a start info and outcome.
toUserFunctionStartInfo(OperationIdentifier, String, boolean, Integer) - Static method in class software.amazon.lambda.durable.plugin.PluginInfoConverter
Creates a UserFunctionStartInfo for when a user function starts executing.
trace(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
 
type() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeItemInfo
Returns the value of the type record component.
type() - Method in record class software.amazon.lambda.durable.plugin.OperationEndInfo
Returns the value of the type record component.
type() - Method in record class software.amazon.lambda.durable.plugin.OperationInfo
Returns the value of the type record component.
type() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Returns the value of the type record component.
type() - Method in record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Returns the value of the type record component.
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
 
UnrecoverableDurableExecutionException(ErrorObject, boolean) - 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
updatedOperationIds() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
Returns the value of the updatedOperationIds record component.
updatedOperations() - Method in record class software.amazon.lambda.durable.plugin.InvocationInfo
Returns the value of the updatedOperations record component.
updatedOperations() - Method in record class software.amazon.lambda.durable.plugin.OperationChangeInfo
Returns the value of the updatedOperations record component.
UserFunctionEndInfo - Record Class in software.amazon.lambda.durable.plugin
Information provided when a user function finishes executing.
UserFunctionEndInfo(String, String, String, String, String, Instant, Instant, boolean, Integer, UserFunctionOutcome, Throwable) - Constructor for record class software.amazon.lambda.durable.plugin.UserFunctionEndInfo
Creates an instance of a UserFunctionEndInfo record class.
UserFunctionOutcome - Enum Class in software.amazon.lambda.durable.plugin
Outcome of a user-provided function when its execution ends.
UserFunctionStartInfo - Record Class in software.amazon.lambda.durable.plugin
Information provided when a user function starts executing.
UserFunctionStartInfo(String, String, String, String, String, Instant, boolean, Integer) - Constructor for record class software.amazon.lambda.durable.plugin.UserFunctionStartInfo
Creates an instance of a UserFunctionStartInfo record class.

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 value record component.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.config.NestingType
Returns the enum constant of this class with the specified name.
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.model.ParallelResult.Status
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.plugin.InvocationStatus
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.plugin.UserFunctionOutcome
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.NestingType
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.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.model.ParallelResult.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.plugin.InvocationStatus
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.plugin.UserFunctionOutcome
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 - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
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.
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 TypeToken and 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 TypeToken and custom configuration.
WaitForCallbackConfig - Class in software.amazon.lambda.durable.config
Configuration for the waitForCallback composite operation.
WaitForCallbackConfig.Builder - Class in software.amazon.lambda.durable.config
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 TypeToken and 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 TypeToken and custom configuration.
WaitForConditionConfig<T> - Class in software.amazon.lambda.durable.config
Configuration for waitForCondition operations.
WaitForConditionConfig.Builder<T> - Class in software.amazon.lambda.durable.config
 
WaitForConditionFailedException - Exception in software.amazon.lambda.durable.exception
Exception thrown when a waitForCondition operation 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(OperationIdentifier, 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 WaitForConditionResult record class.
WaitForConditionWaitStrategy<T> - Interface in software.amazon.lambda.durable.retry
Strategy that computes the delay before the next polling attempt in a waitForCondition operation.
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 WaitForConditionWaitStrategy implementations.
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
 
wasObservedAtInvocationStart(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns true if the given operation was present in the checkpointed state delivered at the start of this invocation, i.e. it predates this invocation and is being replayed rather than started fresh.
WITH_RETRY - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
withCheckpointDelay(Duration) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets how often the SDK checkpoints updates to backend.
withCheckpointEmptyMap(boolean) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Controls whether an empty map operation emits START and SUCCEED checkpoints.
withDeserializeAfterSerialization(boolean) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Controls whether the SDK immediately deserializes serialized operation data after serialization.
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.
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.
withPlugins(DurableExecutionPlugin...) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Registers one or more plugins for lifecycle event instrumentation.
withPollingStrategy(PollingStrategy) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets the polling strategy.
withReplayLogging() - Static method in record class software.amazon.lambda.durable.logging.LoggerConfig
Configuration that allows logs during replay.
withRetry(String, BiFunction<Integer, DurableContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
Replay-safe retry loop for any durable operation (sync) with default configuration.
withRetry(String, BiFunction<Integer, DurableContext, T>, WithRetryConfig) - Method in interface software.amazon.lambda.durable.DurableContext
Replay-safe retry loop for any durable operation (sync).
withRetryAsync(String, BiFunction<Integer, DurableContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
Replay-safe retry loop for any durable operation (async) with default configuration.
withRetryAsync(String, BiFunction<Integer, DurableContext, T>, WithRetryConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
 
withRetryAsync(String, BiFunction<Integer, DurableContext, T>, WithRetryConfig) - Method in interface software.amazon.lambda.durable.DurableContext
Replay-safe retry loop for any durable operation (async).
WithRetryConfig - Class in software.amazon.lambda.durable.config
WithRetryConfig.Builder - Class in software.amazon.lambda.durable.config
Builder for creating WithRetryConfig instances.
withSerDes(SerDes) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets a custom SerDes implementation.
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.
wrapInChildContext() - Method in class software.amazon.lambda.durable.config.WithRetryConfig
Returns whether the sync withRetry should wrap the retry loop in a child context.
wrapInChildContext(boolean) - Method in class software.amazon.lambda.durable.config.WithRetryConfig.Builder
Sets whether the sync withRetry should wrap the retry loop in a child context.
A B C D E F G H I J L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form