Package software.amazon.lambda.durable

Class DurableContext

java.lang.Object

software.amazon.lambda.durable.BaseContext

software.amazon.lambda.durable.DurableContext

All Implemented Interfaces:

AutoCloseable

public class DurableContext
extends BaseContext

Method Summary

Modifier and Type	Method	Description
void	close()	Clears the logger's thread properties.
<T> DurableCallbackFuture<T>	createCallback(String name, Class<T> resultType)
<T> DurableCallbackFuture<T>	createCallback(String name, Class<T> resultType, CallbackConfig config)
<T> DurableCallbackFuture<T>	createCallback(String name, TypeToken<T> typeToken)
<T> DurableCallbackFuture<T>	createCallback(String name, TypeToken<T> typeToken, CallbackConfig config)
DurableContext	createChildContext(String childContextId, String childContextName)	Creates a child context.
static DurableContext	createRootContext(ExecutionManager executionManager, DurableConfig durableConfig, com.amazonaws.services.lambda.runtime.Context lambdaContext)	Creates a root context (contextId = null)
StepContext	createStepContext(String stepOperationId, String stepOperationName, int attempt)	Creates a step context for executing step operations.
DurableLogger	getLogger()	Returns a logger with execution context information for replay-aware logging.
<T, U> T	invoke(String name, String functionName, U payload, Class<T> resultType)
<T, U> T	invoke(String name, String functionName, U payload, Class<T> resultType, InvokeConfig config)
<T, U> T	invoke(String name, String functionName, U payload, TypeToken<T> typeToken)
<T, U> T	invoke(String name, String functionName, U payload, TypeToken<T> typeToken, InvokeConfig config)
<T, U> DurableFuture<T>	invokeAsync(String name, String functionName, U payload, Class<T> resultType)
<T, U> DurableFuture<T>	invokeAsync(String name, String functionName, U payload, Class<T> resultType, InvokeConfig config)
<T, U> DurableFuture<T>	invokeAsync(String name, String functionName, U payload, TypeToken<T> resultType)
<T, U> DurableFuture<T>	invokeAsync(String name, String functionName, U payload, TypeToken<T> typeToken, InvokeConfig config)
<T> T	runInChildContext(String name, Class<T> resultType, Function<DurableContext,T> func)
<T> T	runInChildContext(String name, TypeToken<T> typeToken, Function<DurableContext,T> func)
<T> DurableFuture<T>	runInChildContextAsync(String name, Class<T> resultType, Function<DurableContext,T> func)
<T> DurableFuture<T>	runInChildContextAsync(String name, TypeToken<T> typeToken, Function<DurableContext,T> func)
<T> T	step(String name, Class<T> resultType, Function<StepContext,T> func)
<T> T	step(String name, Class<T> resultType, Function<StepContext,T> func, StepConfig config)
<T> T	step(String name, Class<T> resultType, Supplier<T> func)	Deprecated. use the variants accepting StepContext instead
<T> T	step(String name, Class<T> resultType, Supplier<T> func, StepConfig config)	Deprecated. use the variants accepting StepContext instead
<T> T	step(String name, TypeToken<T> typeToken, Function<StepContext,T> func)
<T> T	step(String name, TypeToken<T> typeToken, Function<StepContext,T> func, StepConfig config)
<T> T	step(String name, TypeToken<T> typeToken, Supplier<T> func)	Deprecated. use the variants accepting StepContext instead
<T> T	step(String name, TypeToken<T> typeToken, Supplier<T> func, StepConfig config)	Deprecated. use the variants accepting StepContext instead
<T> DurableFuture<T>	stepAsync(String name, Class<T> resultType, Function<StepContext,T> func)
<T> DurableFuture<T>	stepAsync(String name, Class<T> resultType, Function<StepContext,T> func, StepConfig config)
<T> DurableFuture<T>	stepAsync(String name, Class<T> resultType, Supplier<T> func)	Deprecated. use the variants accepting StepContext instead
<T> DurableFuture<T>	stepAsync(String name, Class<T> resultType, Supplier<T> func, StepConfig config)	Deprecated. use the variants accepting StepContext instead
<T> DurableFuture<T>	stepAsync(String name, TypeToken<T> typeToken, Function<StepContext,T> func)
<T> DurableFuture<T>	stepAsync(String name, TypeToken<T> typeToken, Function<StepContext,T> func, StepConfig config)
<T> DurableFuture<T>	stepAsync(String name, TypeToken<T> typeToken, Supplier<T> func)	Deprecated. use the variants accepting StepContext instead
<T> DurableFuture<T>	stepAsync(String name, TypeToken<T> typeToken, Supplier<T> func, StepConfig config)	Deprecated. use the variants accepting StepContext instead
Void	wait(String name, Duration duration)
DurableFuture<Void>	waitAsync(String name, Duration duration)
<T> T	waitForCallback(String name, Class<T> resultType, BiConsumer<String,StepContext> func)
<T> T	waitForCallback(String name, Class<T> resultType, BiConsumer<String,StepContext> func, WaitForCallbackConfig waitForCallbackConfig)
<T> T	waitForCallback(String name, TypeToken<T> typeToken, BiConsumer<String,StepContext> func)
<T> T	waitForCallback(String name, TypeToken<T> typeToken, BiConsumer<String,StepContext> func, WaitForCallbackConfig waitForCallbackConfig)
<T> DurableFuture<T>	waitForCallbackAsync(String name, Class<T> resultType, BiConsumer<String,StepContext> func)
<T> DurableFuture<T>	waitForCallbackAsync(String name, Class<T> resultType, BiConsumer<String,StepContext> func, WaitForCallbackConfig waitForCallbackConfig)
<T> DurableFuture<T>	waitForCallbackAsync(String name, TypeToken<T> typeToken, BiConsumer<String,StepContext> func)
<T> DurableFuture<T>	waitForCallbackAsync(String name, TypeToken<T> typeToken, BiConsumer<String,StepContext> func, WaitForCallbackConfig waitForCallbackConfig)

