Enum V2Transport 

pub enum V2Transport {
    Grpc(AgentClientV2),
    Uds(AgentClientV2Uds),
    Reverse(ReverseConnectionClient),
}

Transport layer for v2 agent connections.

Supports gRPC, Unix Domain Socket, and reverse connections.

Variants

Grpc(AgentClientV2)

gRPC over HTTP/2

Uds(AgentClientV2Uds)

Binary protocol over Unix Domain Socket

Reverse(ReverseConnectionClient)

Reverse connection (agent connected to proxy)

Implementations

impl V2Transport

pub async fn is_connected(&self) -> bool

Check if the transport is connected.

pub async fn can_accept_requests(&self) -> bool

Check if the transport can accept new requests.

Returns false if the agent has sent a flow control pause signal.

pub async fn capabilities(&self) -> Option<AgentCapabilities>

Get negotiated capabilities.

pub async fn send_request_headers( &self, correlation_id: &str, event: &RequestHeadersEvent, ) -> Result<AgentResponse, AgentProtocolError>

Send a request headers event.

pub async fn send_request_body_chunk( &self, correlation_id: &str, event: &RequestBodyChunkEvent, ) -> Result<AgentResponse, AgentProtocolError>

Send a request body chunk event.

pub async fn send_response_headers( &self, correlation_id: &str, event: &ResponseHeadersEvent, ) -> Result<AgentResponse, AgentProtocolError>

Send a response headers event.

pub async fn send_response_body_chunk( &self, correlation_id: &str, event: &ResponseBodyChunkEvent, ) -> Result<AgentResponse, AgentProtocolError>

Send a response body chunk event.

pub async fn send_guardrail_inspect( &self, correlation_id: &str, event: &GuardrailInspectEvent, ) -> Result<AgentResponse, AgentProtocolError>

Send a guardrail inspect event.

pub async fn cancel_request( &self, correlation_id: &str, reason: CancelReason, ) -> Result<(), AgentProtocolError>

Cancel a specific request.

pub async fn cancel_all( &self, reason: CancelReason, ) -> Result<usize, AgentProtocolError>

Cancel all in-flight requests.

pub async fn close(&self) -> Result<(), AgentProtocolError>

Close the transport.

pub fn agent_id(&self) -> &str

Get agent ID.