Struct background_jobs::Manager

pub struct Manager { /* private fields */ }

Manager for worker threads

Manager attempts to restart workers as their arbiters die

Implementations

impl Manager

pub fn queue_handle(&self) -> &QueueHandle

Retrieve the QueueHandle for the managed workers

Methods from Deref<Target = QueueHandle>

pub async fn queue<J>(&'_ self, job: J) -> Result<(), Error> where
    J: Job, 

Queues a job for execution

This job will be sent to the server for storage, and will execute whenever a worker for the job’s queue is free to do so.

pub async fn schedule<J>(
    &'_ self,
    job: J,
    after: SystemTime
) -> Result<(), Error> where
    J: Job, 

Schedule a job for execution later

This job will be sent to the server for storage, and will execute after the specified time and when a worker for the job’s queue is free to do so.

pub fn every<J>(&self, duration: Duration, job: J) where
    J: 'static + Job + Clone + Send, 

Queues a job for recurring execution

This job will be added to it’s queue on the server once every Duration. It will be processed whenever workers are free to do so.

pub async fn get_stats(&'_ self) -> Result<Stats, Error>

Return an overview of the processor’s statistics

Trait Implementations

impl Deref for Manager

type Target = QueueHandle

The resulting type after dereferencing.

pub fn deref(&self) -> &<Manager as Deref>::Target

Dereferences the value.