Package software.amazon.lambda.durable.client

Class LambdaDurableFunctionsClient

java.lang.Object

software.amazon.lambda.durable.client.LambdaDurableFunctionsClient

All Implemented Interfaces:

DurableExecutionClient

public class LambdaDurableFunctionsClient
extends Object
implements DurableExecutionClient

Default implementation of DurableExecutionClient backed by the AWS Lambda SDK client.

Translates SDK-level checkpoint and state-retrieval calls into the corresponding LambdaClient API requests.

Constructor Summary

Constructors

Constructor	Description
LambdaDurableFunctionsClient(software.amazon.awssdk.services.lambda.LambdaClient lambdaClient)	Creates a LambdaDurableFunctionsClient with the provided LambdaClient.

Method Summary

Modifier and Type	Method	Description
software.amazon.awssdk.services.lambda.model.CheckpointDurableExecutionResponse	checkpoint(String arn, String token, List<software.amazon.awssdk.services.lambda.model.OperationUpdate> updates)	Sends a batch of operation updates to the backend.
software.amazon.awssdk.services.lambda.model.GetDurableExecutionStateResponse	getExecutionState(String arn, String checkpointToken, String marker)	Retrieves the current execution state from the backend.

Methods inherited from class java.lang.Object

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

Constructor Details

LambdaDurableFunctionsClient

public LambdaDurableFunctionsClient(software.amazon.awssdk.services.lambda.LambdaClient lambdaClient)

Creates a LambdaDurableFunctionsClient with the provided LambdaClient.

Parameters:

lambdaClient - LambdaClient instance to use for backend communication

Throws:

NullPointerException - if lambdaClient is null

Method Details

checkpoint

public software.amazon.awssdk.services.lambda.model.CheckpointDurableExecutionResponse checkpoint(String arn,
 String token,
 List<software.amazon.awssdk.services.lambda.model.OperationUpdate> updates)

Description copied from interface: DurableExecutionClient

Sends a batch of operation updates to the backend.

Specified by:

checkpoint in interface DurableExecutionClient

Parameters:

arn - the durable execution ARN

token - the checkpoint token

updates - the operation updates to send

Returns:

the checkpoint response

getExecutionState

public software.amazon.awssdk.services.lambda.model.GetDurableExecutionStateResponse getExecutionState(String arn,
 String checkpointToken,
 String marker)

Description copied from interface: DurableExecutionClient

Retrieves the current execution state from the backend.

Specified by:

getExecutionState in interface DurableExecutionClient

Parameters:

arn - the durable execution ARN

checkpointToken - the checkpoint token

marker - pagination marker, or null for the first page

Returns:

the execution state response