lazycelery 0.8.3

A terminal UI for monitoring and managing Celery workers and tasks, inspired by lazydocker/lazygit
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
26
27
28
29
30
31
32
33
34

pub mod amqp;
pub mod result_backend;

pub mod redis;

use crate::error::BrokerError;
use crate::models::{Queue, Task, Worker};
use async_trait::async_trait;

#[async_trait]
#[allow(dead_code)]
pub trait Broker: Send + Sync {
    async fn connect(url: &str) -> Result<Self, BrokerError>
    where
        Self: Sized;

    async fn get_workers(&self) -> Result<Vec<Worker>, BrokerError>;
    async fn get_tasks(&self) -> Result<Vec<Task>, BrokerError>;
    async fn get_queues(&self) -> Result<Vec<Queue>, BrokerError>;
    async fn retry_task(&self, task_id: &str) -> Result<(), BrokerError>;
    async fn revoke_task(&self, task_id: &str) -> Result<(), BrokerError>;
    async fn purge_queue(&self, queue_name: &str) -> Result<u64, BrokerError>;
}

/// Create a broker based on the URL scheme
pub async fn create_broker(url: &str) -> Result<Box<dyn Broker>, BrokerError> {
    if url.starts_with("redis://") {
        Ok(Box::new(redis::RedisBroker::connect(url).await?))
    } else if url.starts_with("amqp://") || url.starts_with("rabbitmq://") {
        Ok(Box::new(amqp::AmqpBroker::connect(url).await?))
    } else {
        Err(BrokerError::InvalidUrl(url.to_string()))
    }
}