Struct RuleBasedRouter 

pub struct RuleBasedRouter { /* private fields */ }

基于规则的路由器

Implementations

impl RuleBasedRouter

pub fn new() -> RuleBasedRouter

pub fn with_default_agent(self, agent_id: impl Into<String>) -> RuleBasedRouter

pub fn with_confirm_on_match(self, confirm: bool) -> RuleBasedRouter

pub async fn add_rule(&self, rule: RoutingRule)

添加规则

pub async fn remove_rule(&self, rule_id: &str)

移除规则

Trait Implementations

impl AgentRouter for RuleBasedRouter

fn name(&self) -> &str

路由器名称

fn route<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, context: &'life1 RoutingContext, available_agents: &'life2 [AgentInfo], ) -> Pin<Box<dyn Future<Output = Result<RoutingDecision, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, RuleBasedRouter: 'async_trait,

为子任务选择最合适的Agent

fn route_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, contexts: &'life1 [RoutingContext], available_agents: &'life2 [AgentInfo], ) -> Pin<Box<dyn Future<Output = Result<Vec<RoutingDecision>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

批量路由多个子任务

fn validate_decision<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, decision: &'life1 RoutingDecision, available_agents: &'life2 [AgentInfo], ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

验证路由决策是否有效

impl Default for RuleBasedRouter

fn default() -> RuleBasedRouter

Returns the “default value” for a type.