dora-cli 1.0.0-rc.2

`dora` goal is to be a low latency, composable, and distributed data flow.
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
59
60
61
62
63

use crate::command::Executable;
use dora_message::id::{DataId, NodeId};

mod add;
mod connect;
mod disconnect;

/// Parse "node_id/port_id" format used by connect/disconnect commands.
pub(crate) fn parse_node_port(s: &str) -> eyre::Result<(NodeId, DataId)> {
    let parts: Vec<&str> = s.splitn(2, '/').collect();
    if parts.len() != 2 || parts[0].is_empty() || parts[1].is_empty() {
        eyre::bail!("expected 'node_id/port_id', got '{s}'");
    }
    let node: NodeId = parts[0]
        .parse()
        .map_err(|e| eyre::eyre!("invalid node ID: {e}"))?;
    let port: DataId = parts[1]
        .parse()
        .map_err(|e| eyre::eyre!("invalid port ID: {e}"))?;
    Ok((node, port))
}
mod info;
mod list;
mod remove;
mod restart;
mod stop;

pub use add::Add;
pub use connect::Connect;
pub use disconnect::Disconnect;
pub use info::Info;
pub use list::List;
pub use remove::Remove;
pub use restart::Restart;
pub use stop::Stop;

/// Manage and inspect dataflow nodes.
#[derive(Debug, clap::Subcommand)]
pub enum Node {
    List(List),
    Info(Info),
    Add(Add),
    Remove(Remove),
    Connect(Connect),
    Disconnect(Disconnect),
    Restart(Restart),
    Stop(Stop),
}

impl Executable for Node {
    fn execute(self) -> eyre::Result<()> {
        match self {
            Node::List(cmd) => cmd.execute(),
            Node::Info(cmd) => cmd.execute(),
            Node::Add(cmd) => cmd.execute(),
            Node::Remove(cmd) => cmd.execute(),
            Node::Connect(cmd) => cmd.execute(),
            Node::Disconnect(cmd) => cmd.execute(),
            Node::Restart(cmd) => cmd.execute(),
            Node::Stop(cmd) => cmd.execute(),
        }
    }
}