pub trait CheckpointStoreV2: Send + Sync {
Show 15 methods
// Required methods
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_claimed_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 renew_checkpoint_claim_v2(
&self,
checkpoint_key: &str,
claim_token: &str,
lease_expires_at_ms: u64,
now_ms: 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 acknowledge_terminal_v2(
&self,
checkpoint_key: &str,
expected_revision: u64,
) -> CheckpointResult<bool>;
fn delete_checkpoint_v2(&self, checkpoint_key: &str) -> CheckpointResult<()>;
fn list_checkpoints_v2(&self) -> CheckpointResult<Vec<String>>;
// Provided methods
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>> { ... }
}Required Methods§
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_claimed_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 renew_checkpoint_claim_v2( &self, checkpoint_key: &str, claim_token: &str, lease_expires_at_ms: u64, now_ms: 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 acknowledge_terminal_v2( &self, checkpoint_key: &str, expected_revision: u64, ) -> CheckpointResult<bool>
fn delete_checkpoint_v2(&self, checkpoint_key: &str) -> CheckpointResult<()>
fn list_checkpoints_v2(&self) -> CheckpointResult<Vec<String>>
Provided Methods§
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>>
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".