Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

Implementations

impl MemoryStore

pub fn new() -> Self

Trait Implementations

impl Clone for MemoryStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl TaskStore for MemoryStore

fn enqueue<'a>( &'a self, opts: EnqueueOpts, ) -> BoxFuture<'a, Result<String, TaskError>>

fn claim<'a>( &'a self, queue: &'a str, worker: &'a str, lease: Duration, limit: usize, ) -> BoxFuture<'a, Result<Vec<Task>, TaskError>>

fn heartbeat<'a>( &'a self, id: &'a str, lease: Duration, ) -> BoxFuture<'a, Result<(), TaskError>>

fn complete<'a>(&'a self, id: &'a str) -> BoxFuture<'a, Result<(), TaskError>>

fn fail<'a>( &'a self, id: &'a str, retry_at: Option<SystemTime>, ) -> BoxFuture<'a, Result<(), TaskError>>

fn reap<'a>(&'a self, now: SystemTime) -> BoxFuture<'a, Result<u64, TaskError>>

fn list<'a>( &'a self, queue: &'a str, limit: usize, ) -> BoxFuture<'a, Result<Vec<Task>, TaskError>>