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

mod delete;
mod ls;

use self::{
    delete::{DeleteOpts, TopicsDelete},
    ls::{LsOpts, TopicsList},
};
use super::AxCliCommand;
use futures::Future;

/// manage topics
#[derive(clap::Subcommand, Clone, Debug)]
pub enum TopicsOpts {
    Ls(LsOpts),
    Delete(DeleteOpts),
}

pub fn run(opts: TopicsOpts, json: bool) -> Box<dyn Future<Output = ()> + Unpin> {
    match opts {
        TopicsOpts::Ls(opts) => TopicsList::output(opts, json),
        TopicsOpts::Delete(opts) => TopicsDelete::output(opts, json),
    }
}