Struct ConditionalAgent 

pub struct ConditionalAgent { /* private fields */ }

Rule-based conditional routing agent.

Executes one of two sub-agents based on a synchronous condition function. For LLM-based intelligent routing, use crate::LlmConditionalAgent instead.

Example

// Route based on session state flag
let router = ConditionalAgent::new(
    "premium_router",
    |ctx| ctx.session().state().get("is_premium").map(|v| v.as_bool()).flatten().unwrap_or(false),
    Arc::new(premium_agent),
).with_else(Arc::new(basic_agent));

Implementations

impl ConditionalAgent

pub fn new<F>( name: impl Into<String>, condition: F, if_agent: Arc<dyn Agent>, ) -> Self

where F: Fn(&dyn InvocationContext) -> bool + Send + Sync + 'static,

pub fn with_description(self, desc: impl Into<String>) -> Self

pub fn with_else(self, else_agent: Arc<dyn Agent>) -> Self

pub fn before_callback(self, callback: BeforeAgentCallback) -> Self

pub fn after_callback(self, callback: AfterAgentCallback) -> Self

pub fn with_skills(self, index: SkillIndex) -> Self

pub fn with_auto_skills(self) -> Result<Self>

pub fn with_skills_from_root(self, root: impl AsRef<Path>) -> Result<Self>

pub fn with_skill_policy(self, policy: SelectionPolicy) -> Self

pub fn with_skill_budget(self, max_chars: usize) -> Self

Trait Implementations

impl Agent for ConditionalAgent

fn name(&self) -> &str

fn description(&self) -> &str

fn sub_agents(&self) -> &[Arc<dyn Agent>]

fn run<'life0, 'async_trait>( &'life0 self, ctx: Arc<dyn InvocationContext>, ) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,