aboutsummaryrefslogtreecommitdiff
path: root/src/rpc/rpc_helper.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-02-24 13:18:51 +0100
committerAlex Auvolat <alex@adnab.me>2022-03-14 10:54:12 +0100
commitf869ca625d025d8c52af405392d2081bd81437a8 (patch)
treeb7ad1950afdde2ff9cd6caf1a932a6e5a27c9706 /src/rpc/rpc_helper.rs
parent0cc31ee16994d11f4446186c817d8492b0b54f6b (diff)
downloadgarage-f869ca625d025d8c52af405392d2081bd81437a8.tar.gz
garage-f869ca625d025d8c52af405392d2081bd81437a8.zip
Add spans to table calls, change span names in RPC
Diffstat (limited to 'src/rpc/rpc_helper.rs')
-rw-r--r--src/rpc/rpc_helper.rs16
1 files changed, 15 insertions, 1 deletions
diff --git a/src/rpc/rpc_helper.rs b/src/rpc/rpc_helper.rs
index 4114724f..89225511 100644
--- a/src/rpc/rpc_helper.rs
+++ b/src/rpc/rpc_helper.rs
@@ -234,9 +234,23 @@ impl RpcHelper {
let quorum = strategy.rs_quorum.unwrap_or(to.len());
let tracer = opentelemetry::global::tracer("garage");
- let mut span = tracer.start(format!("RPC {} to {}", endpoint.path(), to.len()));
+ let span_name = if strategy.rs_interrupt_after_quorum {
+ format!("RPC {} to {} of {}", endpoint.path(), quorum, to.len())
+ } else {
+ format!(
+ "RPC {} to {} (quorum {})",
+ endpoint.path(),
+ to.len(),
+ quorum
+ )
+ };
+ let mut span = tracer.start(span_name);
span.set_attribute(KeyValue::new("to", format!("{:?}", to)));
span.set_attribute(KeyValue::new("quorum", quorum as i64));
+ span.set_attribute(KeyValue::new(
+ "interrupt_after_quorum",
+ strategy.rs_interrupt_after_quorum.to_string(),
+ ));
self.try_call_many_internal(endpoint, to, msg, strategy, quorum)
.with_context(Context::current_with_span(span))