Struct tourniquet::integrations::celery::CeleryConnector

pub struct CeleryConnector<'a> {
    pub name: &'a str,
    pub default_queue: Option<&'a str>,
    pub routes: &'a [(&'a str, &'a str)],
    pub connection_timeout: Option<u32>,
}

Ready to use connector for Celery.

Please refer to celery’s documentation for more information about the fields of this structure.

Note that this is a basic connector for celery, exposing only the most common options used by celery producers, not consumers. Please create your own connector should you need finer grained control over the created celery client.

Fields

name: &'a str

default_queue: Option<&'a str>

routes: &'a [(&'a str, &'a str)]

connection_timeout: Option<u32>

Trait Implementations

impl<'a> Connector<String, Celery<AMQPBroker>, CeleryError> for CeleryConnector<'a>

fn connect<'life0, 'life1, 'async_trait>(
    &'life0 self,
    url: &'life1 String
) -> Pin<Box<dyn Future<Output = Result<Celery<AMQPBroker>, CeleryError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

impl<'a> Default for CeleryConnector<'a>

fn default() -> Self

Returns the “default value” for a type.