diff --git a/snix/castore/src/blobservice/grpc.rs b/snix/castore/src/blobservice/grpc.rs index 672a130a4..5c3474309 100644 --- a/snix/castore/src/blobservice/grpc.rs +++ b/snix/castore/src/blobservice/grpc.rs @@ -215,8 +215,9 @@ impl ServiceBuilder for GRPCBlobServiceConfig { instance_name: &str, _context: &CompositionContext, ) -> Result, Box> { - let client = proto::blob_service_client::BlobServiceClient::new( + let client = proto::blob_service_client::BlobServiceClient::with_interceptor( crate::tonic::channel_from_url(&self.url.parse()?).await?, + snix_tracing::propagate::tonic::send_trace, ); Ok(Arc::new(GRPCBlobService::from_client( instance_name.to_string(), diff --git a/snix/castore/src/directoryservice/grpc.rs b/snix/castore/src/directoryservice/grpc.rs index 340764881..d85e08483 100644 --- a/snix/castore/src/directoryservice/grpc.rs +++ b/snix/castore/src/directoryservice/grpc.rs @@ -243,8 +243,9 @@ impl ServiceBuilder for GRPCDirectoryServiceConfig { instance_name: &str, _context: &CompositionContext, ) -> Result, Box> { - let client = proto::directory_service_client::DirectoryServiceClient::new( + let client = proto::directory_service_client::DirectoryServiceClient::with_interceptor( crate::tonic::channel_from_url(&self.url.parse()?).await?, + snix_tracing::propagate::tonic::send_trace, ); Ok(Arc::new(GRPCDirectoryService::from_client( instance_name.to_string(), diff --git a/snix/store/src/pathinfoservice/grpc.rs b/snix/store/src/pathinfoservice/grpc.rs index b8d0b5aaa..79e99d927 100644 --- a/snix/store/src/pathinfoservice/grpc.rs +++ b/snix/store/src/pathinfoservice/grpc.rs @@ -173,8 +173,9 @@ impl ServiceBuilder for GRPCPathInfoServiceConfig { instance_name: &str, _context: &CompositionContext, ) -> Result, Box> { - let client = proto::path_info_service_client::PathInfoServiceClient::new( + let client = proto::path_info_service_client::PathInfoServiceClient::with_interceptor( snix_castore::tonic::channel_from_url(&self.url.parse()?).await?, + snix_tracing::propagate::tonic::send_trace, ); Ok(Arc::new(GRPCPathInfoService::from_client( instance_name.to_string(),