Package software.amazon.lambda.durable.operation

Class WaitForConditionOperation<T>

java.lang.Object

software.amazon.lambda.durable.operation.BaseDurableOperation

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

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

Type Parameters:

T - the type of state being polled

All Implemented Interfaces:

DurableFuture<T>

public class WaitForConditionOperation<T>
extends SerializableDurableOperation<T>

Durable operation that periodically checks a user-supplied condition function, using a configurable wait strategy to determine polling intervals and termination.

Uses OperationType.STEP with OperationSubType.WAIT_FOR_CONDITION subtype. Each polling iteration is checkpointed as a RETRY on the same STEP operation.

Field Summary

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

completionFuture, executionManager, parentOperation

Constructor Summary

Constructors

Constructor	Description
WaitForConditionOperation(String operationId, String name, BiFunction<T,StepContext,WaitForConditionResult<T>> checkFunc, TypeToken<T> resultTypeToken, WaitForConditionConfig<T> config, DurableContextImpl 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 from an existing checkpoint.
protected void	start()	Starts the operation on first execution (no existing checkpoint).

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

deserializeException, deserializeResult, serializeException, serializeResult

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

execute, getChildOperations, getCompletionFuture, getContext, getCurrentThreadContext, getName, getOperation, getOperationId, getSubType, getType, isOperationCompleted, markAlreadyCompleted, onCheckpointComplete, pollForOperationUpdates, pollForOperationUpdates, registerActiveThread, runUserHandler, sendOperationUpdate, sendOperationUpdateAsync, terminateExecution, terminateExecutionWithIllegalDurableOperationException, validateReplay, waitForOperationCompletion

Methods inherited from class java.lang.Object

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

Constructor Details

WaitForConditionOperation

public WaitForConditionOperation(String operationId,
 String name,
 BiFunction<T,StepContext,WaitForConditionResult<T>> checkFunc,
 TypeToken<T> resultTypeToken,
 WaitForConditionConfig<T> config,
 DurableContextImpl durableContext)

Method Details

start

protected void start()

Description copied from class: BaseDurableOperation

Starts the operation on first execution (no existing checkpoint).

Specified by:

start in class BaseDurableOperation

replay

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

Description copied from class: BaseDurableOperation

Replays the operation from an existing checkpoint.

Specified by:

replay in class BaseDurableOperation

Parameters:

existing - the checkpointed operation state

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

Specified by:

get in interface DurableFuture<T>

Specified by:

get in class SerializableDurableOperation<T>

Returns:

the operation result