Methods inherited from class software.amazon.lambda.durable.BaseContext

getContextId, getContextName, getDurableConfig, getExecutionContext, getExecutionManager, getLambdaContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

createRootContext

public static DurableContext createRootContext(ExecutionManager executionManager,
 DurableConfig durableConfig,
 com.amazonaws.services.lambda.runtime.Context lambdaContext)

Creates a root context (contextId = null)

The context itself always has a null contextId (making it a root context).

Parameters:

executionManager - the execution manager

durableConfig - the durable configuration

lambdaContext - the Lambda context

Returns:

a new root DurableContext

createChildContext

public DurableContext createChildContext(String childContextId,
 String childContextName)

Creates a child context.

Parameters:

childContextId - the child context's ID (the CONTEXT operation's operation ID)

Returns:

a new DurableContext for the child context

createStepContext

public StepContext createStepContext(String stepOperationId,
 String stepOperationName,
 int attempt)

Creates a step context for executing step operations.

Parameters:

stepOperationId - the ID of the step operation (used for thread registration)

Returns:

a new StepContext instance

step

public <T> T step(String name,
 Class<T> resultType,
 Function<StepContext,T> func)

step

public <T> T step(String name,
 Class<T> resultType,
 Function<StepContext,T> func,
 StepConfig config)

step

public <T> T step(String name,
 TypeToken<T> typeToken,
 Function<StepContext,T> func)

step

public <T> T step(String name,
 TypeToken<T> typeToken,
 Function<StepContext,T> func,
 StepConfig config)

stepAsync

public <T> DurableFuture<T> stepAsync(String name,
 Class<T> resultType,
 Function<StepContext,T> func)

stepAsync

public <T> DurableFuture<T> stepAsync(String name,
 Class<T> resultType,
 Function<StepContext,T> func,
 StepConfig config)

stepAsync

public <T> DurableFuture<T> stepAsync(String name,
 TypeToken<T> typeToken,
 Function<StepContext,T> func)

stepAsync

public <T> DurableFuture<T> stepAsync(String name,
 TypeToken<T> typeToken,
 Function<StepContext,T> func,
 StepConfig config)

step

public <T> T step(String name,
 Class<T> resultType,
 Supplier<T> func)

Deprecated.

use the variants accepting StepContext instead

step

public <T> T step(String name,
 Class<T> resultType,
 Supplier<T> func,
 StepConfig config)

Deprecated.

use the variants accepting StepContext instead

step

public <T> T step(String name,
 TypeToken<T> typeToken,
 Supplier<T> func)

Deprecated.

use the variants accepting StepContext instead

step

public <T> T step(String name,
 TypeToken<T> typeToken,
 Supplier<T> func,
 StepConfig config)

Deprecated.

use the variants accepting StepContext instead

stepAsync

public <T> DurableFuture<T> stepAsync(String name,
 Class<T> resultType,
 Supplier<T> func)

Deprecated.

use the variants accepting StepContext instead

stepAsync

public <T> DurableFuture<T> stepAsync(String name,
 Class<T> resultType,
 Supplier<T> func,
 StepConfig config)

Deprecated.

use the variants accepting StepContext instead

stepAsync

