class Amazonite::Lambda::CheckpointDurableExecutionRequest

Included Modules

Defined in:

lambda/checkpoint_durable_execution_request.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(durable_execution_arn : String, checkpoint_token : String, updates : Array(OperationUpdate) | Nil = nil, client_token : String | Nil = nil) #

[View source]
def self.new(pull : JSON::PullParser) #

[View source]
def self.new(*, __pull_for_json_serializable pull : JSON::PullParser) #

[View source]

Instance Method Detail

def ==(other : self) #
Description copied from class Reference

Returns true if this reference is the same as other. Invokes same?.


def checkpoint_token : String #

A unique token that identifies the current checkpoint state. This token is provided by the Lambda runtime and must be used to ensure checkpoints are applied in the correct order. Each checkpoint operation consumes this token and returns a new one.


[View source]
def checkpoint_token=(checkpoint_token : String) #

A unique token that identifies the current checkpoint state. This token is provided by the Lambda runtime and must be used to ensure checkpoints are applied in the correct order. Each checkpoint operation consumes this token and returns a new one.


[View source]
def client_token : String | Nil #

An optional idempotency token to ensure that duplicate checkpoint requests are handled correctly. If provided, Lambda uses this token to detect and handle duplicate requests within a 15-minute window.


[View source]
def client_token=(client_token : String | Nil) #

An optional idempotency token to ensure that duplicate checkpoint requests are handled correctly. If provided, Lambda uses this token to detect and handle duplicate requests within a 15-minute window.


[View source]
def durable_execution_arn : String #

The Amazon Resource Name (ARN) of the durable execution.


[View source]
def durable_execution_arn=(durable_execution_arn : String) #

The Amazon Resource Name (ARN) of the durable execution.


[View source]
def hash(hasher) #
Description copied from class Reference

See Object#hash(hasher)


def updates : Array(OperationUpdate) | Nil #

An array of state updates to apply during this checkpoint. Each update represents a change to the execution state, such as completing a step, starting a callback, or scheduling a timer. Updates are applied atomically as part of the checkpoint operation.


[View source]
def updates=(updates : Array(OperationUpdate) | Nil) #

An array of state updates to apply during this checkpoint. Each update represents a change to the execution state, such as completing a step, starting a callback, or scheduling a timer. Updates are applied atomically as part of the checkpoint operation.


[View source]
def validate! : Nil #

[View source]