Struct RedisCheckpointStore 

pub struct RedisCheckpointStore { /* private fields */ }

Implementations

impl RedisCheckpointStore

pub fn new(redis_url: impl AsRef<str>) -> CheckpointResult<Self>

pub fn data_key(checkpoint_key: &str) -> String

pub fn lease_key(checkpoint_key: &str) -> String

pub fn redis_url(&self) -> &str

Trait Implementations

impl CheckpointStore for RedisCheckpointStore

fn create_checkpoint(&self, checkpoint: Checkpoint) -> CheckpointResult<bool>

fn load_checkpoint( &self, checkpoint_key: &str, ) -> CheckpointResult<Option<Checkpoint>>

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

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

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

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

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

fn finalize_checkpoint( &self, checkpoint: Checkpoint, expected_revision: u64, ) -> CheckpointResult<bool>

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

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

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

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

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

impl Debug for RedisCheckpointStore

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

Formats the value using the given formatter.