Struct DaemonFanOutSpawner 

pub struct DaemonFanOutSpawner {
    pub config: Arc<ConfigReloader>,
    pub shared_mcp: Arc<Mutex<ToolExecutor>>,
    pub mcp_tool_defs: Vec<Tool>,
    pub mcp_pool: Arc<McpPool>,
    pub hub: InteractionHub,
    pub subagent_tx: UnboundedSender<SubAgentOp>,
    pub tool_service: Arc<CliToolService>,
    pub agents_dir: Option<PathBuf>,
    pub now_secs: fn() -> i64,
}

Everything build_agent needs, captured so a fan-out worker can be spawned from inside a world-system (which has no access to the daemon’s context).

Fields

config: Arc<ConfigReloader>

Spawn-time config, read fresh per worker so a config.toml edit reaches fan-out workers too (shared with the daemon’s main spawner).

shared_mcp: Arc<Mutex<ToolExecutor>>

mcp_tool_defs: Vec<Tool>

mcp_pool: Arc<McpPool>

Shared MCP pool for per-agent [[mcp_servers]] - a fan-out worker advertises its blueprint’s already-connected servers and lazily warms any uncached ones for subsequent workers of the same type.

hub: InteractionHub

subagent_tx: UnboundedSender<SubAgentOp>

tool_service: Arc<CliToolService>

agents_dir: Option<PathBuf>

~/.leviath/agents, for resolving worker_query. None when there is no home directory.

now_secs: fn() -> i64

Trait Implementations

impl Clone for DaemonFanOutSpawner

fn clone(&self) -> DaemonFanOutSpawner

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl FanOutSpawner for DaemonFanOutSpawner

fn spawn_worker( &self, world: &mut World, parent: Entity, config: &FanOutConfig, item_id: &str, item_context: &Value, ) -> Result<Entity, String>

Spawn one worker under parent for the given work item, or Err with a human-readable reason (recorded as that item’s failure).