From 1968002d656383069a386bd874c9f0cc83e3116e Mon Sep 17 00:00:00 2001 From: rtkay123 Date: Fri, 15 Aug 2025 19:36:22 +0200 Subject: feat(rule-exec): receive messages --- crates/router/src/processor/grpc.rs | 27 --------------------------- 1 file changed, 27 deletions(-) delete mode 100644 crates/router/src/processor/grpc.rs (limited to 'crates/router/src/processor') diff --git a/crates/router/src/processor/grpc.rs b/crates/router/src/processor/grpc.rs deleted file mode 100644 index 344f2a1..0000000 --- a/crates/router/src/processor/grpc.rs +++ /dev/null @@ -1,27 +0,0 @@ -pub mod interceptor { - use opentelemetry::global; - use tonic::{ - Status, - service::{Interceptor, interceptor::InterceptedService}, - transport::Channel, - }; - use tracing::Span; - use tracing_opentelemetry::OpenTelemetrySpanExt; - use warden_stack::tracing::telemetry::tonic::injector; - - pub type Intercepted = InterceptedService; - - #[derive(Clone, Copy)] - pub struct MyInterceptor; - - impl Interceptor for MyInterceptor { - fn call(&mut self, mut request: tonic::Request<()>) -> Result, Status> { - let cx = Span::current().context(); - global::get_text_map_propagator(|propagator| { - propagator.inject_context(&cx, &mut injector::MetadataMap(request.metadata_mut())) - }); - - Ok(request) - } - } -} -- cgit v1.2.3