aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2021-10-19 17:00:01 +0200
committerAlex Auvolat <alex@adnab.me>2021-10-19 23:39:47 +0200
commit550ce7db2a43ddff310df710b78aab4a11436a2b (patch)
tree13c69699d1dfb526f79d14a57565a87ce3a3a105 /src
parent12190efd410002a75b28167526273b9276d36bd2 (diff)
downloadgarage-550ce7db2a43ddff310df710b78aab4a11436a2b.tar.gz
garage-550ce7db2a43ddff310df710b78aab4a11436a2b.zip
Update doc: quick_start
Diffstat (limited to 'src')
-rw-r--r--src/garage/cli.rs4
-rw-r--r--src/util/config.rs7
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
}