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", so this trait is not object safe.

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, S::Error: ResilientStoreError,

type Error = <S as StateStore>::Error