Struct AgentV2 

pub struct AgentV2 { /* private fields */ }

Protocol v2 agent with connection pooling and bidirectional streaming.

Implementations

impl AgentV2

pub fn new(config: AgentConfig, circuit_breaker: Arc<CircuitBreaker>) -> Self

Create a new v2 agent.

pub fn id(&self) -> &str

Get the agent ID.

pub fn circuit_breaker(&self) -> &CircuitBreaker

Get the agent’s circuit breaker.

pub fn failure_mode(&self) -> FailureMode

Get the agent’s failure mode.

pub fn timeout_ms(&self) -> u64

Get the agent’s timeout in milliseconds.

pub fn metrics(&self) -> &AgentMetrics

Get the agent’s metrics.

pub fn handles_event(&self, event_type: EventType) -> bool

Check if agent handles a specific event type.

pub async fn initialize(&self) -> SentinelResult<()>

Initialize agent connection(s).

pub async fn call_request_headers( &self, event: &RequestHeadersEvent, ) -> SentinelResult<AgentResponse>

Call agent with request headers event.

pub async fn call_request_body_chunk( &self, event: &RequestBodyChunkEvent, ) -> SentinelResult<AgentResponse>

Call agent with request body chunk event.

For streaming body inspection, chunks are sent sequentially with increasing chunk_index. The agent responds after processing each chunk.

pub async fn call_response_headers( &self, event: &ResponseHeadersEvent, ) -> SentinelResult<AgentResponse>

Call agent with response headers event.

Called when upstream response headers are received, allowing the agent to inspect/modify response headers before they’re sent to the client.

pub async fn call_response_body_chunk( &self, event: &ResponseBodyChunkEvent, ) -> SentinelResult<AgentResponse>

Call agent with response body chunk event.

For streaming response body inspection, chunks are sent sequentially. The agent can inspect and optionally modify response body data.

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

Cancel an in-flight request.

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

Get agent capabilities.

pub async fn is_healthy(&self) -> bool

Check if agent is healthy.

pub fn record_success(&self, duration: Duration)

Record successful call (lock-free).

pub fn time_since_last_success(&self) -> Option<Duration>

Get the time since last successful call.

pub fn record_failure(&self)

Record failed call.

pub fn record_timeout(&self)

Record timeout.

pub async fn pool_stats(&self) -> Option<AgentPoolStats>

Get pool statistics.

pub fn pool_metrics_collector(&self) -> &MetricsCollector

Get the pool’s metrics collector.

Returns a reference to the shared metrics collector that aggregates metrics reports from all agents in this pool.

pub fn pool_metrics_collector_arc(&self) -> Arc<MetricsCollector>

Get an Arc to the pool’s metrics collector.

This is useful for registering the collector with a MetricsManager.

pub fn export_prometheus(&self) -> String

Export agent metrics in Prometheus format.

Returns a string containing all metrics collected from agents in Prometheus exposition format.

pub fn config_pusher(&self) -> &ConfigPusher

Get the pool’s config pusher.

Returns a reference to the shared config pusher that distributes configuration updates to agents.

pub fn push_config(&self, update_type: ConfigUpdateType) -> Option<String>

Push a configuration update to this agent.

Returns the push ID if the agent supports config push, None otherwise.

pub async fn send_configuration(&self, config: Value) -> SentinelResult<()>

Send a configuration update to this agent via the control stream.

This is a direct config push using the ConfigureEvent message.

pub async fn shutdown(&self)

Shutdown agent.

This removes the agent from the pool and closes all connections.