Struct ValkeyCoordinatedStateStore 

pub struct ValkeyCoordinatedStateStore { /* private fields */ }

Implementations

impl ValkeyCoordinatedStateStore

pub async fn new(url: impl AsRef<str>) -> Result<Self, RedisError>

pub async fn with_prefixes( url: impl AsRef<str>, state_key_prefix: impl Into<String>, execution_key_prefix: impl Into<String>, ) -> Result<Self, RedisError>

Trait Implementations

impl Clone for ValkeyCoordinatedStateStore

fn clone(&self) -> ValkeyCoordinatedStateStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CoordinatedStateStore for ValkeyCoordinatedStateStore

type Error = ValkeyStoreError

async fn load_or_initialize( &self, job_id: &str, initial_state: JobState, ) -> Result<CoordinatedRuntimeState, Self::Error>

async fn save_state( &self, job_id: &str, revision: u64, state: &JobState, ) -> Result<bool, Self::Error>

async fn reclaim_inflight( &self, job_id: &str, resource_id: &str, lease_config: CoordinatedLeaseConfig, ) -> Result<Option<CoordinatedClaim>, Self::Error>

async fn claim_trigger( &self, job_id: &str, resource_id: &str, revision: u64, trigger: CoordinatedPendingTrigger, next_state: &JobState, lease_config: CoordinatedLeaseConfig, ) -> Result<Option<CoordinatedClaim>, Self::Error>

async fn renew( &self, lease: &ExecutionLease, lease_config: CoordinatedLeaseConfig, ) -> Result<ExecutionGuardRenewal, Self::Error>

async fn complete( &self, job_id: &str, revision: u64, lease: &ExecutionLease, state: &JobState, ) -> Result<bool, Self::Error>

async fn delete(&self, job_id: &str) -> Result<(), Self::Error>

async fn pause(&self, job_id: &str) -> Result<bool, Self::Error>

async fn resume(&self, job_id: &str) -> Result<bool, Self::Error>

fn classify_store_error(error: &Self::Error) -> StoreErrorKind

where Self: Sized,

fn classify_guard_error(error: &Self::Error) -> ExecutionGuardErrorKind

where Self: Sized,

impl Debug for ValkeyCoordinatedStateStore

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

Formats the value using the given formatter.