ax 2.18.2

ax distributed event databank and command line tool
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

mod dump;
mod offsets;
mod publish;
mod query;
mod restore;

use super::AxCliCommand;
use futures::Future;

#[derive(clap::Subcommand, Clone, Debug)]
/// interact with the events API through the admin port
pub enum EventsOpts {
    Offsets(offsets::OffsetsOpts),
    Query(query::QueryOpts),
    Publish(publish::PublishOpts),
    Dump(dump::DumpOpts),
    Restore(restore::RestoreOpts),
}

pub fn run(opts: EventsOpts, json: bool) -> Box<dyn Future<Output = ()> + Unpin> {
    match opts {
        EventsOpts::Offsets(opt) => offsets::EventsOffsets::output(opt, json),
        EventsOpts::Query(opt) => query::EventsQuery::output(opt, json),
        EventsOpts::Publish(opt) => publish::EventsPublish::output(opt, json),
        EventsOpts::Dump(opt) => dump::EventsDump::output(opt, json),
        EventsOpts::Restore(opt) => restore::EventsRestore::output(opt, json),
    }
}