Struct GrpcAgentHandlerV2 

pub struct GrpcAgentHandlerV2 { /* private fields */ }

Internal handler that implements the gRPC AgentServiceV2 trait.

Trait Implementations

impl AgentServiceV2 for GrpcAgentHandlerV2

fn process_stream<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<ProxyToAgent>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ProcessStreamStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle bidirectional stream for processing events.

fn control_stream<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<AgentControl>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ControlStreamStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle control stream for health/metrics/config.

The control stream is a bidirectional channel for:

• Agent -> Proxy: Health status, metrics reports, config update requests, logs
• Proxy -> Agent: Configuration updates, shutdown/drain requests

fn process_event<'life0, 'async_trait>( &'life0 self, request: Request<ProxyToAgent>, ) -> Pin<Box<dyn Future<Output = Result<Response<AgentToProxy>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle single event (v1 compatibility mode).

type ProcessStreamStream = Pin<Box<dyn Stream<Item = Result<AgentToProxy, Status>> + Send>>

Server streaming response type for the ProcessStream method.

type ControlStreamStream = Pin<Box<dyn Stream<Item = Result<ProxyControl, Status>> + Send>>

Server streaming response type for the ControlStream method.