Struct AgentManager 

pub struct AgentManager { /* private fields */ }

Agent manager handling all external agents.

Implementations

impl AgentManager

pub async fn new( agents: Vec<AgentConfig>, max_concurrent_calls: usize, ) -> SentinelResult<Self>

Create new agent manager.

pub async fn process_request_headers( &self, ctx: &AgentCallContext, headers: &HashMap<String, Vec<String>>, route_agents: &[String], ) -> SentinelResult<AgentDecision>

Process request headers through agents.

pub async fn process_request_body( &self, ctx: &AgentCallContext, data: &[u8], is_last: bool, route_agents: &[String], ) -> SentinelResult<AgentDecision>

Process request body chunk through agents.

pub async fn process_request_body_streaming( &self, ctx: &AgentCallContext, data: &[u8], is_last: bool, chunk_index: u32, bytes_received: usize, total_size: Option<usize>, route_agents: &[String], ) -> SentinelResult<AgentDecision>

Process a single request body chunk through agents (streaming mode).

Unlike process_request_body which is used for buffered mode, this method is designed for streaming where chunks are sent individually as they arrive.

pub async fn process_response_body_streaming( &self, ctx: &AgentCallContext, data: &[u8], is_last: bool, chunk_index: u32, bytes_sent: usize, total_size: Option<usize>, route_agents: &[String], ) -> SentinelResult<AgentDecision>

Process a single response body chunk through agents (streaming mode).

pub async fn process_response_headers( &self, ctx: &AgentCallContext, status: u16, headers: &HashMap<String, Vec<String>>, route_agents: &[String], ) -> SentinelResult<AgentDecision>

Process response headers through agents.

pub async fn process_websocket_frame( &self, route_id: &str, event: WebSocketFrameEvent, ) -> SentinelResult<AgentResponse>

Process a WebSocket frame through agents.

This is used for WebSocket frame inspection after an upgrade. Returns the agent response directly to allow the caller to access the websocket_decision field.

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

Initialize agent connections.

pub async fn shutdown(&self)

Shutdown all agents.

pub fn metrics(&self) -> &AgentMetrics

Get agent metrics.

pub fn get_agents_for_event(&self, event_type: EventType) -> Vec<String>

Get agent IDs that handle a specific event type.

This is useful for pre-filtering agents before making calls, e.g., to check if any agents handle WebSocket frames.