Struct AgentRouter 

pub struct AgentRouter { /* private fields */ }

Implementations

impl AgentRouter

pub fn new() -> Self

pub async fn delegate( &self, broker: &AnyBroker, from: &str, to: &str, task: &str, context: Value, timeout_ms: u64, ) -> Result<Value>

pub fn resolve(&self, correlation_id: Uuid, output: Value) -> bool

pub fn pending_count(&self) -> usize

Cleanup helper — returns the current pending entry count. Used by tests and health checks to verify the map doesn’t leak.

Trait Implementations

impl Default for AgentRouter

fn default() -> AgentRouter

Returns the “default value” for a type.