Trait StateStore 

pub trait StateStore {
    type Error: Error + Send + Sync + 'static;

    // Required methods
    fn load(
        &self,
        job_id: &str,
    ) -> impl Future<Output = Result<Option<JobState>, Self::Error>> + Send;
    fn save(
        &self,
        state: &JobState,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send;

    // Provided methods
    fn delete(
        &self,
        _job_id: &str,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send { ... }
    fn drain_events(
        &self,
    ) -> impl Future<Output = Result<Vec<StoreEvent>, Self::Error>> + Send { ... }
    fn classify_error(_error: &Self::Error) -> StoreErrorKind
       where Self: Sized { ... }
}

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn load( &self, job_id: &str, ) -> impl Future<Output = Result<Option<JobState>, Self::Error>> + Send

fn save( &self, state: &JobState, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Provided Methods

fn delete( &self, _job_id: &str, ) -> impl Future<Output = Result<(), Self::Error>> + Send

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

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

where Self: Sized,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<T> StateStore for Arc<T>

where T: StateStore + Send + Sync,

type Error = <T as StateStore>::Error

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>

async fn drain_events(&self) -> Result<Vec<StoreEvent>, Self::Error>

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

where Self: Sized,

Implementors

impl StateStore for InMemoryStateStore

type Error = Infallible

impl StateStore for ValkeyStateStore

type Error = ValkeyStoreError

impl<S> StateStore for ResilientStateStore<S>

where S: StateStore + Send + Sync, S::Error: ResilientStoreError,

type Error = <S as StateStore>::Error