diff options
author | Alex Auvolat <alex@adnab.me> | 2021-10-19 17:00:01 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2021-10-19 23:39:47 +0200 |
commit | 550ce7db2a43ddff310df710b78aab4a11436a2b (patch) | |
tree | 13c69699d1dfb526f79d14a57565a87ce3a3a105 /src | |
parent | 12190efd410002a75b28167526273b9276d36bd2 (diff) | |
download | garage-550ce7db2a43ddff310df710b78aab4a11436a2b.tar.gz garage-550ce7db2a43ddff310df710b78aab4a11436a2b.zip |
Update doc: quick_start
Diffstat (limited to 'src')
-rw-r--r-- | src/garage/cli.rs | 4 | ||||
-rw-r--r-- | src/util/config.rs | 7 |
2 files changed, 2 insertions, 9 deletions
diff --git a/src/garage/cli.rs b/src/garage/cli.rs index 67606b97..a88bd84e 100644 --- a/src/garage/cli.rs +++ b/src/garage/cli.rs @@ -356,7 +356,7 @@ pub async fn cmd_status(rpc_cli: &Endpoint<SystemRpc, ()>, rpc_host: NodeID) -> resp => return Err(Error::Message(format!("Invalid RPC response: {:?}", resp))), }; - println!("Healthy nodes:"); + println!("==== HEALTHY NODES ===="); let mut healthy_nodes = vec!["ID\tHostname\tAddress\tTag\tZone\tCapacity".to_string()]; for adv in status.iter().filter(|adv| adv.is_up) { if let Some(cfg) = config.members.get(&adv.id) { @@ -387,7 +387,7 @@ pub async fn cmd_status(rpc_cli: &Endpoint<SystemRpc, ()>, rpc_host: NodeID) -> .iter() .any(|(id, _)| !status_keys.contains(id)); if failure_case_1 || failure_case_2 { - println!("\nFailed nodes:"); + println!("\n==== FAILED NODES ===="); let mut failed_nodes = vec!["ID\tHostname\tAddress\tTag\tZone\tCapacity\tLast seen".to_string()]; for adv in status.iter().filter(|adv| !adv.is_up) { diff --git a/src/util/config.rs b/src/util/config.rs index 95c5cfc0..5ce5aa17 100644 --- a/src/util/config.rs +++ b/src/util/config.rs @@ -46,10 +46,6 @@ pub struct Config { /// Consul service name to use pub consul_service_name: Option<String>, - /// Max number of concurrent RPC request - #[serde(default = "default_max_concurrent_rpc_requests")] - pub max_concurrent_rpc_requests: usize, - /// Sled cache size, in bytes #[serde(default = "default_sled_cache_capacity")] pub sled_cache_capacity: u64, @@ -91,9 +87,6 @@ fn default_sled_cache_capacity() -> u64 { fn default_sled_flush_every_ms() -> u64 { 2000 } -fn default_max_concurrent_rpc_requests() -> usize { - 12 -} fn default_block_size() -> usize { 1048576 } |