Struct Daemon 

pub struct Daemon {
    pub runtime: Arc<Runtime<ProviderManager, DaemonHook>>,
}

Shared daemon state — holds the runtime. Cheap to clone (Arc-backed).

Fields

runtime: Arc<Runtime<ProviderManager, DaemonHook>>

The walrus runtime.

Implementations

impl Daemon

pub async fn start(config_dir: &Path) -> Result<DaemonHandle>

Load config, build runtime, bind the Unix domain socket, and start serving.

Returns a DaemonHandle with the socket path and a shutdown trigger.

pub async fn start_with_config( config: &DaemonConfig, config_dir: &Path, ) -> Result<DaemonHandle>

Start with an already-loaded config. Useful when the caller resolves config separately (e.g. CLI with scaffold logic).

Trait Implementations

impl Clone for Daemon

fn clone(&self) -> Daemon

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Server for Daemon

async fn send(&self, req: SendRequest) -> Result<SendResponse>

Handle Send — run agent and return complete response.

fn stream( &self, req: StreamRequest, ) -> impl Stream<Item = Result<StreamEvent>> + Send

Handle Stream — run agent and stream response events.

async fn clear_session( &self, req: ClearSessionRequest, ) -> Result<SessionCleared>

Handle ClearSession — clear agent history.

async fn list_agents(&self) -> Result<AgentList>

Handle ListAgents — list all registered agents.

async fn agent_info(&self, req: AgentInfoRequest) -> Result<AgentDetail>

Handle AgentInfo — get agent details.

async fn list_memory(&self) -> Result<MemoryList>

Handle ListMemory — list all memory entries.

async fn get_memory(&self, req: GetMemoryRequest) -> Result<MemoryEntry>

Handle GetMemory — get a memory entry by key.

fn download( &self, req: DownloadRequest, ) -> impl Stream<Item = Result<DownloadEvent>> + Send

Handle Download — download model files with progress.

async fn reload_skills(&self) -> Result<SkillsReloaded>

Handle ReloadSkills — reload skills from disk.

async fn mcp_add(&self, req: McpAddRequest) -> Result<McpAdded>

Handle McpAdd — add an MCP server.

async fn mcp_remove(&self, req: McpRemoveRequest) -> Result<McpRemoved>

Handle McpRemove — remove an MCP server.

async fn mcp_reload(&self) -> Result<McpReloaded>

Handle McpReload — reload MCP servers from config.

async fn mcp_list(&self) -> Result<McpServerList>

Handle McpList — list connected MCP servers.

async fn ping(&self) -> Result<()>

Handle Ping — keepalive.

fn dispatch( &self, msg: ClientMessage, ) -> impl Stream<Item = ServerMessage> + Send

Dispatch a ClientMessage to the appropriate handler method.