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>>

The daemon-wide MCP executor, for servers configured globally.

mcp_tool_defs: Vec<Tool>

Tool definitions from shared_mcp, resolved once rather than per worker.

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

Where a worker’s prompts go. Shared with the daemon, so a fan-out worker’s question reaches the same place as any other run’s.

subagent_tx: UnboundedSender<SubAgentOp>

Where a worker’s own sub-agent spawns are sent.

tool_service: Arc<CliToolService>

The tool dispatcher every worker’s calls go through.

agents_dir: Option<PathBuf>

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

now_secs: fn() -> i64

The clock, injected so a test can stamp a worker deterministically.

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).