From ab737ded76c5c5d887066fa3f0fbe04edff9c2ed Mon Sep 17 00:00:00 2001 From: katelyn martin Date: Mon, 24 Feb 2025 00:00:00 +0000 Subject: [PATCH] chore(app/trace_collector): remove `Default` bounds see https://github.com/linkerd/linkerd2/issues/8733 for more information. in hyper 1.x, `Incoming` bodies do not provide a `Default` implementation. compare the trait implementations here: * https://docs.rs/hyper/0.14.31/hyper/body/struct.Body.html#impl-Default-for-Body * https://docs.rs/hyper/latest/hyper/body/struct.Incoming.html#trait-implementations this commit removes these bounds from the `linkerd_app::trace_collector::otel_collector::SpanExporter` and other connected functions. Signed-off-by: katelyn martin --- linkerd/app/src/trace_collector/otel_collector.rs | 2 +- linkerd/opencensus/src/lib.rs | 4 ++-- linkerd/opentelemetry/src/lib.rs | 4 ++-- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/linkerd/app/src/trace_collector/otel_collector.rs b/linkerd/app/src/trace_collector/otel_collector.rs index 0541aa75d6..052cb71007 100644 --- a/linkerd/app/src/trace_collector/otel_collector.rs +++ b/linkerd/app/src/trace_collector/otel_collector.rs @@ -34,7 +34,7 @@ where S: GrpcService + Clone + Send + 'static, S::Error: Into, S::Future: Send, - S::ResponseBody: Default + Body + Send + 'static, + S::ResponseBody: Body + Send + 'static, ::Error: Into + Send, { let (span_sink, spans_rx) = mpsc::channel(crate::trace_collector::SPAN_BUFFER_CAPACITY); diff --git a/linkerd/opencensus/src/lib.rs b/linkerd/opencensus/src/lib.rs index 798f48ad1e..2cb971a7af 100644 --- a/linkerd/opencensus/src/lib.rs +++ b/linkerd/opencensus/src/lib.rs @@ -24,7 +24,7 @@ pub async fn export_spans(client: T, node: Node, spans: S, metrics: Regist where T: GrpcService + Clone, T::Error: Into, - T::ResponseBody: Default + Body + Send + 'static, + T::ResponseBody: Body + Send + 'static, ::Error: Into + Send, S: Stream + Unpin, { @@ -49,7 +49,7 @@ impl SpanExporter where T: GrpcService, T::Error: Into, - T::ResponseBody: Default + Body + Send + 'static, + T::ResponseBody: Body + Send + 'static, ::Error: Into + Send, S: Stream + Unpin, { diff --git a/linkerd/opentelemetry/src/lib.rs b/linkerd/opentelemetry/src/lib.rs index ad46eee823..1759fa4a71 100644 --- a/linkerd/opentelemetry/src/lib.rs +++ b/linkerd/opentelemetry/src/lib.rs @@ -39,7 +39,7 @@ pub async fn export_spans( ) where T: GrpcService + Clone, T::Error: Into, - T::ResponseBody: Default + Body + Send + 'static, + T::ResponseBody: Body + Send + 'static, ::Error: Into + Send, S: Stream + Unpin, { @@ -66,7 +66,7 @@ impl SpanExporter where T: GrpcService + Clone, T::Error: Into, - T::ResponseBody: Default + Body + Send + 'static, + T::ResponseBody: Body + Send + 'static, ::Error: Into + Send, S: Stream + Unpin, {