Struct ResilientStateStore 

pub struct ResilientStateStore<S>
where
    S: StateStore,
    S::Error: ResilientStoreError,
{ /* private fields */ }

Wraps a primary store with an in-process mirror that takes over after connection-class failures.

Implementations

impl<S> ResilientStateStore<S>

where S: StateStore, S::Error: ResilientStoreError,

pub fn new(store: S) -> Self

pub fn degraded() -> Self

pub fn from_result(result: Result<S, S::Error>) -> Result<Self, S::Error>

pub fn is_degraded(&self) -> bool

Returns true once the store has permanently fallen back to its in-process mirror.

Trait Implementations

impl<S> Debug for ResilientStateStore<S>

where S: StateStore + Debug, S::Error: ResilientStoreError,

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

Formats the value using the given formatter.

impl<S> StateStore for ResilientStateStore<S>

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

type Error = <S 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,