kade 0.0.1

High-performance queue pipeline and key-value store
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

mod verbose;

use clap::Parser;
use kade_server::DEFAULT_PORT;
use std::{env::consts, path::PathBuf, process};
use tokio::net::TcpListener;
use tokio::signal;
use tracing_subscriber::fmt::format::FmtSpan;
use verbose::{InfoLevel, Verbosity};

#[derive(Parser, Debug)]
#[command(name = "kade-server", version)]
struct Cli {
    #[arg(long, default_value_t = DEFAULT_PORT)]
    port: u16,

    #[arg(id = "hostname", long, default_value = "127.0.0.1")]
    host: String,

    #[clap(flatten)]
    verbose: Verbosity<InfoLevel>,

    #[arg(long, default_value = "state.kade", help = "Path to save/load database state")]
    state: Option<PathBuf>,

    #[arg(long, help = "Disable state caching")]
    no_cache: bool,
}

#[tokio::main]
pub async fn main() -> kade_proto::Result<()> {
    let mut cli = Cli::parse();

    tracing_subscriber::fmt()
        .with_span_events(FmtSpan::CLOSE)
        .with_thread_names(true)
        .with_thread_ids(true)
        .with_max_level(cli.verbose.log_level_filter())
        .init();

    let addr = format!("{}:{}", cli.host, cli.port);
    let listener = TcpListener::bind(&addr).await?;

    println!(
        "\n  Kade v{} {}-{}\n\n  Starting in standalone mode\n  Port: {}\n  PID: {}\n\n\n    https://themackabu.dev\n",
        env!("CARGO_PKG_VERSION"),
        consts::OS,
        consts::ARCH,
        cli.port,
        process::id()
    );

    if cli.no_cache {
        cli.state = None;
    }

    Ok(kade_server::run(listener, signal::ctrl_c(), cli.state).await)
}