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

advanceReadyOperations() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Advance all operations (simulates time passing for retries/waits).
advanceTime() - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Advances all pending operations, simulating time passing for retries and waits.
ALL_COMPLETED - Enum constant in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
 
allCompleted() - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
All items run regardless of failures.
allOf(List<DurableFuture<T>>) - Static method in interface software.amazon.lambda.durable.DurableFuture
Waits for all provided futures to complete and returns their results in order.
allOf(DurableFuture<T>...) - Static method in interface software.amazon.lambda.durable.DurableFuture
Waits for all provided futures to complete and returns their results in order.
allSucceeded() - Method in record class software.amazon.lambda.durable.model.MapResult
Returns true if all items succeeded (no failures or not-started items).
allSuccessful() - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
All items must succeed.
amount() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
Returns the value of the amount record component.
anyOf(DurableFuture<?>...) - Static method in interface software.amazon.lambda.durable.DurableFuture
Waits for any of the provided futures to complete and returns its result.
ApiRequestDelayedBatcher<T> - Class in software.amazon.lambda.durable.execution
Batches API requests to optimize throughput by grouping individual calls into batch operations.
ApiRequestDelayedBatcher(int, int, Function<T, Integer>, Consumer<List<T>>) - Constructor for class software.amazon.lambda.durable.execution.ApiRequestDelayedBatcher
Creates a new ApiRequestDelayedBatcher with the specified configuration.
apply(double) - Method in enum class software.amazon.lambda.durable.retry.JitterStrategy
Applies jitter to the given base delay.
apply(I, int, DurableContext) - Method in interface software.amazon.lambda.durable.DurableContext.MapFunction
Applies this function to the given item.
ApprovalRequest - Record Class in software.amazon.lambda.durable.examples.types
Input for the approval workflow.
ApprovalRequest(String, double) - Constructor for record class software.amazon.lambda.durable.examples.types.ApprovalRequest
 
ApprovalRequest(String, double, Integer) - Constructor for record class software.amazon.lambda.durable.examples.types.ApprovalRequest
Creates an instance of a ApprovalRequest record class.
AsyncExecution<O> - Class in software.amazon.lambda.durable.testing
Handle for an asynchronously executing durable function.
AsyncExecution(String, LambdaClient, TypeToken<O>, Duration, Duration) - Constructor for class software.amazon.lambda.durable.testing.AsyncExecution
 
at(Instant) - Static method in class software.amazon.lambda.durable.retry.PollingStrategies
Creates a polling strategy that polls at a specific instant in time.
AT_LEAST_ONCE_PER_RETRY - Enum constant in enum class software.amazon.lambda.durable.config.StepSemantics
At-least-once delivery (default).
AT_MOST_ONCE_PER_RETRY - Enum constant in enum class software.amazon.lambda.durable.config.StepSemantics
At-most-once delivery per retry attempt.
AwsSdkV2Module - Class in software.amazon.lambda.durable.serde
Jackson module that registers custom serializers and deserializers for AWS SDK v2 model classes.
AwsSdkV2Module() - Constructor for class software.amazon.lambda.durable.serde.AwsSdkV2Module
 

B

BaseContext - Interface in software.amazon.lambda.durable.context
 
BaseContextImpl - Class in software.amazon.lambda.durable.context
 
