Package software.amazon.lambda.durable.operation

Class ChildContextOperation<T>

java.lang.Object

software.amazon.lambda.durable.operation.BaseDurableOperation<T>

software.amazon.lambda.durable.operation.ChildContextOperation<T>

All Implemented Interfaces:

DurableFuture<T>

public class ChildContextOperation<T>
extends BaseDurableOperation<T>

Manages the lifecycle of a child execution context.

A child context runs a user function in a separate thread with its own operation counter and checkpoint log. Operations within the child context use the child's context ID as their parentId.

Field Summary

Fields inherited from class software.amazon.lambda.durable.operation.BaseDurableOperation

completionFuture

Constructor Summary

Constructors

Constructor	Description
ChildContextOperation(String operationId, String name, Function<DurableContext,T> function, OperationSubType subType, TypeToken<T> resultTypeToken, SerDes resultSerDes, DurableContext durableContext)

Method Summary

Modifier and Type	Method	Description
T	get()	Blocks until the operation completes and returns the result.
protected void	replay(software.amazon.awssdk.services.lambda.model.Operation existing)	Replays the operation.
protected void	start()	Starts the operation.

Methods inherited from class software.amazon.lambda.durable.operation.BaseDurableOperation

deserializeException, deserializeResult, execute, getChildOperations, getContext, getCurrentThreadContext, getName, getOperation, getOperationId, getType, isOperationCompleted, markAlreadyCompleted, onCheckpointComplete, pollForOperationUpdates, pollForOperationUpdates, registerActiveThread, sendOperationUpdate, sendOperationUpdateAsync, serializeException, serializeResult, terminateExecution, terminateExecutionWithIllegalDurableOperationException, validateReplay, waitForOperationCompletion

Methods inherited from class java.lang.Object

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

Constructor Details

ChildContextOperation

public ChildContextOperation(String operationId,
 String name,
 Function<DurableContext,T> function,
 OperationSubType subType,
 TypeToken<T> resultTypeToken,
 SerDes resultSerDes,
 DurableContext durableContext)

Method Details

start

protected void start()

Starts the operation.

Specified by:

start in class BaseDurableOperation<T>

replay

protected void replay(software.amazon.awssdk.services.lambda.model.Operation existing)

Replays the operation.

Specified by:

replay in class BaseDurableOperation<T>

get

public T get()

Description copied from interface: DurableFuture

Blocks until the operation completes and returns the result.

This delegates to operation.get() which handles: - Thread deregistration (allows suspension) - Thread reactivation (resumes execution) - Result retrieval

Returns:

the operation result