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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

pub mod facade;
pub mod operations;
pub mod pool;
pub mod protocol;

use crate::broker::Broker;
use crate::error::BrokerError;
use crate::models::{Queue, Task, Worker};
use async_trait::async_trait;
use tracing::{debug, info};

// Re-export for backward compatibility
pub use facade::BrokerFacade;

/// Redis broker implementation using the improved facade pattern
pub struct RedisBroker {
    facade: BrokerFacade,
}

#[async_trait]
impl Broker for RedisBroker {
    async fn connect(url: &str) -> Result<Self, BrokerError> {
        info!("Connecting to Redis broker using facade pattern");
        debug!(
            "Redis URL: {}",
            url.split('@').next_back().unwrap_or("hidden")
        );

        let facade = BrokerFacade::new(url).await?;

        // Perform initial health check
        facade.health_check().await?;

        info!("Redis broker connected successfully");

        Ok(Self { facade })
    }

    async fn get_workers(&self) -> Result<Vec<Worker>, BrokerError> {
        self.facade.get_workers().await
    }

    async fn get_tasks(&self) -> Result<Vec<Task>, BrokerError> {
        self.facade.get_tasks().await
    }

    async fn get_queues(&self) -> Result<Vec<Queue>, BrokerError> {
        self.facade.get_queues().await
    }

    async fn retry_task(&self, task_id: &str) -> Result<(), BrokerError> {
        self.facade.retry_task(task_id).await
    }

    async fn revoke_task(&self, task_id: &str) -> Result<(), BrokerError> {
        self.facade.revoke_task(task_id).await
    }

    async fn purge_queue(&self, queue_name: &str) -> Result<u64, BrokerError> {
        self.facade.purge_queue(queue_name).await
    }
}