We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 392df24 commit 2031a4bCopy full SHA for 2031a4b
lading/src/blackhole/otlp.rs
@@ -109,7 +109,6 @@ impl Otlp {
109
})
110
}
111
112
-
113
/// Run [`Otlp`] to completion
114
///
115
/// This function runs the OTLP server(s) until a shutdown signal is
@@ -122,7 +121,12 @@ impl Otlp {
122
121
let mut join_set = JoinSet::new();
123
124
if let Some(addr) = self.grpc_addr {
125
- let grpc_task = grpc::run_server(addr, self.response_delay, &self.labels, self.concurrency_limit);
+ let grpc_task = grpc::run_server(
+ addr,
126
+ self.response_delay,
127
+ &self.labels,
128
+ self.concurrency_limit,
129
+ );
130
join_set.spawn(async move {
131
grpc_task.await.unwrap_or_else(|e| {
132
error!("gRPC task failed: {}", e);
0 commit comments