Module Values.CheckpointDurableExecutionRequestSource

Saves the progress of a durable function execution during runtime. This API is used by the Lambda durable functions SDK to checkpoint completed steps and schedule asynchronous operations. You typically don't need to call this API directly as the SDK handles checkpointing automatically. Each checkpoint operation consumes the current checkpoint token and returns a new one for the next checkpoint. This ensures that checkpoints are applied in the correct order and prevents duplicate or out-of-order state updates.

Sourcetype nonrec t = {
  1. durableExecutionArn : DurableExecutionArn.t;
    (*

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

    *)
  2. checkpointToken : CheckpointToken.t;
    (*

    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.

    *)
  3. updates : OperationUpdates.t option;
    (*

    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.

    *)
  4. clientToken : ClientToken.t option;
    (*

    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.

    *)
}
Sourceval context_ : string
Sourceval make : ?updates:??? -> ?clientToken:??? -> durableExecutionArn:DurableExecutionArn.t -> checkpointToken:CheckpointToken.t -> unit -> t
Sourceval to_value : t -> [> `Structure of (string * [> `List of [> `Structure of (string * [> `Enum of string | `String of OperationId.t | `Structure of (string * [> `Boolean of ReplayChildren.t | `Integer of StepOptionsNextAttemptDelaySecondsInteger.t | `List of [> `String of StackTraceEntry.t ] list | `String of ErrorMessage.t ]) list ]) list ] list | `String of DurableExecutionArn.t ]) list ]
Sourceval to_query : t -> Awso.Client.Query.t
Sourceval of_xml : Awso.Xml.t -> t
Sourceval of_string : string -> t
Sourceval of_json : Yojson.Safe.t -> t
Sourceval to_json : t -> Yojson.Safe.t