Struct celery::Celery

pub struct Celery<B: Broker> {
    pub name: String,
    pub broker: B,
    pub default_queue_name: String,
    pub task_timeout: Option<usize>,
    pub task_max_retries: Option<usize>,
    pub task_min_retry_delay: Option<usize>,
    pub task_max_retry_delay: Option<usize>,
    // some fields omitted
}

A Celery app is used to produce or consume tasks asyncronously.

Fields

name: String

broker: B

default_queue_name: String

task_timeout: Option<usize>

task_max_retries: Option<usize>

task_min_retry_delay: Option<usize>

task_max_retry_delay: Option<usize>

Methods

impl<B> Celery<B> where
    B: Broker + 'static, 

pub fn builder() -> CeleryBuilder

Get a CeleryBuilder for creating a Celery app with a custom configuration.

pub fn new(name: &str, broker: B) -> Self

Create a new Celery app with the given name.

pub async fn send_task<'_, '_, T: Task>(
    &'_ self,
    task: T,
    queue: &'_ str
) -> Result<(), Error>

Send a task to a remote worker.

pub fn register_task<T: Task + 'static>(
    &mut self,
    name: &str
) -> Result<(), Error>

Register a task.

pub async fn execute_task<'_, '_>(
    &'_ self,
    task_name: &'_ str,
    data: Vec<u8>
) -> Result<(), Error>

pub async fn consume<'_, '_>(&'_ self, queue: &'_ str) -> Result<(), Error>

Consume tasks from the default queue.