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.

Nested Class Summary

Nested classes/interfaces inherited from class software.amazon.lambda.durable.operation.SerializableDurableOperation

SerializableDurableOperation.SerializedResult<T>

Field Summary

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

completionFuture, executionManager, isVirtual, parentOperation, replayCompletedOperation

Constructor Summary

Constructors

Constructor	Description
WaitForConditionOperation(OperationIdentifier operationIdentifier, 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, serDesContext, serializeAndDeserializeResult, serializeException

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

deregisterActiveThread, execute, extractErrorFromOperation, fireOnOperationEnd, getChildOperations, getCompletionFuture, getContext, getCurrentThreadContext, getErrorObject, getName, getOperation, getOperationId, getRunningUserHandler, getSubType, getType, interruptRunningUserHandler, isOperationCompleted, isRunningUserHandlerOwner, markAlreadyCompleted, onCheckpointComplete, pollForOperationUpdates, pollForOperationUpdates, processCheckpointUpdate, registerActiveThread, runUserFunction, runUserHandler, sendOperationUpdate, sendOperationUpdateAsync, terminateExecution, terminateExecutionWithIllegalDurableOperationException, validateReplay, waitForFirstOperationCompletion, waitForOperationCompletion

Methods inherited from class java.lang.Object

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

Constructor Details

WaitForConditionOperation

public WaitForConditionOperation(OperationIdentifier operationIdentifier,
 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