Struct InMemoryCheckpointStoreV2 

pub struct InMemoryCheckpointStoreV2 { /* private fields */ }

Implementations

impl InMemoryCheckpointStoreV2

pub fn new() -> Self

pub fn save_checkpoint_v2( &self, checkpoint: CheckpointV2, ) -> CheckpointResult<()>

Trait Implementations

impl CheckpointStoreV2 for InMemoryCheckpointStoreV2

fn create_checkpoint_v2( &self, checkpoint: CheckpointV2, ) -> CheckpointResult<bool>

fn load_checkpoint_v2( &self, checkpoint_key: &str, ) -> CheckpointResult<Option<CheckpointV2>>

fn claim_checkpoint_v2( &self, checkpoint_key: &str, cycle_index: u64, claim_token: &str, lease_expires_at_ms: u64, now_ms: u64, claim_mode: ClaimMode, ) -> CheckpointResult<Option<CheckpointV2>>

fn progress_checkpoint_v2( &self, checkpoint: CheckpointV2, claim_token: &str, expected_revision: u64, ) -> CheckpointResult<bool>

fn suspend_checkpoint_v2( &self, checkpoint: CheckpointV2, claim_token: &str, expected_revision: u64, ) -> CheckpointResult<bool>

fn commit_checkpoint_v2( &self, checkpoint: CheckpointV2, claim_token: &str, expected_revision: u64, ) -> CheckpointResult<bool>

fn finalize_checkpoint_v2( &self, checkpoint: CheckpointV2, expected_revision: u64, ) -> CheckpointResult<bool>

fn finalize_claimed_v2( &self, checkpoint: CheckpointV2, claim_token: &str, expected_revision: u64, ) -> CheckpointResult<bool>

fn renew_checkpoint_claim_v2( &self, checkpoint_key: &str, claim_token: &str, lease_expires_at_ms: u64, now_ms: u64, ) -> CheckpointResult<bool>

fn acknowledge_terminal_v2( &self, checkpoint_key: &str, expected_revision: u64, ) -> CheckpointResult<bool>

fn record_event_delivery_v2( &self, checkpoint_key: &str, claim_token: Option<&str>, expected_revision: u64, event_id: &str, payload_digest: &str, cursor: EventCursor, ) -> CheckpointResult<bool>

fn delete_checkpoint_v2(&self, checkpoint_key: &str) -> CheckpointResult<()>

fn list_checkpoints_v2(&self) -> CheckpointResult<Vec<String>>

fn claim_checkpoint_v2_continue( &self, checkpoint_key: &str, cycle_index: u64, claim_token: &str, lease_expires_at_ms: u64, now_ms: u64, ) -> CheckpointResult<Option<CheckpointV2>>

fn claim_checkpoint_v2_recovery( &self, checkpoint_key: &str, cycle_index: u64, claim_token: &str, lease_expires_at_ms: u64, now_ms: u64, ) -> CheckpointResult<Option<CheckpointV2>>

impl Clone for InMemoryCheckpointStoreV2

fn clone(&self) -> InMemoryCheckpointStoreV2

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for InMemoryCheckpointStoreV2

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

Formats the value using the given formatter.

impl Default for InMemoryCheckpointStoreV2

fn default() -> InMemoryCheckpointStoreV2

Returns the “default value” for a type.