Struct Engine 

pub struct Engine { /* private fields */ }

Implementations

impl Engine

pub fn new(router: Arc<dyn Router>, config: Config) -> Self

pub fn with_memory(self, memory: Arc<dyn Memory>) -> Self

pub fn with_skills(self, skills: Arc<dyn SkillLibrary>) -> Self

pub fn with_identity(self, identity: Identity) -> Self

pub fn with_agent_store(self, store: Arc<dyn AgentStore>) -> Self

pub fn with_org_policy(self, policy: OrgPolicy) -> Self

pub fn with_hooks_config(self, hooks: Vec<Hook>) -> Self

pub fn with_approval_handler( self, approval_handler: Arc<dyn ApprovalHandler>, ) -> Self

pub async fn drive( &self, task: Task, event_tx: UnboundedSender<Event>, ) -> Result<OutcomeSummary>

Drive one AgentRun to completion.

pub async fn drive_with_run_id( &self, task: Task, event_tx: UnboundedSender<Event>, run_id: RunId, ) -> Result<OutcomeSummary>

Drive with a caller-provided run id.

pub async fn drive_with_inject( &self, task: Task, event_tx: UnboundedSender<Event>, run_id: RunId, inject_rx: Option<UnboundedReceiver<String>>, ) -> Result<OutcomeSummary>

Drive with an optional inject_rx channel that lets the caller inject user messages mid-run. Polled non-blocking between turns. (§3.7)