From c73e0ad6d86618003ed4d80967639004a386d26a Mon Sep 17 00:00:00 2001 From: haixuantao Date: Wed, 30 Jul 2025 15:21:30 +0800 Subject: [PATCH] Making command public --- binaries/cli/src/command/mod.rs | 32 +++++++++++++-------------- binaries/cli/src/command/start/mod.rs | 16 +++++++------- binaries/cli/src/lib.rs | 2 +- 3 files changed, 25 insertions(+), 25 deletions(-) diff --git a/binaries/cli/src/command/mod.rs b/binaries/cli/src/command/mod.rs index 617f9b05..e0d776a4 100644 --- a/binaries/cli/src/command/mod.rs +++ b/binaries/cli/src/command/mod.rs @@ -16,22 +16,22 @@ mod up; pub use run::run_func; -use build::Build; -use check::Check; -use coordinator::Coordinator; -use daemon::Daemon; -use destroy::Destroy; -use eyre::Context; -use graph::Graph; -use list::ListArgs; -use logs::LogsArgs; -use new::NewArgs; -use run::Run; -use runtime::Runtime; -use self_::SelfSubCommand; -use start::Start; -use stop::Stop; -use up::Up; +pub use build::Build; +pub use check::Check; +pub use coordinator::Coordinator; +pub use daemon::Daemon; +pub use destroy::Destroy; +pub use eyre::Context; +pub use graph::Graph; +pub use list::ListArgs; +pub use logs::LogsArgs; +pub use new::NewArgs; +pub use run::Run; +pub use runtime::Runtime; +pub use self_::SelfSubCommand; +pub use start::Start; +pub use stop::Stop; +pub use up::Up; /// dora-rs cli client #[derive(Debug, clap::Subcommand)] diff --git a/binaries/cli/src/command/start/mod.rs b/binaries/cli/src/command/start/mod.rs index 077a67b4..db2933e7 100644 --- a/binaries/cli/src/command/start/mod.rs +++ b/binaries/cli/src/command/start/mod.rs @@ -31,28 +31,28 @@ mod attach; pub struct Start { /// Path to the dataflow descriptor file #[clap(value_name = "PATH")] - dataflow: String, + pub dataflow: String, /// Assign a name to the dataflow #[clap(long)] - name: Option, + pub name: Option, /// Address of the dora coordinator #[clap(long, value_name = "IP", default_value_t = LOCALHOST)] - coordinator_addr: IpAddr, + pub coordinator_addr: IpAddr, /// Port number of the coordinator control server #[clap(long, value_name = "PORT", default_value_t = DORA_COORDINATOR_PORT_CONTROL_DEFAULT)] - coordinator_port: u16, + pub coordinator_port: u16, /// Attach to the dataflow and wait for its completion #[clap(long, action)] - attach: bool, + pub attach: bool, /// Run the dataflow in background #[clap(long, action)] - detach: bool, + pub detach: bool, /// Enable hot reloading (Python only) #[clap(long, action)] - hot_reload: bool, + pub hot_reload: bool, // Use UV to run nodes. #[clap(long, action)] - uv: bool, + pub uv: bool, } impl Executable for Start { diff --git a/binaries/cli/src/lib.rs b/binaries/cli/src/lib.rs index 868d7a5a..c89f74fa 100644 --- a/binaries/cli/src/lib.rs +++ b/binaries/cli/src/lib.rs @@ -5,7 +5,7 @@ use std::{ path::PathBuf, }; -mod command; +pub mod command; mod common; mod formatting; pub mod output;