Struct ReverseConnectionClient 

pub struct ReverseConnectionClient { /* private fields */ }

Client wrapper for a reverse connection.

This wraps an accepted connection and provides the same interface as AgentClientV2Uds but for inbound connections.

Implementations

impl ReverseConnectionClient

pub fn agent_id(&self) -> &str

Get the agent ID.

pub fn connection_id(&self) -> &str

Get the connection ID.

pub async fn is_connected(&self) -> bool

Check if connected.

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

Get capabilities.

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.

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 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 connection.

pub fn in_flight(&self) -> u64

Get in-flight request count.