public <T> DurableFuture<T> stepAsync(String name,
 TypeToken<T> typeToken,
 Supplier<T> func)

Deprecated.

use the variants accepting StepContext instead

stepAsync

public <T> DurableFuture<T> stepAsync(String name,
 TypeToken<T> typeToken,
 Supplier<T> func,
 StepConfig config)

Deprecated.

use the variants accepting StepContext instead

wait

public Void wait(String name,
 Duration duration)

waitAsync

public DurableFuture<Void> waitAsync(String name,
 Duration duration)

invoke

public <T,
U> T invoke(String name,
 String functionName,
 U payload,
 Class<T> resultType)

invoke

public <T,
U> T invoke(String name,
 String functionName,
 U payload,
 Class<T> resultType,
 InvokeConfig config)

invoke

public <T,
U> T invoke(String name,
 String functionName,
 U payload,
 TypeToken<T> typeToken)

invoke

public <T,
U> T invoke(String name,
 String functionName,
 U payload,
 TypeToken<T> typeToken,
 InvokeConfig config)

invokeAsync

public <T,
U> DurableFuture<T> invokeAsync(String name,
 String functionName,
 U payload,
 Class<T> resultType,
 InvokeConfig config)

invokeAsync

public <T,
U> DurableFuture<T> invokeAsync(String name,
 String functionName,
 U payload,
 Class<T> resultType)

invokeAsync

public <T,
U> DurableFuture<T> invokeAsync(String name,
 String functionName,
 U payload,
 TypeToken<T> resultType)

invokeAsync

public <T,
U> DurableFuture<T> invokeAsync(String name,
 String functionName,
 U payload,
 TypeToken<T> typeToken,
 InvokeConfig config)

createCallback

public <T> DurableCallbackFuture<T> createCallback(String name,
 Class<T> resultType,
 CallbackConfig config)

createCallback

public <T> DurableCallbackFuture<T> createCallback(String name,
 TypeToken<T> typeToken)

createCallback

public <T> DurableCallbackFuture<T> createCallback(String name,
 Class<T> resultType)

createCallback

public <T> DurableCallbackFuture<T> createCallback(String name,
 TypeToken<T> typeToken,
 CallbackConfig config)

runInChildContext

public <T> T runInChildContext(String name,
 Class<T> resultType,
 Function<DurableContext,T> func)

runInChildContext

public <T> T runInChildContext(String name,
 TypeToken<T> typeToken,
 Function<DurableContext,T> func)

runInChildContextAsync

public <T> DurableFuture<T> runInChildContextAsync(String name,
 Class<T> resultType,
 Function<DurableContext,T> func)

runInChildContextAsync

public <T> DurableFuture<T> runInChildContextAsync(String name,
 TypeToken<T> typeToken,
 Function<DurableContext,T> func)

waitForCallback

public <T> T waitForCallback(String name,
 Class<T> resultType,
 BiConsumer<String,StepContext> func)

waitForCallback

public <T> T waitForCallback(String name,
 TypeToken<T> typeToken,
 BiConsumer<String,StepContext> func)

waitForCallback

public <T> T waitForCallback(String name,
 Class<T> resultType,
 BiConsumer<String,StepContext> func,
 WaitForCallbackConfig waitForCallbackConfig)

waitForCallback

public <T> T waitForCallback(String name,
 TypeToken<T> typeToken,
 BiConsumer<String,StepContext> func,
 WaitForCallbackConfig waitForCallbackConfig)

waitForCallbackAsync

public <T> DurableFuture<T> waitForCallbackAsync(String name,
 Class<T> resultType,
 BiConsumer<String,StepContext> func)

waitForCallbackAsync

public <T> DurableFuture<T> waitForCallbackAsync(String name,
 TypeToken<T> typeToken,
 BiConsumer<String,StepContext> func)

waitForCallbackAsync

public <T> DurableFuture<T> waitForCallbackAsync(String name,
 Class<T> resultType,
 BiConsumer<String,StepContext> func,
 WaitForCallbackConfig waitForCallbackConfig)

waitForCallbackAsync

public <T> DurableFuture<T> waitForCallbackAsync(String name,
 TypeToken<T> typeToken,
 BiConsumer<String,StepContext> func,
 WaitForCallbackConfig waitForCallbackConfig)

getLogger

public DurableLogger getLogger()

Returns a logger with execution context information for replay-aware logging.

Specified by:

getLogger in class BaseContext

Returns:

the durable logger

close

public void close()

Clears the logger's thread properties. Called during context destruction to prevent memory leaks and ensure clean state for subsequent executions.

Specified by:

close in interface AutoCloseable

Overrides:

close in class BaseContext