BaseContextImpl(ExecutionManager, DurableConfig, Context, String, String, ThreadType) - Constructor for class software.amazon.lambda.durable.context.BaseContextImpl
Creates a new BaseContext instance.
BaseDurableOperation - Class in software.amazon.lambda.durable.operation
Base class for all durable operations (STEP, WAIT, etc.).
BaseDurableOperation(OperationIdentifier, DurableContextImpl, BaseDurableOperation) - Constructor for class software.amazon.lambda.durable.operation.BaseDurableOperation
Constructs a new durable operation.
branch(String, Class<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
Registers and immediately starts a branch (respects maxConcurrency).
branch(String, Class<T>, Function<DurableContext, T>, ParallelBranchConfig) - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
Registers and immediately starts a branch (respects maxConcurrency).
branch(String, TypeToken<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
Registers and immediately starts a branch (respects maxConcurrency).
branch(String, TypeToken<T>, Function<DurableContext, T>, ParallelBranchConfig) - Method in class software.amazon.lambda.durable.operation.ParallelOperation
 
branch(String, TypeToken<T>, Function<DurableContext, T>, ParallelBranchConfig) - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
Registers and immediately starts a branch (respects maxConcurrency).
build() - Method in class software.amazon.lambda.durable.config.CallbackConfig.Builder
Builds the 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.DurableConfig.Builder
Builds the DurableConfig instance.
builder() - Static method in class software.amazon.lambda.durable.config.CallbackConfig
Creates a new builder with default values.
builder() - Static method in class software.amazon.lambda.durable.config.InvokeConfig
 
builder() - Static method in class software.amazon.lambda.durable.config.MapConfig
 
builder() - Static method in class software.amazon.lambda.durable.config.ParallelBranchConfig
Creates a new builder for ParallelBranchConfig.
builder() - Static method in class software.amazon.lambda.durable.config.ParallelConfig
Creates a new builder for ParallelConfig.
builder() - Static method in class software.amazon.lambda.durable.config.RunInChildContextConfig
Creates a new builder for RunInChildContextConfig.
builder() - Static method in class software.amazon.lambda.durable.config.StepConfig
Creates a new builder for StepConfig.
builder() - Static method in class software.amazon.lambda.durable.config.WaitForCallbackConfig
Creates a new builder.
builder() - Static method in class software.amazon.lambda.durable.config.WaitForConditionConfig
Creates a new builder for WaitForConditionConfig.
builder() - Static method in class software.amazon.lambda.durable.DurableConfig
Creates a new builder for DurableConfig.
Builder() - Constructor for class software.amazon.lambda.durable.config.WaitForCallbackConfig.Builder
 
Builder() - Constructor for class software.amazon.lambda.durable.DurableConfig.Builder
 
Builder(Duration, Duration, SerDes) - Constructor for class software.amazon.lambda.durable.config.CallbackConfig.Builder
 
Builder(RetryStrategy, StepSemantics, SerDes) - Constructor for class software.amazon.lambda.durable.config.StepConfig.Builder
 
Builder(SerDes) - Constructor for class software.amazon.lambda.durable.config.ParallelBranchConfig.Builder
 
Builder(SerDes) - Constructor for class software.amazon.lambda.durable.config.RunInChildContextConfig.Builder
 
buildErrorObject(Throwable, SerDes) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
build an ErrorObject from a Throwable

C

callbackConfig() - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig
Returns the callback configuration for the composite operation.
callbackConfig(CallbackConfig) - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig.Builder
Sets the callback configuration for the composite operation.
CallbackConfig - Class in software.amazon.lambda.durable.config
Configuration for callback operations.
CallbackConfig.Builder - Class in software.amazon.lambda.durable.config
Builder for CallbackConfig.
CallbackExample - Class in software.amazon.lambda.durable.examples.callback
Example demonstrating callback operations for external system integration.
CallbackExample() - Constructor for class software.amazon.lambda.durable.examples.callback.CallbackExample
 
CallbackException - Exception in software.amazon.lambda.durable.exception
Thrown when a callback operation encounters an error.
CallbackException(Operation, String) - Constructor for exception software.amazon.lambda.durable.exception.CallbackException
 
CallbackException(Operation, String, Throwable) - Constructor for exception software.amazon.lambda.durable.exception.CallbackException
 
CallbackFailedException - Exception in software.amazon.lambda.durable.exception
Exception thrown when a callback fails due to an error from the external system.
CallbackFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.CallbackFailedException
 
callbackId() - Method in interface software.amazon.lambda.durable.DurableCallbackFuture
Returns the unique identifier for this callback.
callbackId() - Method in class software.amazon.lambda.durable.operation.CallbackOperation
 
CallbackOperation<T> - Class in software.amazon.lambda.durable.operation
Durable operation for creating and waiting on external callbacks.
CallbackOperation(OperationIdentifier, TypeToken<T>, CallbackConfig, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.CallbackOperation
 
CallbackSubmitterException - Exception in software.amazon.lambda.durable.exception
Exception thrown when a callback submitter step fails to submit a callback.
CallbackSubmitterException(Operation, StepException) - Constructor for exception software.amazon.lambda.durable.exception.CallbackSubmitterException
 
CallbackTimeoutException - Exception in software.amazon.lambda.durable.exception
Exception thrown when a callback times out.
CallbackTimeoutException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.CallbackTimeoutException
 
categories - Variable in class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
 
checkpoint(String, String, List<OperationUpdate>) - Method in interface software.amazon.lambda.durable.client.DurableExecutionClient
Sends a batch of operation updates to the backend.
checkpoint(String, String, List<OperationUpdate>) - Method in class software.amazon.lambda.durable.client.LambdaDurableFunctionsClient
 
checkpoint(String, String, List<OperationUpdate>) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
 
checkpointToken() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
Returns the value of the checkpointToken record component.
ChildContextExample - Class in software.amazon.lambda.durable.examples.child
Example demonstrating child context workflows with the Durable Execution SDK.
ChildContextExample() - Constructor for class software.amazon.lambda.durable.examples.child.ChildContextExample
 
ChildContextFailedException - Exception in software.amazon.lambda.durable.exception
Exception thrown when a child context fails and the original exception cannot be reconstructed.
ChildContextFailedException(Operation) - Constructor for exception software.amazon.lambda.durable.exception.ChildContextFailedException
 
ChildContextOperation<T> - Class in software.amazon.lambda.durable.operation
Manages the lifecycle of a child execution context.
ChildContextOperation(OperationIdentifier, Function<DurableContext, T>, TypeToken<T>, RunInChildContextConfig, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.ChildContextOperation
 
ChildContextOperation(OperationIdentifier, Function<DurableContext, T>, TypeToken<T>, RunInChildContextConfig, DurableContextImpl, ConcurrencyOperation<?>) - Constructor for class software.amazon.lambda.durable.operation.ChildContextOperation
 
close() - Method in interface software.amazon.lambda.durable.context.BaseContext
Closes this context.
close() - Method in class software.amazon.lambda.durable.context.DurableContextImpl
Clears the logger's thread properties.
close() - Method in class software.amazon.lambda.durable.context.StepContextImpl
Closes the logger for this context.
close() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Shutdown the checkpoint batcher.
close() - Method in class software.amazon.lambda.durable.logging.DurableLogger
Clears all MDC entries.
close() - Method in class software.amazon.lambda.durable.operation.ParallelOperation
Calls ParallelOperation.get() if not already called.
close() - Method in interface software.amazon.lambda.durable.ParallelDurableFuture
Calls DurableFuture.get() if not already called.
CloudDurableTestRunner<I,O> - Class in software.amazon.lambda.durable.testing
Test runner for durable Lambda functions deployed to AWS.
completeCallback(String, String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Complete a callback with success result.
completeCallback(String, String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Simulate external system completing callback successfully.
completeChainedInvoke(String, String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Completes a chained invoke operation with a successful result.
completeChainedInvoke(String, OperationResult) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Completes a chained invoke operation with the given result, simulating a child Lambda response.
CompletedDurableFuture<T> - Class in software.amazon.lambda.durable.util
A DurableFuture that is already completed with a value.
CompletedDurableFuture(T) - Constructor for class software.amazon.lambda.durable.util.CompletedDurableFuture
 
completionConfig() - Method in class software.amazon.lambda.durable.config.MapConfig
 
completionConfig() - Method in class software.amazon.lambda.durable.config.ParallelConfig
 
completionConfig(CompletionConfig) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
Sets the completion criteria for the map operation.
completionConfig(CompletionConfig) - Method in class software.amazon.lambda.durable.config.ParallelConfig.Builder
Sets the maximum number of branches that can run simultaneously.
CompletionConfig - Record Class in software.amazon.lambda.durable.config
Controls when a concurrent operation (map or parallel) completes.
CompletionConfig(Integer, Integer, Double) - Constructor for record class software.amazon.lambda.durable.config.CompletionConfig
Creates an instance of a CompletionConfig record class.
completionFuture - Variable in class software.amazon.lambda.durable.operation.BaseDurableOperation
 
completionReason() - Method in record class software.amazon.lambda.durable.model.MapResult
Returns the value of the completionReason record component.
completionStatus() - Method in record class software.amazon.lambda.durable.model.ParallelResult
Returns the value of the completionStatus record component.
ComplexMapExample - Class in software.amazon.lambda.durable.examples.map
Example demonstrating advanced map features: wait operations inside branches, error handling, and early termination.
ComplexMapExample() - Constructor for class software.amazon.lambda.durable.examples.map.ComplexMapExample
 
computeDelay(int) - Method in interface software.amazon.lambda.durable.retry.PollingStrategy
Computes the delay before the next polling attempt.
ConcurrencyCompletionStatus - Enum Class in software.amazon.lambda.durable.model
 
ConcurrencyOperation<T> - Class in software.amazon.lambda.durable.operation
Abstract base class for concurrent execution of multiple child context operations.
ConcurrencyOperation(OperationIdentifier, TypeToken<T>, SerDes, DurableContextImpl, int, Integer, Integer) - Constructor for class software.amazon.lambda.durable.operation.ConcurrencyOperation
 
ConcurrentWaitForConditionExample - Class in software.amazon.lambda.durable.examples.wait
Example demonstrating concurrent waitForCondition operations using map.
ConcurrentWaitForConditionExample() - Constructor for class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample
 
ConcurrentWaitForConditionExample.Input - Record Class in software.amazon.lambda.durable.examples.wait
 
CONTEXT - Enum constant in enum class software.amazon.lambda.durable.execution.ThreadType
 
continuePolling(T) - Static method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Creates a result indicating polling should continue with the given state.
counts - Variable in class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
 
create(Class<I>, BiFunction<I, DurableContext, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Creates a LocalDurableTestRunner with default configuration.
create(Class<I>, BiFunction<I, DurableContext, O>, DurableConfig) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Creates a LocalDurableTestRunner that uses a custom configuration.
create(Class<I>, DurableHandler<I, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Creates a LocalDurableTestRunner from a DurableHandler instance, automatically extracting the configuration.
create(String, Class<I>, Class<O>) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Creates a runner for the given function ARN with Class-based input/output types.
create(String, Class<I>, Class<O>, LambdaClient) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Creates a runner with a custom LambdaClient and Class-based input/output types.
create(String, TypeToken<I>, TypeToken<O>) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Creates a runner for the given function ARN with TypeToken-based input/output types.
create(String, TypeToken<I>, TypeToken<O>, LambdaClient) - Static method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Creates a runner with a custom LambdaClient and TypeToken-based input/output types.
create(TypeToken<I>, BiFunction<I, DurableContext, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Creates a LocalDurableTestRunner with default configuration.
create(TypeToken<I>, BiFunction<I, DurableContext, O>, DurableConfig) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Creates a LocalDurableTestRunner that uses a custom configuration.
create(TypeToken<I>, DurableHandler<I, O>) - Static method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Creates a LocalDurableTestRunner from a DurableHandler instance, automatically extracting the configuration.
createCallback(String, Class<T>) - Method in interface software.amazon.lambda.durable.DurableContext
Creates a callback with default configuration.
createCallback(String, Class<T>, CallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
Creates a callback with custom configuration.
createCallback(String, TypeToken<T>) - Method in interface software.amazon.lambda.durable.DurableContext
Creates a callback using a 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) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
Creates a child context.
createConfiguration() - Method in class software.amazon.lambda.durable.DurableHandler
Template method for creating configuration.
createConfiguration() - Method in class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample
 
createConfiguration() - Method in class software.amazon.lambda.durable.examples.general.CustomConfigExample
 
createConfiguration() - Method in class software.amazon.lambda.durable.examples.general.CustomPollingExample
 
createConfiguration() - Method in class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample
 
createItem(String, String, Function<DurableContext, R>, TypeToken<R>, SerDes, OperationSubType, DurableContextImpl) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
Creates a child context operation for a single item (branch or iteration).
createRootContext(ExecutionManager, DurableConfig, Context) - Static method in class software.amazon.lambda.durable.context.DurableContextImpl
Creates a root context (contextId = null)
createStepContext(String, String, int) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
Creates a step context for executing step operations.
CustomConfigExample - Class in software.amazon.lambda.durable.examples.general
Example demonstrating custom configuration with both custom HTTP client and custom SerDes.
CustomConfigExample() - Constructor for class software.amazon.lambda.durable.examples.general.CustomConfigExample
 
CustomConfigExample.CustomData - Class in software.amazon.lambda.durable.examples.general
Custom data class with camelCase field names to demonstrate snake_case serialization.
CustomData() - Constructor for class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
 
CustomData(String, String, int, String) - Constructor for class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
 
CustomPollingExample - Class in software.amazon.lambda.durable.examples.general
Example demonstrating custom polling strategy configuration.
CustomPollingExample() - Constructor for class software.amazon.lambda.durable.examples.general.CustomPollingExample
 

D

debug(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
 
DEFAULT - Static variable in class software.amazon.lambda.durable.retry.PollingStrategies.Presets
Default polling strategy: - Base interval: 1 second - Backoff rate: 2x - Jitter: FULL - Max interval 10 second
DEFAULT - Static variable in class software.amazon.lambda.durable.retry.RetryStrategies.Presets
Default retry strategy: - 6 total attempts (1 initial + 5 retries) - Initial delay: 5 seconds - Max delay: 60 seconds - Backoff rate: 2x - Jitter: FULL
DEFAULT - Static variable in class software.amazon.lambda.durable.retry.WaitStrategies.Presets
Default wait strategy: exponential backoff with 60 max attempts, 5s initial delay, 300s max delay, 1.5x backoff rate, and FULL jitter.
defaultConfig() - Static method in class software.amazon.lambda.durable.DurableConfig
Creates a DurableConfig with default settings.
defaults() - Static method in record class software.amazon.lambda.durable.logging.LoggerConfig
Default configuration: suppress logs during replay.
defaultStrategy() - Static method in class software.amazon.lambda.durable.retry.WaitStrategies
Returns the default wait strategy.
delay() - Method in class software.amazon.lambda.durable.retry.RetryDecision
 
deliveries() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
Returns the value of the deliveries record component.
deregisterActiveThread(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Mark a thread as inactive.
description() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
Returns the value of the description record component.
DeserializationFailedMapExample - Class in software.amazon.lambda.durable.examples.map
Example demonstrating the map operation with the Durable Execution SDK.
DeserializationFailedMapExample() - Constructor for class software.amazon.lambda.durable.examples.map.DeserializationFailedMapExample
 
DeserializationFailedParallelExample - Class in software.amazon.lambda.durable.examples.parallel
Example demonstrating parallel branch execution with the Durable Execution SDK.
DeserializationFailedParallelExample() - Constructor for class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample
 
DeserializationFailedParallelExample.Input - Record Class in software.amazon.lambda.durable.examples.parallel
 
DeserializationFailureExample - Class in software.amazon.lambda.durable.examples.step
 
DeserializationFailureExample() - Constructor for class software.amazon.lambda.durable.examples.step.DeserializationFailureExample
 
deserialize(String, TypeToken<T>) - Method in class software.amazon.lambda.durable.serde.DurableInputOutputSerDes
Deserializes a JSON string to DurableExecutionInput object
deserialize(String, TypeToken<T>) - Method in class software.amazon.lambda.durable.serde.JacksonSerDes
 
deserialize(String, TypeToken<T>) - Method in interface software.amazon.lambda.durable.serde.SerDes
Deserializes a JSON string to an object of the specified generic type.
deserializeException(ErrorObject) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
Deserializes an 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.
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.
DurableExecutionClient - Interface in software.amazon.lambda.durable.client
Client interface for communicating with the Lambda Durable Functions backend.
DurableExecutionException - Exception in software.amazon.lambda.durable.exception
Base exception for all durable execution errors.
DurableExecutionException(String) - Constructor for exception software.amazon.lambda.durable.exception.DurableExecutionException
 
DurableExecutionException(String, Throwable) - Constructor for exception software.amazon.lambda.durable.exception.DurableExecutionException
 
DurableExecutionException(String, Throwable, StackTraceElement[]) - Constructor for exception software.amazon.lambda.durable.exception.DurableExecutionException
 
DurableExecutionInput - Record Class in software.amazon.lambda.durable.model
Input payload received by the Lambda handler from the Durable Functions backend.
DurableExecutionInput(String, String, CheckpointUpdatedExecutionState) - Constructor for record class software.amazon.lambda.durable.model.DurableExecutionInput
Creates an instance of a 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.
DurableExecutor - Class in software.amazon.lambda.durable.execution
Orchestrates the lifecycle of a durable execution.
DurableFuture<T> - Interface in software.amazon.lambda.durable
A future representing the result of an asynchronous durable operation.
DurableHandler<I,O> - Class in software.amazon.lambda.durable
Abstract base class for Lambda handlers that use durable execution.
DurableHandler() - Constructor for class software.amazon.lambda.durable.DurableHandler
 
DurableInputOutputSerDes - Class in software.amazon.lambda.durable.serde
Serializer/Deserializer for Durable Execution Input and Output objects.
DurableInputOutputSerDes() - Constructor for class software.amazon.lambda.durable.serde.DurableInputOutputSerDes
 
DurableLogger - Class in software.amazon.lambda.durable.logging
Logger wrapper that adds durable execution context to log entries via MDC and optionally suppresses logs during replay.
DurableLogger(Logger, BaseContextImpl) - Constructor for class software.amazon.lambda.durable.logging.DurableLogger
Creates a DurableLogger wrapping the given SLF4J logger with execution context MDC entries.
DurableOperationException - Exception in software.amazon.lambda.durable.exception
Exception associated with a specific durable operation, carrying the operation and error details.
DurableOperationException(Operation, ErrorObject) - Constructor for exception software.amazon.lambda.durable.exception.DurableOperationException
 
DurableOperationException(Operation, ErrorObject, String) - Constructor for exception software.amazon.lambda.durable.exception.DurableOperationException
 
DurableOperationException(Operation, ErrorObject, String, StackTraceElement[], Throwable) - Constructor for exception software.amazon.lambda.durable.exception.DurableOperationException
 
DurableOperationException(Operation, ErrorObject, String, Throwable) - Constructor for exception software.amazon.lambda.durable.exception.DurableOperationException
 

E

emailAddress - Variable in class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
 
empty() - Static method in record class software.amazon.lambda.durable.model.MapResult
Returns an empty MapResult with no items.
enqueueItem(String, Function<DurableContext, R>, TypeToken<R>, SerDes, OperationSubType) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
Creates and enqueues an item without starting execution.
equals(Object) - Method in record class software.amazon.lambda.durable.config.CompletionConfig
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.execution.ThreadContext
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.model.MapResult
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.model.ParallelResult
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class software.amazon.lambda.durable.testing.OperationResult
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class software.amazon.lambda.durable.TypeToken
 
error() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Returns the value of the 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.testing.OperationResult
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
 
ErrorHandlingExample - Class in software.amazon.lambda.durable.examples.general
Example demonstrating error handling patterns with the Durable Execution SDK.
ErrorHandlingExample() - Constructor for class software.amazon.lambda.durable.examples.general.ErrorHandlingExample
 
ErrorHandlingExample.ServiceUnavailableException - Exception in software.amazon.lambda.durable.examples.general
Custom exception to demonstrate that original exception types are preserved across checkpoints.
errorMessage() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
Returns the value of the 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.
executionManager - Variable in class software.amazon.lambda.durable.operation.BaseDurableOperation
 
ExecutionManager - Class in software.amazon.lambda.durable.execution
Central manager for durable execution coordination.
ExecutionManager(DurableExecutionInput, DurableConfig) - Constructor for class software.amazon.lambda.durable.execution.ExecutionManager
 
ExecutionStatus - Enum Class in software.amazon.lambda.durable.model
Terminal status of a durable execution.
executionTimeMs() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
Returns the value of the executionTimeMs record component.
executionTimeMs() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
Returns the value of the executionTimeMs record component.
exponentialBackoff(int, Duration, Duration, double, JitterStrategy) - Static method in class software.amazon.lambda.durable.retry.RetryStrategies
Creates an exponential backoff retry strategy.
exponentialBackoff(int, Duration, Duration, double, JitterStrategy) - Static method in class software.amazon.lambda.durable.retry.WaitStrategies
Creates an exponential backoff wait strategy.
exponentialBackoff(Duration, double, JitterStrategy, Duration) - Static method in class software.amazon.lambda.durable.retry.PollingStrategies
Creates an exponential backoff polling strategy.

F

fail() - Static method in class software.amazon.lambda.durable.retry.RetryDecision
Creates a retry decision indicating the operation should not be retried.
failCallback(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Fail a callback with error.
failCallback(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Simulate external system failing callback.
failChainedInvoke(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Fails a chained invoke operation with the given error.
failed() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
Returns the value of the failed record component.
failed() - Method in record class software.amazon.lambda.durable.model.MapResult
Returns errors from items that failed.
failed() - Method in record class software.amazon.lambda.durable.model.ParallelResult
Returns the value of the failed record component.
failed(MapResult.MapError) - Static method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Creates a failed result item.
FAILED - Enum constant in enum class software.amazon.lambda.durable.model.ExecutionStatus
 
FAILED - Enum constant in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
 
failure(ErrorObject) - Static method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Creates a failed output with the given error details.
FAILURE_TOLERANCE_EXCEEDED - Enum constant in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
 
faiure() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
Returns the value of the faiure record component.
firstSuccessful() - Static method in record class software.amazon.lambda.durable.config.CompletionConfig
Complete as soon as the first item succeeds.
fixedDelay(int, Duration) - Static method in class software.amazon.lambda.durable.retry.RetryStrategies
Creates a simple retry strategy that retries a fixed number of times with a fixed delay.
fixedDelay(int, Duration) - Static method in class software.amazon.lambda.durable.retry.WaitStrategies
Creates a fixed delay wait strategy that returns a constant delay regardless of attempt number or state.
fixedDelay(Duration) - Static method in class software.amazon.lambda.durable.retry.PollingStrategies
Creates a fixed-delay polling strategy that uses the same interval for every attempt.
FULL - Enum constant in enum class software.amazon.lambda.durable.retry.JitterStrategy
Full jitter - random delay between 0 and calculated delay.
fullName - Variable in class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
 

G

GenericInputOutputExample - Class in software.amazon.lambda.durable.examples.general
Example demonstrating a durable Lambda function that uses generic types in input and output.
GenericInputOutputExample() - Constructor for class software.amazon.lambda.durable.examples.general.GenericInputOutputExample
 
GenericTypesExample - Class in software.amazon.lambda.durable.examples.general
Example demonstrating TypeToken support for complex generic types.
GenericTypesExample() - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample
 
GenericTypesExample.Input - Class in software.amazon.lambda.durable.examples.general
 
GenericTypesExample.Output - Class in software.amazon.lambda.durable.examples.general
 
get() - Method in interface software.amazon.lambda.durable.DurableFuture
Blocks until the operation completes and returns the result.
get() - Method in class software.amazon.lambda.durable.operation.CallbackOperation
 
get() - Method in class software.amazon.lambda.durable.operation.ChildContextOperation
 
get() - Method in class software.amazon.lambda.durable.operation.InvokeOperation
Blocks until the operation completes and returns the result.
get() - Method in class software.amazon.lambda.durable.operation.MapOperation
 
get() - Method in class software.amazon.lambda.durable.operation.ParallelOperation
 
get() - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
 
get() - Method in class software.amazon.lambda.durable.operation.StepOperation
 
get() - Method in class software.amazon.lambda.durable.operation.WaitForConditionOperation
 
get() - Method in class software.amazon.lambda.durable.operation.WaitOperation
 
get() - Method in class software.amazon.lambda.durable.util.CompletedDurableFuture
 
get(Class<U>) - Static method in class software.amazon.lambda.durable.TypeToken
Creates a TypeToken for a simple (non-generic) class.
getAllEvents() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Get all events in order.
getAllOperations() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Returns all operations currently stored.
getAttempt() - Method in class software.amazon.lambda.durable.context.StepContextImpl
Returns the current retry attempt number (0-based).
getAttempt() - Method in interface software.amazon.lambda.durable.StepContext
Returns the current retry attempt number (0-based).
getAttempt() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the current retry attempt number (0-based), defaulting to 0 if not available.
getBranches() - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
 
getCallbackDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the callback details, or null if this is not a callback operation.
getCallbackId() - Method in exception software.amazon.lambda.durable.exception.CallbackException
Returns the callback ID associated with this exception.
getCallbackId(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Get the callback ID for a callback operation.
getCallbackId(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Get callback ID for a named callback operation.
getCallbackId(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Get callback ID for a named callback operation.
getChainedInvokeDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the chained invoke details, or null if this is not a chained invoke operation.
getCheckpointDelay() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the configured checkpoint delay.
getChildOperations() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the direct child Operations of this context operation
getChildOperations(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Gets all child operations for a given operationId.
getCompletionFuture() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
 
getConfiguration() - Method in class software.amazon.lambda.durable.DurableHandler
Gets the configuration used by this handler.
getContext() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the parent context.
getContextDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the context details, or null if this operation is not a context.
getContextId() - Method in interface software.amazon.lambda.durable.context.BaseContext
Gets the context ID for this context.
getContextId() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
Gets the context ID for this context.
getContextName() - Method in interface software.amazon.lambda.durable.context.BaseContext
Gets the context name for this context.
getContextName() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
Gets the context name for this context.
getCurrentThreadContext() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns the current thread's ThreadContext (threadId and threadType), or null if not set.
getCurrentThreadContext() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Returns the current thread's context from the execution manager.
getDurableConfig() - Method in interface software.amazon.lambda.durable.context.BaseContext
Returns the configuration for durable execution behavior.
getDurableConfig() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
Returns the configuration for durable execution behavior.
getDurableExecutionArn() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns the ARN of the durable execution being managed.
getDurableExecutionClient() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the configured DurableExecutionClient.
getDuration() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the duration of the operation
getError() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the step error, or null if the step succeeded or this is not a step operation.
getError() - Method in class software.amazon.lambda.durable.testing.TestResult
Returns the execution error, if present.
getError(int) - Method in record class software.amazon.lambda.durable.model.MapResult
Returns the error at the given index, or null if that item succeeded or was not started.
getErrorObject() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
Returns the error details from the failed operation.
getErrorObject() - Method in exception software.amazon.lambda.durable.exception.UnrecoverableDurableExecutionException
Returns the error details for this unrecoverable exception.
getEvents() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the raw history events associated with this operation.
getEventsForOperation(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Get events for a specific operation.
getEventsForOperation(String) - Method in class software.amazon.lambda.durable.testing.TestResult
Returns the raw history events for the given operation name, or an empty list if not found.
getExecutionArn() - Method in interface software.amazon.lambda.durable.context.BaseContext
Returns the current durable execution arn
getExecutionArn() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
Returns metadata about the current durable execution.
getExecutionArn() - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Get the execution ARN.
getExecutionDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the execution details, or null if this operation is not an EXECUTION operation.
getExecutionManager() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
 
getExecutionOperation() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns the initial EXECUTION operation from the checkpoint state.
getExecutionState(String, String, String) - Method in interface software.amazon.lambda.durable.client.DurableExecutionClient
Retrieves the current execution state from the backend.
getExecutionState(String, String, String) - Method in class software.amazon.lambda.durable.client.LambdaDurableFunctionsClient
 
getExecutionState(String, String, String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
 
getExecutorService() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the configured ExecutorService.
getFailedOperations() - Method in class software.amazon.lambda.durable.testing.TestResult
Returns all operations that failed, were cancelled, timed out, or stopped.
getHistoryEvents() - Method in class software.amazon.lambda.durable.testing.TestResult
Returns all raw history events from the execution.
getItem(int) - Method in record class software.amazon.lambda.durable.model.MapResult
Returns the result item at the given index.
getLambdaContext() - Method in interface software.amazon.lambda.durable.context.BaseContext
Returns the AWS Lambda runtime context.
getLambdaContext() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
Returns the AWS Lambda runtime context.
getLogger() - Method in interface software.amazon.lambda.durable.context.BaseContext
Gets a logger with additional information of the current execution context.
getLogger() - Method in class software.amazon.lambda.durable.context.DurableContextImpl
 
getLogger() - Method in class software.amazon.lambda.durable.context.StepContextImpl
 
getLoggerConfig() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the configured LoggerConfig.
getName() - Method in class software.amazon.lambda.durable.examples.types.GreetingRequest
 
getName() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the operation name (may be null).
getName() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the operation name.
getOperation() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
Returns the operation that caused this exception.
getOperation() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the Operation from ExecutionManager and update the replay state from REPLAY to EXECUTE if operation is not found.
getOperation(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Get details for a specific operation.
getOperation(String) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Returns the TestOperation for the given name from the last execution result.
getOperation(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Returns the TestOperation for the given operation name, or null if not found.
getOperation(String) - Method in class software.amazon.lambda.durable.testing.TestResult
Returns the TestOperation with the given name, or null if not found.
getOperationAndUpdateReplayState(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Gets an operation by its globally unique operationId, and updates replay state.
getOperationByName(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Returns the operation with the given name, or null if not found.
getOperationId() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
Returns the ID of the operation that caused this exception.
getOperationId() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the unique identifier for this operation.
getOperations() - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Get all operations in the execution.
getOperations() - Method in class software.amazon.lambda.durable.testing.TestResult
Returns all operations from the execution.
getOperationStatus() - Method in exception software.amazon.lambda.durable.exception.DurableOperationException
Returns the status of the operation that caused this exception.
getOperationUpdates() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Get all operation updates that have been sent to this client.
getPollingStrategy() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the polling strategy.
getResult(int) - Method in record class software.amazon.lambda.durable.model.MapResult
Returns the result at the given index, or null if that item failed or was not started.
getResult(Class<T>) - Method in class software.amazon.lambda.durable.testing.TestResult
Deserializes and returns the execution output, throwing if the execution did not succeed.
getResult(TypeToken<T>) - Method in class software.amazon.lambda.durable.testing.TestResult
Deserializes and returns the execution output using a TypeToken for generic types.
getSerDes() - Method in class software.amazon.lambda.durable.DurableConfig
Gets the configured SerDes.
getServiceName() - Method in exception software.amazon.lambda.durable.examples.general.ErrorHandlingExample.ServiceUnavailableException
 
getStatus() - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Get current execution status.
getStatus() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the current status of this operation (e.g.
getStatus() - Method in class software.amazon.lambda.durable.testing.TestResult
Returns the execution status (SUCCEEDED, FAILED, or PENDING).
getStepDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the step details, or null if this is not a step operation.
getStepResult(Class<T>) - Method in class software.amazon.lambda.durable.testing.TestOperation
Deserializes and returns the step result as the given type.
getStepResult(TypeToken<T>) - Method in class software.amazon.lambda.durable.testing.TestOperation
Deserializes and returns the step result using a TypeToken for generic types.
getSubtype() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the operation's subtype
getSubType() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the operation sub-type (e.g.
getSucceededOperations() - Method in class software.amazon.lambda.durable.testing.TestResult
Returns all operations that completed successfully.
getType() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Gets the operation type.
getType() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the operation type (STEP, WAIT, CALLBACK, etc.).
getType() - Method in class software.amazon.lambda.durable.TypeToken
Returns the captured type.
getValue() - Method in enum class software.amazon.lambda.durable.model.OperationSubType
Returns the wire-format string value sent in checkpoint updates.
getWaitDetails() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns the wait details, or null if this is not a wait operation.
GreetingRequest - Class in software.amazon.lambda.durable.examples.types
 
GreetingRequest() - Constructor for class software.amazon.lambda.durable.examples.types.GreetingRequest
 
GreetingRequest(String) - Constructor for class software.amazon.lambda.durable.examples.types.GreetingRequest
 

H

HALF - Enum constant in enum class software.amazon.lambda.durable.retry.JitterStrategy
Half jitter - random delay between 50% and 100% of calculated delay.
handleCompletion(ConcurrencyCompletionStatus) - Method in class software.amazon.lambda.durable.operation.ConcurrencyOperation
Called when the concurrency operation completes.
handleCompletion(ConcurrencyCompletionStatus) - Method in class software.amazon.lambda.durable.operation.MapOperation
 
handleCompletion(ConcurrencyCompletionStatus) - Method in class software.amazon.lambda.durable.operation.ParallelOperation
 
handleRequest(I, DurableContext) - Method in class software.amazon.lambda.durable.DurableHandler
Handle the durable execution.
handleRequest(InputStream, OutputStream, Context) - Method in class software.amazon.lambda.durable.DurableHandler
Reads the request, executes the durable function handler and writes the response
handleRequest(Integer, DurableContext) - Method in class software.amazon.lambda.durable.examples.map.ComplexMapExample
 
handleRequest(Integer, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitForConditionExample
 
handleRequest(Object, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.ErrorHandlingExample
 
handleRequest(Object, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.RetryExample
 
handleRequest(Object, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.RetryInProcessExample
 
handleRequest(String, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.CustomConfigExample
 
handleRequest(String, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.DeserializationFailureExample
 
handleRequest(Map<String, String>, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.GenericInputOutputExample
 
handleRequest(ManyAsyncChildContextExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample
 
handleRequest(GenericTypesExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.GenericTypesExample
 
handleRequest(DeserializationFailedParallelExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample
 
handleRequest(ParallelExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.parallel.ParallelExample
 
handleRequest(ParallelFailureToleranceExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample
 
handleRequest(ParallelWithWaitExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample
 
handleRequest(ManyAsyncStepsExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample
 
handleRequest(ApprovalRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.callback.CallbackExample
 
handleRequest(ApprovalRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.callback.WaitForCallbackFailedExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.child.ChildContextExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.CustomPollingExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.LoggingExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.general.NoopExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.invoke.SimpleInvokeExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.map.DeserializationFailedMapExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.map.SimpleMapExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.step.SimpleStepExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitAsyncExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitAtLeastExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitAtLeastInProcessExample
 
handleRequest(GreetingRequest, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.WaitExample
 
handleRequest(ConcurrentWaitForConditionExample.Input, DurableContext) - Method in class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample
 
hasCallback(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Check if a callback operation with the given name exists and is started.
hashCode() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.execution.ThreadContext
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.model.MapResult
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.model.ParallelResult
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Returns a hash code value for this object.
hashCode() - Method in record class software.amazon.lambda.durable.testing.OperationResult
Returns a hash code value for this object.
hashCode() - Method in class software.amazon.lambda.durable.TypeToken
 
hashOperationId(String) - Static method in class software.amazon.lambda.durable.execution.OperationIdGenerator
Hashes the given string using SHA-256
hasOperation(String) - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Check if an operation with the given name exists.
hasOperationsForContext(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Checks whether there are any cached operations for the given parent context ID.
heartbeatTimeout() - Method in class software.amazon.lambda.durable.config.CallbackConfig
Returns the maximum duration between heartbeats before the callback is considered failed.
heartbeatTimeout(Duration) - Method in class software.amazon.lambda.durable.config.CallbackConfig.Builder
Sets the maximum duration between heartbeats before the callback is considered failed.
HistoryEventProcessor - Class in software.amazon.lambda.durable.testing
Processes execution history events from the GetDurableExecutionHistory API into TestResult objects.
HistoryEventProcessor() - Constructor for class software.amazon.lambda.durable.testing.HistoryEventProcessor
 
HistoryPoller - Class in software.amazon.lambda.durable.testing
Polls the GetDurableExecutionHistory API until execution completes or a timeout is reached.
HistoryPoller(LambdaClient) - Constructor for class software.amazon.lambda.durable.testing.HistoryPoller
Creates a poller backed by the given Lambda client.

I

IllegalDurableOperationException - Exception in software.amazon.lambda.durable.exception
An illegal operation is detected.
IllegalDurableOperationException(String) - Constructor for exception software.amazon.lambda.durable.exception.IllegalDurableOperationException
 
info(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
 
initialExecutionState() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
Returns the value of the 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.
Input() - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample.Input
 
Input(int, int) - Constructor for record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
Creates an instance of a Input record class.
Input(int, int) - Constructor for record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
Creates an instance of a Input record class.
Input(int, int, int) - Constructor for record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
Creates an instance of a Input record class.
Input(String) - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample.Input
 
Input(String, String) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
Creates an instance of a Input record class.
Input(List<String>) - Constructor for record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
Creates an instance of a Input record class.
Input(List<String>) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
Creates an instance of a Input record class.
Input(List<String>, Integer, Integer) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
Creates an instance of a Input record class.
invoke(String, String, U, Class<T>) - Method in interface software.amazon.lambda.durable.DurableContext
Invokes another Lambda function by name and blocks until the result is available.
invoke(String, String, U, Class<T>, InvokeConfig) - Method in interface software.amazon.lambda.durable.DurableContext
Invokes another Lambda function with custom configuration, blocking until the result is available.
invoke(String, String, U, TypeToken<T>) - Method in interface software.amazon.lambda.durable.DurableContext
Invokes another Lambda function using a 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
 
isComplete() - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Check if execution has completed (succeeded or failed).
isCompleted() - Method in class software.amazon.lambda.durable.testing.TestOperation
Returns true if the operation has completed (either succeeded or failed).
isDone() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Returns the value of the isDone record component.
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).
isFailed() - Method in class software.amazon.lambda.durable.testing.TestResult
Returns true if the execution failed.
isJoined - Variable in class software.amazon.lambda.durable.operation.ConcurrencyOperation
 
isOperationCompleted() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Returns true if this operation has completed (successfully or exceptionally).
isReplaying() - Method in interface software.amazon.lambda.durable.context.BaseContext
Returns whether this context is currently in replay mode.
isReplaying() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
Returns whether this context is currently in replay mode.
isReplaying() - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns true if the execution is currently replaying completed operations.
isStepInterruptedException(ErrorObject) - Static method in exception software.amazon.lambda.durable.exception.StepInterruptedException
 
isSucceeded() - Method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
 
isSucceeded() - Method in class software.amazon.lambda.durable.testing.TestResult
Returns true if the execution completed successfully.
isTerminalStatus(OperationStatus) - Static method in class software.amazon.lambda.durable.execution.ExecutionManager
Returns true if the given status represents a terminal (final) operation state.
items - Variable in class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
 
items() - Method in record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
Returns the value of the items record component.
items() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
Returns the value of the items record component.
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.
LocalDurableTestRunner<I,O> - Class in software.amazon.lambda.durable.testing
In-memory test runner for durable Lambda functions.
LocalMemoryExecutionClient - Class in software.amazon.lambda.durable.testing
In-memory implementation of DurableExecutionClient for local testing.
LocalMemoryExecutionClient() - Constructor for class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
 
LoggerConfig - Record Class in software.amazon.lambda.durable.logging
Configuration for DurableLogger behavior.
LoggerConfig(boolean) - Constructor for record class software.amazon.lambda.durable.logging.LoggerConfig
Creates an instance of a LoggerConfig record class.
LoggingExample - Class in software.amazon.lambda.durable.examples.general
Example demonstrating DurableLogger usage for structured logging with execution context.
LoggingExample() - Constructor for class software.amazon.lambda.durable.examples.general.LoggingExample
 

M

makeRetryDecision(Throwable, int) - Method in interface software.amazon.lambda.durable.retry.RetryStrategy
Determines whether to retry a failed operation and calculates the retry delay.
ManyAsyncChildContextExample - Class in software.amazon.lambda.durable.examples.child
Performance test example demonstrating concurrent async child contexts.
ManyAsyncChildContextExample() - Constructor for class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample
 
ManyAsyncChildContextExample.Input - Record Class in software.amazon.lambda.durable.examples.child
 
ManyAsyncChildContextExample.Output - Record Class in software.amazon.lambda.durable.examples.child
 
ManyAsyncStepsExample - Class in software.amazon.lambda.durable.examples.step
Performance test example demonstrating concurrent async steps.
ManyAsyncStepsExample() - Constructor for class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample
 
ManyAsyncStepsExample.Input - Record Class in software.amazon.lambda.durable.examples.step
 
ManyAsyncStepsExample.Output - Record Class in software.amazon.lambda.durable.examples.step
 
map(String, Collection<I>, Class<O>, DurableContext.MapFunction<I, O>) - Method in interface software.amazon.lambda.durable.DurableContext
 
map(String, Collection<I>, Class<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in interface software.amazon.lambda.durable.DurableContext
 
map(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>) - Method in interface software.amazon.lambda.durable.DurableContext
 
map(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in interface software.amazon.lambda.durable.DurableContext
 
MAP - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
MAP_ITERATION - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
mapAsync(String, Collection<I>, Class<O>, DurableContext.MapFunction<I, O>) - Method in interface software.amazon.lambda.durable.DurableContext
 
mapAsync(String, Collection<I>, Class<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in interface software.amazon.lambda.durable.DurableContext
 
mapAsync(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>) - Method in interface software.amazon.lambda.durable.DurableContext
 
mapAsync(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
 
mapAsync(String, Collection<I>, TypeToken<O>, DurableContext.MapFunction<I, O>, MapConfig) - Method in interface software.amazon.lambda.durable.DurableContext
 
MapConfig - Class in software.amazon.lambda.durable.config
Configuration for map operations.
MapConfig.Builder - Class in software.amazon.lambda.durable.config
Builder for creating MapConfig instances.
MapError(String, String, List<String>) - Constructor for record class software.amazon.lambda.durable.model.MapResult.MapError
Creates an instance of a 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, 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() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
Returns the value of the maxConcurrency record component.
maxConcurrency(Integer) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
 
maxConcurrency(Integer) - Method in class software.amazon.lambda.durable.config.ParallelConfig.Builder
Sets the maximum number of branches that can run simultaneously.
message() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
Returns the value of the message record component.
MIN_SUCCESSFUL_REACHED - Enum constant in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
 
minSuccessful() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
Returns the value of the minSuccessful record component.
minSuccessful() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
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.
multiplier() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
Returns the value of the multiplier record component.
multiplier() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
Returns the value of the multiplier record component.

N

name() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns the value of the name record component.
nextOperationId() - Method in class software.amazon.lambda.durable.execution.OperationIdGenerator
Returns the next globally unique operation ID.
NO_RETRY - Static variable in class software.amazon.lambda.durable.retry.RetryStrategies.Presets
No retry strategy - fails immediately on first error.
NonDeterministicExecutionException - Exception in software.amazon.lambda.durable.exception
Exception thrown when non-deterministic code is detected during replay.
NonDeterministicExecutionException(String) - Constructor for exception software.amazon.lambda.durable.exception.NonDeterministicExecutionException
 
NONE - Enum constant in enum class software.amazon.lambda.durable.retry.JitterStrategy
No jitter - use exact calculated delay.
NoopExample - Class in software.amazon.lambda.durable.examples.general
Simple example demonstrating a durable function doesn't have any durable operation
NoopExample() - Constructor for class software.amazon.lambda.durable.examples.general.NoopExample
 

O

of(String, String, OperationType) - Static method in record class software.amazon.lambda.durable.model.OperationIdentifier
Creates an identifier without a sub-type.
of(String, String, OperationType, OperationSubType) - Static method in record class software.amazon.lambda.durable.model.OperationIdentifier
Creates an identifier with a sub-type.
of(Throwable) - Static method in record class software.amazon.lambda.durable.model.MapResult.MapError
 
onCheckpointComplete(Operation) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Receives operation updates from ExecutionManager.
operationId() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns the value of the 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 optional sub-type.
OperationIdentifier(String, String, OperationType, 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
 
OperationResult - Record Class in software.amazon.lambda.durable.testing
The operation status and result/error from Step, Context, Callback and ChainedInvoke operations
OperationResult(OperationStatus, String, ErrorObject) - Constructor for record class software.amazon.lambda.durable.testing.OperationResult
Creates an instance of a OperationResult record class.
operationStatus() - Method in record class software.amazon.lambda.durable.testing.OperationResult
Returns the value of the operationStatus record component.
OperationSubType - Enum Class in software.amazon.lambda.durable.model
Fine-grained classification of durable operations beyond the basic operation types.
operationType() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns the value of the operationType record component.
Output() - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
 
Output(int, int) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
Creates an instance of a Output record class.
Output(long, long, long) - Constructor for record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
Creates an instance of a Output record class.
Output(long, long, long) - Constructor for record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
Creates an instance of a Output record class.
Output(List<String>, int) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
Creates an instance of a Output record class.
Output(List<String>, int, int) - Constructor for record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
Creates an instance of a Output record class.
Output(List<String>, Map<String, Integer>, Map<String, List<String>>) - Constructor for class software.amazon.lambda.durable.examples.general.GenericTypesExample.Output
 

P

parallel(String) - Method in interface software.amazon.lambda.durable.DurableContext
Creates a 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.
ParallelExample - Class in software.amazon.lambda.durable.examples.parallel
Example demonstrating parallel branch execution with the Durable Execution SDK.
ParallelExample() - Constructor for class software.amazon.lambda.durable.examples.parallel.ParallelExample
 
ParallelExample.Input - Record Class in software.amazon.lambda.durable.examples.parallel
 
ParallelExample.Output - Record Class in software.amazon.lambda.durable.examples.parallel
 
ParallelFailureToleranceExample - Class in software.amazon.lambda.durable.examples.parallel
Example demonstrating parallel execution with failure tolerance.
ParallelFailureToleranceExample() - Constructor for class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample
 
ParallelFailureToleranceExample.Input - Record Class in software.amazon.lambda.durable.examples.parallel
 
ParallelFailureToleranceExample.Output - Record Class in software.amazon.lambda.durable.examples.parallel
 
ParallelOperation - Class in software.amazon.lambda.durable.operation
Manages parallel execution of multiple branches as child context operations.
ParallelOperation(OperationIdentifier, SerDes, DurableContextImpl, ParallelConfig) - Constructor for class software.amazon.lambda.durable.operation.ParallelOperation
 
ParallelResult - Record Class in software.amazon.lambda.durable.model
Summary result of a parallel operation.
ParallelResult(int, int, int, ConcurrencyCompletionStatus) - Constructor for record class software.amazon.lambda.durable.model.ParallelResult
Creates an instance of a ParallelResult record class.
ParallelWithWaitExample - Class in software.amazon.lambda.durable.examples.parallel
Example demonstrating parallel branches where some branches include wait operations.
ParallelWithWaitExample() - Constructor for class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample
 
ParallelWithWaitExample.Input - Record Class in software.amazon.lambda.durable.examples.parallel
 
ParallelWithWaitExample.Output - Record Class in software.amazon.lambda.durable.examples.parallel
 
ParameterValidator - Class in software.amazon.lambda.durable.util
Utility class for validating input parameters in the Durable Execution SDK.
parentOperation - Variable in class software.amazon.lambda.durable.operation.BaseDurableOperation
 
payloadSerDes() - Method in class software.amazon.lambda.durable.config.InvokeConfig
 
payloadSerDes(SerDes) - Method in class software.amazon.lambda.durable.config.InvokeConfig.Builder
Sets a custom serializer for the invoke operation payload.
pending() - Static method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Creates a pending output indicating the execution was suspended.
PENDING - Enum constant in enum class software.amazon.lambda.durable.model.ExecutionStatus
 
pollForOperationUpdates() - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Polls the backend for updates to this operation.
pollForOperationUpdates(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
 
pollForOperationUpdates(String, Instant) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Pools for operation updates at a specific time
pollForOperationUpdates(Instant) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Polls the backend for updates to this operation at a specific time.
PollingStrategies - Class in software.amazon.lambda.durable.retry
Factory class for creating common polling strategies.
PollingStrategies() - Constructor for class software.amazon.lambda.durable.retry.PollingStrategies
 
PollingStrategies.Presets - Class in software.amazon.lambda.durable.retry
Preset polling strategies for common use cases.
PollingStrategy - Interface in software.amazon.lambda.durable.retry
Functional interface for computing polling delays between attempts.
pollUntil(Predicate<AsyncExecution<O>>) - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Poll execution history until the given condition is met.
pollUntilComplete() - Method in class software.amazon.lambda.durable.testing.AsyncExecution
Poll until execution completes and return the final result.
pollUntilComplete(String, Duration, Duration) - Method in class software.amazon.lambda.durable.testing.HistoryPoller
Polls execution history until a terminal event is found or the timeout is exceeded.
Presets() - Constructor for class software.amazon.lambda.durable.retry.PollingStrategies.Presets
 
Presets() - Constructor for class software.amazon.lambda.durable.retry.RetryStrategies.Presets
 
Presets() - Constructor for class software.amazon.lambda.durable.retry.WaitStrategies.Presets
 
processEvents(List<Event>, TypeToken<O>) - Method in class software.amazon.lambda.durable.testing.HistoryEventProcessor
Processes a list of execution history events into a structured TestResult.

R

registerActiveThread(String) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Registers a thread as active.
registerActiveThread(String) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Registers a thread as active in the execution manager.
registerOperation(BaseDurableOperation) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Registers an operation so it can receive checkpoint completion notifications.
replay(Operation) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Replays the operation from an existing checkpoint.
replay(Operation) - Method in class software.amazon.lambda.durable.operation.CallbackOperation
Replays the operation.
replay(Operation) - Method in class software.amazon.lambda.durable.operation.ChildContextOperation
Replays the operation.
replay(Operation) - Method in class software.amazon.lambda.durable.operation.InvokeOperation
Replays the operation.
replay(Operation) - Method in class software.amazon.lambda.durable.operation.MapOperation
 
replay(Operation) - Method in class software.amazon.lambda.durable.operation.ParallelOperation
 
replay(Operation) - Method in class software.amazon.lambda.durable.operation.StepOperation
Replays the operation.
replay(Operation) - Method in class software.amazon.lambda.durable.operation.WaitForConditionOperation
 
replay(Operation) - Method in class software.amazon.lambda.durable.operation.WaitOperation
Replays the operation.
replayTimeMs() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
Returns the value of the replayTimeMs record component.
replayTimeMs() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
Returns the value of the replayTimeMs record component.
reset() - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Clears all operations and events, resetting the client to its initial state.
resetCheckpointToStarted(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Resets a named step operation to STARTED status, simulating a checkpoint failure.
resetCheckpointToStarted(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Simulate checkpoint failure by forcing an operation into STARTED state
result() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
Returns the value of the result record component.
result() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
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.testing.OperationResult
Returns the value of the result record component.
results() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
Returns the value of the results 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.
RetryExample - Class in software.amazon.lambda.durable.examples.step
Simple example demonstrating retry strategies with a flaky API.
RetryExample() - Constructor for class software.amazon.lambda.durable.examples.step.RetryExample
 
RetryInProcessExample - Class in software.amazon.lambda.durable.examples.step
Example demonstrating in-process retry behavior with concurrent operations.
RetryInProcessExample() - Constructor for class software.amazon.lambda.durable.examples.step.RetryInProcessExample
 
RetryStrategies - Class in software.amazon.lambda.durable.retry
Factory class for creating common retry strategies.
RetryStrategies() - Constructor for class software.amazon.lambda.durable.retry.RetryStrategies
 
RetryStrategies.Presets - Class in software.amazon.lambda.durable.retry
Preset retry strategies for common use cases.
retryStrategy() - Method in class software.amazon.lambda.durable.config.StepConfig
Returns the retry strategy for this step, or the default strategy if not specified.
retryStrategy(RetryStrategy) - Method in class software.amazon.lambda.durable.config.StepConfig.Builder
Sets the retry strategy for the step.
RetryStrategy - Interface in software.amazon.lambda.durable.retry
Functional interface for determining retry behavior when operations fail.
run(I) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Invokes the Lambda function, polls execution history until completion, and returns the result.
run(I) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Run a single invocation (may return PENDING if waiting/retrying).
RUN_IN_CHILD_CONTEXT - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
runInChildContext(String, Class<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
Runs a function in a child context, blocking until it completes.
runInChildContext(String, Class<T>, Function<DurableContext, T>, RunInChildContextConfig) - Method in interface software.amazon.lambda.durable.DurableContext
Runs a function in a child context, blocking until it completes.
runInChildContext(String, TypeToken<T>, Function<DurableContext, T>) - Method in interface software.amazon.lambda.durable.DurableContext
Runs a function in a child context using a 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.
runUntilComplete(I) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Run until completion (SUCCEEDED or FAILED) or pending manual intervention, simulating Lambda re-invocations.
runUntilCompleteOrSuspend(CompletableFuture<T>) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
return a future that completes when userFuture completes successfully or the execution is terminated or suspended.
runUserHandler(Runnable, String, ThreadType) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
 

S

semantics() - Method in class software.amazon.lambda.durable.config.StepConfig
Returns the delivery semantics for this step, defaults to AT_LEAST_ONCE_PER_RETRY if not specified.
semantics(StepSemantics) - Method in class software.amazon.lambda.durable.config.StepConfig.Builder
Sets the delivery semantics for the step.
sendOperationUpdate(OperationUpdate) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
 
sendOperationUpdate(OperationUpdate.Builder) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Sends an operation update synchronously (blocks until the update is acknowledged).
sendOperationUpdateAsync(OperationUpdate.Builder) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Sends an operation update asynchronously.
serDes() - Method in class software.amazon.lambda.durable.config.CallbackConfig
Returns the custom serializer for this callback, or null if not specified (uses default SerDes).
serDes() - Method in class software.amazon.lambda.durable.config.InvokeConfig
 
serDes() - Method in class software.amazon.lambda.durable.config.MapConfig
 
serDes() - Method in class software.amazon.lambda.durable.config.ParallelBranchConfig
Returns the custom serializer for this step, or null if not specified (uses default SerDes).
serDes() - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig
Returns the custom serializer for this RunInChildContext operation, or null if not specified (uses default SerDes).
serDes() - Method in class software.amazon.lambda.durable.config.StepConfig
Returns the custom serializer for this step, or null if not specified (uses default SerDes).
serDes() - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig
Returns the custom serializer, or null if not specified (uses default SerDes).
serDes(SerDes) - Method in class software.amazon.lambda.durable.config.CallbackConfig.Builder
Sets a custom serializer for the callback.
serDes(SerDes) - Method in class software.amazon.lambda.durable.config.InvokeConfig.Builder
Sets a custom serializer for the invoke result.
serDes(SerDes) - Method in class software.amazon.lambda.durable.config.MapConfig.Builder
Sets the custom serializer to use for serializing map items and results.
serDes(SerDes) - Method in class software.amazon.lambda.durable.config.ParallelBranchConfig.Builder
Sets a custom serializer for the step.
serDes(SerDes) - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig.Builder
Sets a custom serializer for the step.
serDes(SerDes) - Method in class software.amazon.lambda.durable.config.StepConfig.Builder
Sets a custom serializer for the step.
serDes(SerDes) - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig.Builder
Sets a custom serializer for the waitForCondition operation.
SerDes - Interface in software.amazon.lambda.durable.serde
Interface for serialization and deserialization of objects.
SerDesException - Exception in software.amazon.lambda.durable.exception
Exception thrown when serialization or deserialization fails.
SerDesException(String) - Constructor for exception software.amazon.lambda.durable.exception.SerDesException
 
SerDesException(String, Throwable) - Constructor for exception software.amazon.lambda.durable.exception.SerDesException
 
SerializableDurableOperation<T> - Class in software.amazon.lambda.durable.operation
Base class for all durable operations (STEP, WAIT, etc.).
SerializableDurableOperation(OperationIdentifier, TypeToken<T>, SerDes, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.SerializableDurableOperation
Constructs a new durable operation.
SerializableDurableOperation(OperationIdentifier, TypeToken<T>, SerDes, DurableContextImpl, BaseDurableOperation) - Constructor for class software.amazon.lambda.durable.operation.SerializableDurableOperation
 
serialize(Object) - Method in class software.amazon.lambda.durable.serde.DurableInputOutputSerDes
Serializes an object to a JSON string.
serialize(Object) - Method in class software.amazon.lambda.durable.serde.JacksonSerDes
 
serialize(Object) - Method in interface software.amazon.lambda.durable.serde.SerDes
Serializes an object to a JSON string.
serializeException(Throwable) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
Serializes a throwable into an ErrorObject for checkpointing.
serializeResult(T) - Method in class software.amazon.lambda.durable.operation.SerializableDurableOperation
Serializes the result to a string.
serializeStackTrace(StackTraceElement[]) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
Serializes a stack trace to a list of pipe-delimited strings in the format className|methodName|fileName|lineNumber.
services() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
Returns the value of the services record component.
ServiceUnavailableException() - Constructor for exception software.amazon.lambda.durable.examples.general.ErrorHandlingExample.ServiceUnavailableException
Default constructor required for Jackson deserialization.
ServiceUnavailableException(String, String) - Constructor for exception software.amazon.lambda.durable.examples.general.ErrorHandlingExample.ServiceUnavailableException
 
setCurrentThreadContext(ThreadContext) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Sets the current thread's ThreadContext (threadId and threadType).
setExecutionMode() - Method in class software.amazon.lambda.durable.context.BaseContextImpl
Transitions this context from replay to execution mode.
setName(String) - Method in class software.amazon.lambda.durable.examples.types.GreetingRequest
 
shouldRetry() - Method in class software.amazon.lambda.durable.retry.RetryDecision
 
SimpleInvokeExample - Class in software.amazon.lambda.durable.examples.invoke
Simple example demonstrating basic invoke execution with the Durable Execution SDK.
SimpleInvokeExample() - Constructor for class software.amazon.lambda.durable.examples.invoke.SimpleInvokeExample
 
SimpleMapExample - Class in software.amazon.lambda.durable.examples.map
Example demonstrating the map operation with the Durable Execution SDK.
SimpleMapExample() - Constructor for class software.amazon.lambda.durable.examples.map.SimpleMapExample
 
SimpleStepExample - Class in software.amazon.lambda.durable.examples.step
Simple example demonstrating basic step execution with the Durable Execution SDK.
SimpleStepExample() - Constructor for class software.amazon.lambda.durable.examples.step.SimpleStepExample
 
simulateFireAndForgetCheckpointLoss(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Removes a named step operation entirely, simulating loss of a fire-and-forget checkpoint.
simulateFireAndForgetCheckpointLoss(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Simulate fire-and-forget checkpoint loss by removing the operation entirely
size() - Method in record class software.amazon.lambda.durable.model.MapResult
Returns the number of items in this result.
size() - Method in record class software.amazon.lambda.durable.model.ParallelResult
Returns the value of the size record component.
skipped() - Static method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Creates a skipped result item.
SKIPPED - Enum constant in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
 
sneakyThrow(Throwable) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
Throws any exception as if it were unchecked using type erasure.
software.amazon.lambda.durable - package software.amazon.lambda.durable
 
software.amazon.lambda.durable.client - package software.amazon.lambda.durable.client
 
software.amazon.lambda.durable.config - package software.amazon.lambda.durable.config
 
software.amazon.lambda.durable.context - package software.amazon.lambda.durable.context
 
software.amazon.lambda.durable.examples.callback - package software.amazon.lambda.durable.examples.callback
 
software.amazon.lambda.durable.examples.child - package software.amazon.lambda.durable.examples.child
 
software.amazon.lambda.durable.examples.general - package software.amazon.lambda.durable.examples.general
 
software.amazon.lambda.durable.examples.invoke - package software.amazon.lambda.durable.examples.invoke
 
software.amazon.lambda.durable.examples.map - package software.amazon.lambda.durable.examples.map
 
software.amazon.lambda.durable.examples.parallel - package software.amazon.lambda.durable.examples.parallel
 
software.amazon.lambda.durable.examples.step - package software.amazon.lambda.durable.examples.step
 
software.amazon.lambda.durable.examples.types - package software.amazon.lambda.durable.examples.types
 
software.amazon.lambda.durable.examples.wait - package software.amazon.lambda.durable.examples.wait
 
software.amazon.lambda.durable.exception - package software.amazon.lambda.durable.exception
 
software.amazon.lambda.durable.execution - package software.amazon.lambda.durable.execution
 
software.amazon.lambda.durable.logging - package software.amazon.lambda.durable.logging
 
software.amazon.lambda.durable.model - package software.amazon.lambda.durable.model
 
software.amazon.lambda.durable.operation - package software.amazon.lambda.durable.operation
 
software.amazon.lambda.durable.retry - package software.amazon.lambda.durable.retry
 
software.amazon.lambda.durable.serde - package software.amazon.lambda.durable.serde
 
software.amazon.lambda.durable.testing - package software.amazon.lambda.durable.testing
 
software.amazon.lambda.durable.util - package software.amazon.lambda.durable.util
 
stackTrace() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
Returns the value of the 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.
startAsync(I) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Start an asynchronous execution and return a handle for incremental polling.
status() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Returns the value of the status record component.
status() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Returns the value of the status 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
 
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
 
steps() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
Returns the value of the steps record component.
steps() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
Returns the value of the steps record component.
StepSemantics - Enum Class in software.amazon.lambda.durable.config
Delivery semantics for step operations.
stopChainedInvoke(String, ErrorObject) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Stops a chained invoke operation with the given error.
stopPolling(T) - Static method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Creates a result indicating the condition is met and polling should stop.
subType() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns the value of the subType record component.
succeeded() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
Returns the value of the succeeded 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.MapResult.MapResultItem
Creates a successful result item.
SUCCEEDED - Enum constant in enum class software.amazon.lambda.durable.model.ExecutionStatus
 
SUCCEEDED - Enum constant in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
 
success() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
Returns the value of the success record component.
success(String) - Static method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Creates a successful output with the given serialized result.
suppressReplayLogs() - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
Returns the value of the 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 - Exception in software.amazon.lambda.durable.execution
Exception thrown to suspend execution during wait operations.
SuspendExecutionException() - Constructor for exception software.amazon.lambda.durable.execution.SuspendExecutionException
 

T

tenantId() - Method in class software.amazon.lambda.durable.config.InvokeConfig
 
tenantId(String) - Method in class software.amazon.lambda.durable.config.InvokeConfig.Builder
Sets the tenant ID for the invoke operation.
terminateExecution(UnrecoverableDurableExecutionException) - Method in class software.amazon.lambda.durable.execution.ExecutionManager
Terminates the execution immediately with an unrecoverable error.
terminateExecution(UnrecoverableDurableExecutionException) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Terminates the execution with the given exception.
terminateExecutionWithIllegalDurableOperationException(String) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Terminates the execution with an IllegalDurableOperationException.
TestOperation - Class in software.amazon.lambda.durable.testing
Wrapper for AWS SDK Operation providing convenient access methods.
TestResult<O> - Class in software.amazon.lambda.durable.testing
Represents the result of a durable execution, providing access to the execution status, output, operations, and history events.
ThreadContext - Record Class in software.amazon.lambda.durable.execution
Holds the current thread's execution context.
ThreadContext(String, ThreadType) - Constructor for record class software.amazon.lambda.durable.execution.ThreadContext
Creates an instance of a 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.
threshold() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
Returns the value of the threshold 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.
timeoutCallback(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Timeout a callback.
timeoutCallback(String) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Simulate callback timeout.
timeoutChainedInvoke(String) - Method in class software.amazon.lambda.durable.testing.LocalDurableTestRunner
Marks a chained invoke operation as timed out.
timeoutSeconds() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
Returns the value of the timeoutSeconds record component.
toBuilder() - Method in class software.amazon.lambda.durable.config.CallbackConfig
Creates a new builder pre-populated with this config's values.
toBuilder() - Method in class software.amazon.lambda.durable.config.InvokeConfig
 
toBuilder() - Method in class software.amazon.lambda.durable.config.MapConfig
 
toBuilder() - Method in class software.amazon.lambda.durable.config.ParallelBranchConfig
 
toBuilder() - Method in class software.amazon.lambda.durable.config.RunInChildContextConfig
 
toBuilder() - Method in class software.amazon.lambda.durable.config.StepConfig
 
toBuilder() - Method in class software.amazon.lambda.durable.config.WaitForCallbackConfig
Creates a builder pre-populated with this instance's values.
toBuilder() - Method in class software.amazon.lambda.durable.config.WaitForConditionConfig
Returns a new builder initialized with the values from this config.
toleratedFailureCount() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
Returns the value of the 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).
toleratedFailures() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
Returns the value of the toleratedFailures record component.
toString() - Method in record class software.amazon.lambda.durable.config.CompletionConfig
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Input
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.child.ManyAsyncChildContextExample.Output
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.parallel.DeserializationFailedParallelExample.Input
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Input
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Input
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelFailureToleranceExample.Output
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Output
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Input
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.step.ManyAsyncStepsExample.Output
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.types.ApprovalRequest
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.execution.ThreadContext
Returns a string representation of this record class.
toString() - Method in enum class software.amazon.lambda.durable.execution.ThreadType
 
toString() - Method in record class software.amazon.lambda.durable.logging.LoggerConfig
Returns a string representation of this record class.
toString() - Method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
 
toString() - Method in record class software.amazon.lambda.durable.model.DurableExecutionInput
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.model.DurableExecutionOutput
Returns a string representation of this record class.
toString() - Method in enum class software.amazon.lambda.durable.model.ExecutionStatus
 
toString() - Method in record class software.amazon.lambda.durable.model.MapResult.MapError
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.model.MapResult.MapResultItem
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.model.MapResult
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.model.OperationIdentifier
Returns a string representation of this record class.
toString() - Method in enum class software.amazon.lambda.durable.model.OperationSubType
 
toString() - Method in record class software.amazon.lambda.durable.model.ParallelResult
Returns a string representation of this record class.
toString() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Returns a string representation of this record class.
toString() - Method in class software.amazon.lambda.durable.retry.RetryDecision
 
toString() - Method in record class software.amazon.lambda.durable.testing.OperationResult
Returns a string representation of this record class.
toString() - Method in class software.amazon.lambda.durable.TypeToken
 
totalOperations() - Method in record class software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample.Input
Returns the value of the totalOperations record component.
totalProcessed() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelExample.Output
Returns the value of the totalProcessed record component.
toTestResult(DurableExecutionOutput) - Method in class software.amazon.lambda.durable.testing.LocalMemoryExecutionClient
Build TestResult from current state.
trace(String, Object...) - Method in class software.amazon.lambda.durable.logging.DurableLogger
 
TypeToken<T> - Class in software.amazon.lambda.durable
Framework-agnostic type token for capturing generic type information at runtime.
TypeToken() - Constructor for class software.amazon.lambda.durable.TypeToken
Constructs a new TypeToken.

U

UnrecoverableDurableExecutionException - Exception in software.amazon.lambda.durable.exception
Exception thrown when the execution is not recoverable.
UnrecoverableDurableExecutionException(ErrorObject) - Constructor for exception software.amazon.lambda.durable.exception.UnrecoverableDurableExecutionException
 
unwrapCompletableFuture(Throwable) - Static method in class software.amazon.lambda.durable.util.ExceptionHelper
unwrap the exception that is wrapped by CompletionException
userAge - Variable in class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
 
userId - Variable in class software.amazon.lambda.durable.examples.general.CustomConfigExample.CustomData
 
userId - Variable in class software.amazon.lambda.durable.examples.general.GenericTypesExample.Input
 
userId() - Method in record class software.amazon.lambda.durable.examples.parallel.ParallelWithWaitExample.Input
Returns the value of the userId record component.

V

validateConfiguration() - Method in class software.amazon.lambda.durable.DurableConfig
 
validateDuration(Duration, String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
Validates that a duration is at least 1 second.
validateOperationName(String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
 
validateOperationName(String, int) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
 
validateOptionalDuration(Duration, String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
Validates that an optional duration (if provided) is at least 1 second.
validateOptionalPositiveInteger(Integer, String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
Validates that an optional integer value (if provided) is positive (greater than 0).
validateOrderedCollection(Collection<?>) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
Validates that a collection has deterministic iteration order.
validatePositiveInteger(Integer, String) - Static method in class software.amazon.lambda.durable.util.ParameterValidator
Validates that an integer value is positive (greater than 0).
validateReplay(Operation) - Method in class software.amazon.lambda.durable.operation.BaseDurableOperation
Validates that current operation matches checkpointed operation during replay.
value() - Method in record class software.amazon.lambda.durable.model.WaitForConditionResult
Returns the value of the value record component.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.config.StepSemantics
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.execution.ThreadType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.model.ExecutionStatus
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.model.OperationSubType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class software.amazon.lambda.durable.retry.JitterStrategy
Returns the enum constant of this class with the specified name.
values() - Static method in enum class software.amazon.lambda.durable.config.StepSemantics
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class software.amazon.lambda.durable.execution.ThreadType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class software.amazon.lambda.durable.model.ConcurrencyCompletionStatus
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class software.amazon.lambda.durable.model.ExecutionStatus
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class software.amazon.lambda.durable.model.MapResult.MapResultItem.Status
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class software.amazon.lambda.durable.model.OperationSubType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class software.amazon.lambda.durable.retry.JitterStrategy
Returns an array containing the constants of this enum class, in the order they are declared.

W

wait(String, Duration) - Method in interface software.amazon.lambda.durable.DurableContext
Suspends execution for the specified duration without consuming compute resources.
WAIT_FOR_CALLBACK - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
WAIT_FOR_CONDITION - Enum constant in enum class software.amazon.lambda.durable.model.OperationSubType
 
waitAsync(String, Duration) - Method in class software.amazon.lambda.durable.context.DurableContextImpl
 
waitAsync(String, Duration) - Method in interface software.amazon.lambda.durable.DurableContext
Asynchronously suspends execution for the specified duration.
WaitAsyncExample - Class in software.amazon.lambda.durable.examples.wait
Example demonstrating non-blocking wait with waitAsync().
WaitAsyncExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitAsyncExample
 
WaitAtLeastExample - Class in software.amazon.lambda.durable.examples.wait
Example demonstrating concurrent stepAsync() with wait() operations.
WaitAtLeastExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitAtLeastExample
 
WaitAtLeastInProcessExample - Class in software.amazon.lambda.durable.examples.wait
Example demonstrating concurrent stepAsync() with wait() operations where no suspension occurs.
WaitAtLeastInProcessExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitAtLeastInProcessExample
 
WaitExample - Class in software.amazon.lambda.durable.examples.wait
Example demonstrating step execution with wait operations.
WaitExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitExample
 
waitForCallback(String, Class<T>, BiConsumer<String, StepContext>) - Method in interface software.amazon.lambda.durable.DurableContext
Executes a submitter function and waits for an external callback, blocking until the callback completes.
waitForCallback(String, Class<T>, BiConsumer<String, StepContext>, WaitForCallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
Executes a submitter and waits for an external callback with custom configuration, blocking until complete.
waitForCallback(String, TypeToken<T>, BiConsumer<String, StepContext>) - Method in interface software.amazon.lambda.durable.DurableContext
Executes a submitter and waits for an external callback using a TypeToken, blocking until complete.
waitForCallback(String, TypeToken<T>, BiConsumer<String, StepContext>, WaitForCallbackConfig) - Method in interface software.amazon.lambda.durable.DurableContext
Executes a submitter and waits for an external callback using a 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
WaitForCallbackFailedExample - Class in software.amazon.lambda.durable.examples.callback
 
WaitForCallbackFailedExample() - Constructor for class software.amazon.lambda.durable.examples.callback.WaitForCallbackFailedExample
 
waitForCondition(String, Class<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>) - Method in interface software.amazon.lambda.durable.DurableContext
Polls a condition function until it signals done, blocking until complete.
waitForCondition(String, Class<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>, WaitForConditionConfig<T>) - Method in interface software.amazon.lambda.durable.DurableContext
Polls a condition function until it signals done, using a custom configuration, blocking until complete.
waitForCondition(String, TypeToken<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>) - Method in interface software.amazon.lambda.durable.DurableContext
Polls a condition function until it signals done, using a TypeToken, blocking until complete.
waitForCondition(String, TypeToken<T>, BiFunction<T, StepContext, WaitForConditionResult<T>>, WaitForConditionConfig<T>) - Method in interface software.amazon.lambda.durable.DurableContext
Polls a condition function until it signals done, using a 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
 
WaitForConditionExample - Class in software.amazon.lambda.durable.examples.wait
Example demonstrating the waitForCondition operation.
WaitForConditionExample() - Constructor for class software.amazon.lambda.durable.examples.wait.WaitForConditionExample
 
WaitForConditionFailedException - Exception in software.amazon.lambda.durable.exception
Exception thrown when a 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(String, String, BiFunction<T, StepContext, WaitForConditionResult<T>>, TypeToken<T>, WaitForConditionConfig<T>, DurableContextImpl) - Constructor for class software.amazon.lambda.durable.operation.WaitForConditionOperation
 
WaitForConditionResult<T> - Record Class in software.amazon.lambda.durable.model
Result returned by a WaitForCondition check function to signal whether the condition is met.
WaitForConditionResult(T, boolean) - Constructor for record class software.amazon.lambda.durable.model.WaitForConditionResult
Creates an instance of a 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
 
withCheckpointDelay(Duration) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets how often the SDK checkpoints updates to backend.
withDurableExecutionClient(DurableExecutionClient) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets a custom DurableExecutionClient.
withExecutorService(ExecutorService) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets a custom ExecutorService for running user-defined operations.
withInvocationType(InvocationType) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Returns a new runner with the specified Lambda invocation type.
withLambdaClientBuilder(LambdaClientBuilder) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets a custom LambdaClient for production use.
withLoggerConfig(LoggerConfig) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets a custom LoggerConfig.
withPollingStrategy(PollingStrategy) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets the polling strategy.
withPollInterval(Duration) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Returns a new runner with the specified poll interval between history checks.
withReplayLogging() - Static method in record class software.amazon.lambda.durable.logging.LoggerConfig
Configuration that allows logs during replay.
withSerDes(SerDes) - Method in class software.amazon.lambda.durable.DurableConfig.Builder
Sets a custom SerDes implementation.
withTimeout(Duration) - Method in class software.amazon.lambda.durable.testing.CloudDurableTestRunner
Returns a new runner with the specified maximum wait time for execution completion.
wrap(TypeToken<I>, BiFunction<I, DurableContext, O>, DurableConfig) - Static method in class software.amazon.lambda.durable.execution.DurableExecutor
Wraps a user handler in a RequestHandler that can be used by the Lambda runtime.
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