celery 0.1.0-alpha

Rust implementation of Celery
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use async_trait::async_trait;
use futures_util::stream::{Stream, StreamExt};

use crate::protocol::{MessageBody, TryIntoMessage};
use crate::{Error, Task};

#[async_trait]
pub trait Broker {
    type Delivery: TryIntoMessage + Clone;
    type DeliveryError: Into<Error>;
    type Consumer: IntoIterator<
            Item = Result<Self::Delivery, Self::DeliveryError>,
            IntoIter = Self::ConsumerIterator,
        > + Stream<Item = Result<Self::Delivery, Self::DeliveryError>>
        + StreamExt;
    type ConsumerIterator: Iterator<Item = Result<Self::Delivery, Self::DeliveryError>>;

    async fn consume(&self, queue: &str) -> Result<Self::Consumer, Error>;

    async fn ack(&self, delivery: Self::Delivery) -> Result<(), Error>;

    async fn send_task<T: Task>(&self, body: MessageBody<T>, queue: &str) -> Result<(), Error>;
}

pub mod amqp;