Struct CheckpointRequest 

pub struct CheckpointRequest {
    pub operation: OperationUpdate,
    pub completion: Option<Sender<Result<(), DurableError>>>,
}

A request to checkpoint an operation.

This struct is sent through the checkpoint queue to the batcher. It includes an optional completion channel for synchronous checkpoints.

Fields

operation: OperationUpdate

The operation update to checkpoint

completion: Option<Sender<Result<(), DurableError>>>

Optional channel to signal completion (for sync checkpoints)

Implementations

impl CheckpointRequest

pub fn sync( operation: OperationUpdate, ) -> (Self, Receiver<Result<(), DurableError>>)

Creates a new synchronous checkpoint request.

Returns the request and a receiver to wait for completion.

pub fn async_request(operation: OperationUpdate) -> Self

Creates a new asynchronous (fire-and-forget) checkpoint request.

pub fn is_sync(&self) -> bool

Returns true if this is a synchronous request.

pub fn estimated_size(&self) -> usize

Estimates the size of this request in bytes for batching.

Trait Implementations

impl Debug for CheckpointRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.