aboutsummaryrefslogtreecommitdiff
path: root/src/garage/cli
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-01-04 13:25:57 +0100
committerAlex Auvolat <alex@adnab.me>2023-01-04 13:25:57 +0100
commit29dbcb82780dcdb6f2a01a9da5122e70abaf93bf (patch)
tree222ec61f03c5abcca6678239111e94ad4dcfeb67 /src/garage/cli
parentf3f27293df83986ba29fb03f8af26a2177518e20 (diff)
downloadgarage-29dbcb82780dcdb6f2a01a9da5122e70abaf93bf.tar.gz
garage-29dbcb82780dcdb6f2a01a9da5122e70abaf93bf.zip
bg var operation on all nodes at onceworker-get
Diffstat (limited to 'src/garage/cli')
-rw-r--r--src/garage/cli/structs.rs18
-rw-r--r--src/garage/cli/util.rs4
2 files changed, 18 insertions, 4 deletions
diff --git a/src/garage/cli/structs.rs b/src/garage/cli/structs.rs
index 08cb7769..661a71f0 100644
--- a/src/garage/cli/structs.rs
+++ b/src/garage/cli/structs.rs
@@ -519,10 +519,24 @@ pub enum WorkerOperation {
Info { tid: usize },
/// Get worker parameter
#[structopt(name = "get", version = garage_version())]
- Get { variable: Option<String> },
+ Get {
+ /// Gather variable values from all nodes
+ #[structopt(short = "a", long = "all-nodes")]
+ all_nodes: bool,
+ /// Variable name to get, or none to get all variables
+ variable: Option<String>,
+ },
/// Set worker parameter
#[structopt(name = "set", version = garage_version())]
- Set { variable: String, value: String },
+ Set {
+ /// Set variable values on all nodes
+ #[structopt(short = "a", long = "all-nodes")]
+ all_nodes: bool,
+ /// Variable node to set
+ variable: String,
+ /// Value to set the variable to
+ value: String,
+ },
}
#[derive(Serialize, Deserialize, StructOpt, Debug, Eq, PartialEq, Clone, Copy)]
diff --git a/src/garage/cli/util.rs b/src/garage/cli/util.rs
index 17477bd3..230ce3de 100644
--- a/src/garage/cli/util.rs
+++ b/src/garage/cli/util.rs
@@ -357,10 +357,10 @@ pub fn print_worker_info(tid: usize, info: WorkerInfo) {
format_table(table);
}
-pub fn print_worker_vars(wv: Vec<(String, String)>) {
+pub fn print_worker_vars(wv: Vec<(Uuid, String, String)>) {
let table = wv
.into_iter()
- .map(|(k, v)| format!("{}\t{}", k, v))
+ .map(|(n, k, v)| format!("{:?}\t{}\t{}", n, k, v))
.collect::<Vec<_>>();
format_table(table);
}