postmodern-cli 0.1.1

CLI for postmodern job queue management.
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

//! Database statistics and maintenance commands.

use anyhow::{Context, Result};
use postmodern::Queue;

use crate::{
    cli::DbCommand,
    display::{show_table, StatsRow},
};

/// Runs a database command.
pub async fn run(queue: &Queue, command: DbCommand) -> Result<()> {
    match command {
        DbCommand::Stats => {
            let stats = queue.stats().await.context("failed to get stats")?;

            if stats.is_empty() {
                println!("No queues.");
            } else {
                let rows: Vec<StatsRow> = stats
                    .into_iter()
                    .map(|s| StatsRow {
                        queue: s.queue,
                        pending: s.pending,
                        paused: s.paused,
                        in_progress: s.in_progress,
                        finished: s.finished,
                        failed: s.failed,
                    })
                    .collect();
                show_table(rows);
            }
        }

        DbCommand::Reap => {
            let (reaped, next) = queue.reap().await.context("reap failed")?;

            println!("Reaped {reaped} jobs.");
            if let Some(duration) = next {
                println!("Next reap in {:?}.", duration);
            }
        }
    }

    Ok(())
}