Struct CheckpointWorkerManager 

pub struct CheckpointWorkerManager { /* private fields */ }

Manages the checkpoint server thread lifecycle.

Implementations

impl CheckpointWorkerManager

pub fn get_instance( params: Option<CheckpointWorkerParams>, ) -> Result<Arc<CheckpointWorkerManager>, TestError>

Get or create the singleton instance.

If the singleton already exists and params is Some with values that differ from the existing instance’s configuration, an error is returned. Pass None to accept whatever configuration the existing instance has.

pub fn reset_instance_for_testing()

Reset the singleton instance (for testing).

Note: This method should be called from a non-async context or at the start of a test before any async operations. If called from within an async context, it will skip the graceful shutdown and just clear the instance.

pub async fn send_api_request( &self, api_type: ApiType, payload: String, ) -> Result<WorkerApiResponse, TestError>

Send an API request to the checkpoint server and wait for response.

pub async fn shutdown(self) -> Result<(), TestError>

Gracefully shut down the checkpoint server.

pub fn shutdown_sync(self) -> Result<(), TestError>

Synchronous shutdown (for use in Drop or non-async contexts).

pub fn params(&self) -> &CheckpointWorkerParams

Get the configuration parameters.

impl CheckpointWorkerManager

pub async fn send_callback_success( &self, callback_id: &str, result: &str, ) -> Result<(), DurableError>

Send a callback success response.

pub async fn send_callback_failure( &self, callback_id: &str, error: &ErrorObject, ) -> Result<(), DurableError>

Send a callback failure response.

pub async fn send_callback_heartbeat( &self, callback_id: &str, ) -> Result<(), DurableError>

Send a callback heartbeat.

pub async fn get_nodejs_history_events( &self, execution_id: &str, ) -> Result<Vec<NodeJsHistoryEvent>, DurableError>

Get Node.js-compatible history events for an execution.

Returns events in the Node.js SDK compatible format, suitable for cross-SDK history comparison. These events use PascalCase field names and include detailed event-specific information.

Arguments

• execution_id - The execution ID to get history events for

Returns

A vector of Node.js-compatible history events.

Trait Implementations

impl DurableServiceClient for CheckpointWorkerManager

fn checkpoint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, durable_execution_arn: &'life1 str, checkpoint_token: &'life2 str, operations: Vec<OperationUpdate>, ) -> Pin<Box<dyn Future<Output = Result<CheckpointResponse, DurableError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Sends a batch of checkpoint operations to the service.

fn get_operations<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, durable_execution_arn: &'life1 str, _next_marker: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<GetOperationsResponse, DurableError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Retrieves additional operations for pagination.