Struct AgentClientV2Uds 

pub struct AgentClientV2Uds { /* private fields */ }

v2 agent client over Unix Domain Socket.

This client maintains a single connection and multiplexes multiple requests over it using correlation IDs, similar to the gRPC client.

Implementations

impl AgentClientV2Uds

pub async fn new( agent_id: impl Into<String>, socket_path: impl Into<String>, timeout: Duration, ) -> Result<Self, AgentProtocolError>

Create a new UDS v2 client.

pub async fn encoding(&self) -> UdsEncoding

Get the current negotiated encoding.

pub fn set_metrics_callback(&mut self, callback: MetricsCallback)

Set the metrics callback.

pub fn set_config_update_callback(&mut self, callback: ConfigUpdateCallback)

Set the config update callback.

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

Connect and perform handshake.

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

Get negotiated capabilities.

pub async fn is_connected(&self) -> bool

Check if connected.

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_request_complete( &self, correlation_id: &str, event: &RequestCompleteEvent, ) -> Result<AgentResponse, AgentProtocolError>

Send a request complete event.

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

Send a WebSocket frame event.

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

Send a guardrail inspect event.

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

Send a configure event.

pub async fn send_request_body_chunk_binary( &self, event: &BinaryRequestBodyChunkEvent, ) -> Result<AgentResponse, AgentProtocolError>

Send a binary request body chunk event (zero-copy path).

This method avoids base64 encoding when using MessagePack encoding, sending raw bytes directly over the wire for better throughput.

Performance

When MessagePack encoding is negotiated:

• Bytes are serialized directly (no base64 encode/decode)
• Reduces CPU usage and latency for large bodies

When JSON encoding is used:

• Falls back to base64 encoding for JSON compatibility

pub async fn send_response_body_chunk_binary( &self, event: &BinaryResponseBodyChunkEvent, ) -> Result<AgentResponse, AgentProtocolError>

Send a binary response body chunk event (zero-copy path).

This method avoids base64 encoding when using MessagePack encoding, sending raw bytes directly over the wire for better throughput.

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

Send a cancel request for a specific correlation ID.

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

Cancel all in-flight requests.

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

Send a ping.

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

Close the connection.

pub fn in_flight(&self) -> u64

Get in-flight request count.

pub fn agent_id(&self) -> &str

Get agent ID.

pub async fn is_paused(&self) -> bool

Check if the agent has requested flow control pause.

Returns true if the agent sent a FlowAction::Pause signal, indicating it cannot accept more requests.

pub async fn can_accept_requests(&self) -> bool

Check if the transport can accept new requests.

Returns false if the agent has requested a flow control pause.