Struct OperatorSpawner 

pub struct OperatorSpawner { /* private fields */ }

A SpawnerAdapter implementation that hands the dispatch off to an Arc<dyn Operator>.

OperatorSpawner itself does not inspect the operator’s kind — MainAi / Human / Automate / Composite all go through the same path, and the operator implementation absorbs the differences.

Position — the AgentSpec-axis Operator path

Use this type on the path that bakes a separate Operator backend into every AgentDef. For an AgentKind::Operator AgentDef, the OperatorSpawnerFactory produces one with OperatorSpawner::new(op, system_prompt, worker_binding) and places it in routes[agent_name]. Agents flowing in through the agent.md loader default to kind = Operator, so they land here.

The paired Blueprint-global (session) axis is crate::middleware::OperatorDelegateMiddleware — a single operator backend registered on the session and applied uniformly across every agent. When both are effective, the delegate middleware sits at the outer end of the stack and bypasses inner.spawn; this type is inert and no double fire can occur. See the OperatorSpawnerFactory doc for the exclusivity narrative.

Implementations

impl OperatorSpawner

pub fn new( operator: Arc<dyn Operator>, system_prompt: Option<String>, worker_binding: Option<WorkerBinding>, ) -> Self

Binds an operator backend plus an optional compile-time system_prompt template (rendered per-spawn via render_system) and an optional compile-time-baked worker_binding.

Trait Implementations

impl SpawnerAdapter for OperatorSpawner

fn spawn<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, engine: &'life1 Engine, ctx: &'life2 Ctx, task_id: TaskId, attempt: u32, token: CapToken, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Worker>, SpawnError>> + Send + 'async_trait>>

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

Spawn one attempt as a worker. Returns Box<dyn Worker>.