dora-cli 0.5.0

`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

use super::{Executable, default_tracing};
use crate::{LOCALHOST, common::connect_to_coordinator_rpc, get_python_dora_version};
use dora_core::topics::DORA_COORDINATOR_PORT_CONTROL_DEFAULT;
use dora_message::tarpc;

#[derive(Debug, clap::Args)]
/// Show detailed version information for CLI, message format, and coordinator.
pub struct Version {
    /// Address of the dora coordinator
    #[clap(long, value_name = "IP", default_value_t = LOCALHOST)]
    coordinator_addr: std::net::IpAddr,
    /// Port number of the coordinator control server
    #[clap(long, value_name = "PORT", default_value_t = DORA_COORDINATOR_PORT_CONTROL_DEFAULT)]
    coordinator_port: u16,
}

impl Executable for Version {
    async fn execute(self) -> eyre::Result<()> {
        default_tracing()?;

        println!("CLI version:                {}", env!("CARGO_PKG_VERSION"));
        println!("CLI message format version: {}", dora_message::VERSION);

        match get_python_dora_version() {
            Some(v) => println!("Python dora-rs version:     {v}"),
            None => println!("Python dora-rs version:     not found"),
        }

        match connect_to_coordinator_rpc(self.coordinator_addr, self.coordinator_port).await {
            Ok(client) => match client.get_version(tarpc::context::current()).await {
                Ok(info) => {
                    println!("Coordinator version:        {}", info.coordinator_version);
                    println!(
                        "Coordinator message format: {}",
                        info.message_format_version
                    );
                }
                Err(_) => {
                    println!("Coordinator version:        unknown (RPC not supported)");
                }
            },
            Err(_) => {
                println!("Coordinator version:        not reachable");
            }
        }

        Ok(())
    }
}