maurice/snix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(snix/[ca]store): restore client trace propagation

Browse source 
This broke in cl/11976 and cl/11983, the ::with_interceptor() calls
went missing.

Change-Id: Ic78a88d6c102d79da58fe45d5e595d3879c12af7
Reviewed-on: https://cl.snix.dev/c/snix/+/30631
Tested-by: besadii
Autosubmit: Florian Klink <flokli@flokli.de>
Reviewed-by: Ryan Lahfa <ryan@lahfa.xyz>
This commit is contained in:
Florian Klink 2025-07-31 15:09:20 +02:00 • committed by clbot
parent a9d5c184d5
commit 74264569ee
3 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
snix/castore/src/blobservice/grpc.rs
View file

@ -215,8 +215,9 @@ impl ServiceBuilder for GRPCBlobServiceConfig {
instance_name: &str, instance_name: &str,
_context: &CompositionContext, _context: &CompositionContext,
) -> Result<Arc<dyn BlobService>, Box<dyn std::error::Error + Send + Sync + 'static>> { ) -> Result<Arc<dyn BlobService>, Box<dyn std::error::Error + Send + Sync + 'static>> {
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?, crate::tonic::channel_from_url(&self.url.parse()?).await?,
snix_tracing::propagate::tonic::send_trace,
); );
Ok(Arc::new(GRPCBlobService::from_client( Ok(Arc::new(GRPCBlobService::from_client(
instance_name.to_string(), instance_name.to_string(),

3
snix/castore/src/directoryservice/grpc.rs
View file

@ -243,8 +243,9 @@ impl ServiceBuilder for GRPCDirectoryServiceConfig {
instance_name: &str, instance_name: &str,
_context: &CompositionContext, _context: &CompositionContext,
) -> Result<Arc<dyn DirectoryService>, Box<dyn std::error::Error + Send + Sync + 'static>> { ) -> Result<Arc<dyn DirectoryService>, Box<dyn std::error::Error + Send + Sync + 'static>> {
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?, crate::tonic::channel_from_url(&self.url.parse()?).await?,
snix_tracing::propagate::tonic::send_trace,
); );
Ok(Arc::new(GRPCDirectoryService::from_client( Ok(Arc::new(GRPCDirectoryService::from_client(
instance_name.to_string(), instance_name.to_string(),

3
snix/store/src/pathinfoservice/grpc.rs
View file

@ -173,8 +173,9 @@ impl ServiceBuilder for GRPCPathInfoServiceConfig {
instance_name: &str, instance_name: &str,
_context: &CompositionContext, _context: &CompositionContext,
) -> Result<Arc<dyn PathInfoService>, Box<dyn std::error::Error + Send + Sync + 'static>> { ) -> Result<Arc<dyn PathInfoService>, Box<dyn std::error::Error + Send + Sync + 'static>> {
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_castore::tonic::channel_from_url(&self.url.parse()?).await?,
snix_tracing::propagate::tonic::send_trace,
); );
Ok(Arc::new(GRPCPathInfoService::from_client( Ok(Arc::new(GRPCPathInfoService::from_client(
instance_name.to_string(), instance_name.to_string(),