Struct RustFnInProcessSpawnerFactory 

pub struct RustFnInProcessSpawnerFactory { /* private fields */ }

Factory for AgentKind::RustFn. At build time it looks the fn_id up in its internal registry and returns an InProcSpawner with the Rust closure WorkerFn registered under agent_name.

Naming convention: <WorkerIMPL><AdapterType>SpawnerFactory (RustFn worker on InProcess adapter). Sibling to LuaInProcessSpawnerFactory — the Lua-worker half of the same split.

Spec shape:

{ "fn_id": "echo" }     // Rust closure id pre-registered with the factory

Implementations

impl RustFnInProcessSpawnerFactory

pub fn new() -> Self

Start with no registered closures.

pub fn register_fn<F, Fut>(self, fn_id: impl Into<String>, f: F) -> Self

where F: Fn(WorkerInvocation) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<WorkerResult, WorkerError>> + Send + 'static,

Register a Rust closure WorkerFn under fn_id, wrapping it so it matches the WorkerFn signature (boxed, pinned future).

Trait Implementations

impl Default for RustFnInProcessSpawnerFactory

fn default() -> Self

Returns the “default value” for a type.

impl SpawnerFactory for RustFnInProcessSpawnerFactory

fn build( &self, agent_def: &AgentDef, _hint: Option<&Value>, ) -> Result<Arc<dyn SpawnerAdapter>, CompileError>

Build the concrete SpawnerAdapter for one AgentDef. hint is the matching entry (if any) from Blueprint.hints.per_agent.

impl SpawnerFactoryKind for RustFnInProcessSpawnerFactory

const KIND: AgentKind = AgentKind::RustFn

The AgentKind this factory handles — used as the HashMap key by SpawnerRegistry::register.

type Worker = RustFnWorker

The concrete Worker type produced by this AgentKind — this binds the type chain all the way from AgentKind down to Worker. Every factory declares it so the AgentKind → Worker mapping is explicit across all four layers. It is the source of truth for preserving the concrete type right up until SpawnerAdapter::spawn erases it into Box<dyn Worker>.