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.

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.