Struct ValkeyStateStore 

pub struct ValkeyStateStore { /* private fields */ }

Implementations

impl ValkeyStateStore

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

pub async fn resilient( url: impl AsRef<str>, ) -> Result<ResilientStateStore<Self>, ValkeyStoreError>

Creates a Valkey-backed store that permanently falls back to an in-process mirror after connection-class failures.

pub async fn with_prefix( url: impl AsRef<str>, key_prefix: impl Into<String>, ) -> Result<Self, RedisError>

pub async fn from_client( client: Client, key_prefix: impl Into<String>, ) -> Result<Self, RedisError>

pub async fn with_prefix_resilient( url: impl AsRef<str>, key_prefix: impl Into<String>, ) -> Result<ResilientStateStore<Self>, ValkeyStoreError>

pub async fn from_client_resilient( client: Client, key_prefix: impl Into<String>, ) -> Result<ResilientStateStore<Self>, ValkeyStoreError>

Trait Implementations

impl Clone for ValkeyStateStore

fn clone(&self) -> ValkeyStateStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ValkeyStateStore

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

Formats the value using the given formatter.

impl StateStore for ValkeyStateStore

type Error = ValkeyStoreError

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

async fn save(&self, state: &JobState) -> Result<(), Self::Error>

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

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

where Self: Sized,

fn drain_events( &self, ) -> impl Future<Output = Result<Vec<StoreEvent>, Self::Error>> + Send