Trait ruarango::Job

pub trait Job {
    fn status<'life0, 'life1, 'async_trait>(
        &'life0 self,
        id: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<u16>> + Send + 'async_trait>>
    where
        Self: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait;
    fn fetch<'life0, 'life1, 'async_trait, T>(
        &'life0 self,
        id: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<T>> + Send + 'async_trait>>
    where
        T: Serialize + DeserializeOwned + Send + Sync + 'async_trait,
        Self: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait;
    fn fetch_doc_job<'life0, 'life1, 'async_trait, T>(
        &'life0 self,
        id: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<T>> + Send + 'async_trait>>
    where
        T: Serialize + DeserializeOwned + Send + Sync + 'async_trait,
        Self: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait;
    fn jobs<'life0, 'life1, 'async_trait>(
        &'life0 self,
        kind: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>
    where
        Self: 'async_trait,
        'life0: 'async_trait,
        'life1: 'async_trait;
}

Collection Operations

Required Methods

fn status<'life0, 'life1, 'async_trait>(
    &'life0 self,
    id: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<u16>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Returns the processing status of the specified job. The processing status can be determined by checking the HTTP response code.

• 200 is returned if the job requested via id has been executed and its result is ready to fetch.
• 202 is returned if the job requested via id is still in the queue of pending (or not yet finished) jobs.
• 404 is returned if the job was not found, has already deleted, has already been fetched from the job result list.

fn fetch<'life0, 'life1, 'async_trait, T>(
    &'life0 self,
    id: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<T>> + Send + 'async_trait>>where
    T: Serialize + DeserializeOwned + Send + Sync + 'async_trait,
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Docs

fn fetch_doc_job<'life0, 'life1, 'async_trait, T>(
    &'life0 self,
    id: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<T>> + Send + 'async_trait>>where
    T: Serialize + DeserializeOwned + Send + Sync + 'async_trait,
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Docs

fn jobs<'life0, 'life1, 'async_trait>(
    &'life0 self,
    kind: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Docs

Implementors

impl Job for Connection