Skip to main content

ProgressStore

rustlavel_queue::progress

Trait ProgressStore 

Source 
pub trait ProgressStore:
    Send
    + Sync
    + 'static {
    // Required methods
    fn set<'a>(
        &'a self,
        key: &'a str,
        progress: Progress,
    ) -> ProgressFuture<'a, ()>;
    fn get<'a>(&'a self, key: &'a str) -> ProgressFuture<'a, Option<Progress>>;
    fn purge<'a>(&'a self, before: u64) -> ProgressFuture<'a, usize>;
}
Expand description

Where progress lives. Keyed by job id, and by chain id for a job that is a step in one.

Required Methods§

Source

fn set<'a>(&'a self, key: &'a str, progress: Progress) -> ProgressFuture<'a, ()>

Source

fn get<'a>(&'a self, key: &'a str) -> ProgressFuture<'a, Option<Progress>>

Source

fn purge<'a>(&'a self, before: u64) -> ProgressFuture<'a, usize>

Drop records older than before (unix seconds). Housekeeping.

Dyn Compatibility§

This trait is dyn compatible.

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

Implementors§