Trait apalis_core::job::JobStreamExt

pub trait JobStreamExt<Job>: JobStream<Job = Job> where
    Self: Sized, {
    fn list_workers<'life0, 'async_trait>(
        &'life0 mut self
    ) -> Pin<Box<dyn Future<Output = Result<Vec<JobStreamWorker>, JobError>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn list_jobs<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        status: &'life1 JobState,
        page: i32
    ) -> Pin<Box<dyn Future<Output = Result<Vec<JobRequest<Job>>, JobError>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn counts<'life0, 'async_trait>(
        &'life0 mut self
    ) -> Pin<Box<dyn Future<Output = Result<Counts, JobError>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: Send + 'async_trait,
    { ... }
}

JobStream extension usually useful for management via cli, web etc

Required Methods

fn list_workers<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Result<Vec<JobStreamWorker>, JobError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

List all Workers that are working on a Job Stream

fn list_jobs<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    status: &'life1 JobState,
    page: i32
) -> Pin<Box<dyn Future<Output = Result<Vec<JobRequest<Job>>, JobError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Fetch jobs persisted from storage

Provided Methods

fn counts<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Result<Counts, JobError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: Send + 'async_trait, 

Returns the counts of jobs in different states

Implementors