Trait tourniquet_celery::RoundRobinExt

pub trait RoundRobinExt {
    // Required method
    fn send_task<'life0, 'async_trait, T, F>(
        &'life0 self,
        task_gen: F
    ) -> Pin<Box<dyn Future<Output = Result<AsyncResult, CeleryError>> + Send + 'async_trait>>
       where T: Task + 'static + 'async_trait,
             F: Fn() -> Signature<T> + Send + Sync + 'async_trait,
             Self: 'async_trait,
             'life0: 'async_trait;
}

Required Methods

fn send_task<'life0, 'async_trait, T, F>( &'life0 self, task_gen: F ) -> Pin<Box<dyn Future<Output = Result<AsyncResult, CeleryError>> + Send + 'async_trait>>where T: Task + 'static + 'async_trait, F: Fn() -> Signature<T> + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Implementations on Foreign Types

impl<SvcSrc, Conn> RoundRobinExt for RoundRobin<SvcSrc, Celery, RRCeleryError, Conn>where SvcSrc: Debug + Send + Sync, Conn: Connector<SvcSrc, Celery, RRCeleryError> + Send + Sync,

fn send_task<'life0, 'async_trait, T, F>( &'life0 self, task_gen: F ) -> Pin<Box<dyn Future<Output = Result<AsyncResult, CeleryError>> + Send + 'async_trait>>where T: Task + 'static + 'async_trait, F: Fn() -> Signature<T> + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Send a Celery task.

The task_gen argument returns a signature for each attempt, should each attempt hold a different value (e.g. trace id, attempt id, timestamp, …).

Implementors