Package software.amazon.lambda.durable

Class DurableContext

java.lang.Object

software.amazon.lambda.durable.DurableContext

public class DurableContext
extends Object

Method Summary

Modifier and Type	Method	Description
<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)
static DurableContext	createChildContext(ExecutionManager executionManager, DurableConfig durableConfig, com.amazonaws.services.lambda.runtime.Context lambdaContext, String contextId)	Creates a child context without registering the current thread.
ExecutionContext	getExecutionContext()	Returns metadata about the current durable execution.
com.amazonaws.services.lambda.runtime.Context	getLambdaContext()
DurableLogger	getLogger()
<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, Supplier<T> func)
<T> T	step(String name, Class<T> resultType, Supplier<T> func, StepConfig config)
<T> T	step(String name, TypeToken<T> typeToken, Supplier<T> func)
<T> T	step(String name, TypeToken<T> typeToken, Supplier<T> func, StepConfig config)
<T> DurableFuture<T>	stepAsync(String name, Class<T> resultType, Supplier<T> func)
<T> DurableFuture<T>	stepAsync(String name, Class<T> resultType, Supplier<T> func, StepConfig config)
<T> DurableFuture<T>	stepAsync(String name, TypeToken<T> typeToken, Supplier<T> func)
<T> DurableFuture<T>	stepAsync(String name, TypeToken<T> typeToken, Supplier<T> func, StepConfig config)
Void	wait(String waitName, Duration duration)
Void	wait(Duration duration)

Methods inherited from class java.lang.Object

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

Method Details

createChildContext

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

Creates a child context without registering the current thread. Thread registration is handled by ChildContextOperation, which registers on the parent thread before the executor runs and sets the context on the child thread inside the executor.

Parameters:

executionManager - the execution manager

durableConfig - the durable configuration

lambdaContext - the Lambda context

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

Returns:

a new DurableContext for the child context

step

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

step

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

step

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

step

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

stepAsync

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

stepAsync

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

stepAsync

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

stepAsync

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

wait

public Void wait(Duration duration)

wait

public Void wait(String waitName,
 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)

getLambdaContext

public com.amazonaws.services.lambda.runtime.Context getLambdaContext()

getLogger

public DurableLogger getLogger()

getExecutionContext

public ExecutionContext getExecutionContext()

Returns metadata about the current durable execution.

The execution context provides information that remains constant throughout the execution lifecycle, such as the durable execution ARN. This is useful for tracking execution progress, correlating logs, and referencing this execution in external systems.

Returns:

the execution context