consul-kv-trigger 0.1.0

Watch Consul KV and act on changes
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

use clap::Parser;
use consul_kv_trigger::Watcher;
use eyre::Result;
use tracing::subscriber::set_global_default;
use tracing_log::LogTracer;
use tracing_subscriber::{fmt, layer::SubscriberExt, EnvFilter, Registry};

#[derive(Parser, Debug)]
#[clap(author, version, about, long_about = None)]
struct Args {
    /// Path to watch
    #[clap(value_parser)]
    path: String,
}

#[tokio::main]
async fn main() -> Result<()> {
    LogTracer::init().expect("Failed to set logger");

    let env_filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info"));
    let formatter = fmt::Layer::default();
    let subscriber = Registry::default().with(env_filter).with(formatter);
    set_global_default(subscriber).expect("Failed to set subscriber");

    let args = Args::parse();

    let watcher = Watcher::new(args.path);
    watcher
        .run(|results| async move {
            tracing::info!("{:?}", results);
        })
        .await;

    Ok(())
}