Struct pliantdb_jobs::manager::Manager

pub struct Manager<Key = ()> { /* fields omitted */ }

A background jobs manager.

Implementations

impl<Key> Manager<Key> where
    Key: Clone + Hash + Eq + Send + Sync + Debug + 'static, 

pub async fn enqueue<J: Job + 'static>(&self, job: J) -> Handle<J::Output, Key>

Pushes a job into the queue. Pushing the same job definition twice will yield two tasks in the queue.

pub async fn lookup_or_enqueue<J: Keyed<Key>>(
    &self,
    job: J
) -> Handle<<J as Job>::Output, Key>

Uses Keyed::key to ensure no other job with the same key is currently running. If another job is already running that matches, a clone of that Handle will be returned. When the job finishes, all Handle clones will be notified with a copy of the result.

pub fn spawn_worker(&self)

Spawns a worker. In general, you shouldn’t need to call this function directly.

Trait Implementations

impl<Key> Clone for Manager<Key>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Key: Debug> Debug for Manager<Key>

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

Formats the value using the given formatter.

impl<Key> Default for Manager<Key> where
    Key: Clone + Hash + Eq + Send + Sync + Debug + 'static, 

fn default() -> Self

Returns the “default value” for a type.