Struct Daemon 

pub struct Daemon {
    pub runtime: Arc<RwLock<Arc<Runtime<ProviderManager, DaemonHook>>>>,
    /* private fields */
}

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

The runtime is stored behind Arc<RwLock<Arc<Runtime>>> so that Daemon::reload can swap it atomically while in-flight requests that already cloned the inner Arc complete normally.

Fields

runtime: Arc<RwLock<Arc<Runtime<ProviderManager, DaemonHook>>>>

The walrus runtime, swappable via Daemon::reload.

Implementations

impl Daemon

pub async fn reload(&self) -> Result<()>

Rebuild the runtime from disk and swap it in atomically.

In-flight requests that already hold a reference to the old runtime complete normally. New requests after the swap see the new runtime.

impl Daemon

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

Load config, build runtime, and start the event loop.

Returns a DaemonHandle with the event sender exposed. The caller spawns transports (socket, channels) using the handle’s event_tx and shutdown_tx, then integrates its own channels by cloning event_tx and sending DaemonEvent::Message variants.

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.

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

Handle Download — download model files with progress.

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

Handle Ping — keepalive.

async fn list_sessions(&self) -> Result<Vec<SessionInfo>>

Handle Sessions — list active sessions.

async fn kill_session(&self, session: u64) -> Result<bool>

Handle Kill — close a session by ID.

async fn list_tasks(&self) -> Result<Vec<TaskInfo>>

Handle Tasks — list tasks in the task registry.

async fn kill_task(&self, task_id: u64) -> Result<bool>

Handle KillTask — cancel a task by ID.

async fn approve_task(&self, task_id: u64, response: String) -> Result<bool>

Handle Approve — approve a blocked task’s inbox item.

async fn evaluate(&self, req: SendRequest) -> Result<bool>

Handle Evaluate — decide whether the agent should respond (DD#39).

fn hub( &self, package: CompactString, action: HubAction, ) -> impl Stream<Item = Result<DownloadEvent>> + Send

Handle Hub — install or uninstall a hub package.

fn subscribe_tasks(&self) -> impl Stream<Item = Result<TaskEvent>> + Send

Handle SubscribeTasks — stream task lifecycle events.

async fn list_downloads(&self) -> Result<Vec<DownloadInfo>>

Handle Downloads — list downloads in the registry.

fn subscribe_downloads( &self, ) -> impl Stream<Item = Result<DownloadEvent>> + Send

Handle SubscribeDownloads — stream download lifecycle events.

async fn get_config(&self) -> Result<String>

Handle GetConfig — return the full daemon config as JSON.

async fn set_config(&self, config: String) -> Result<()>

Handle SetConfig — replace the daemon config from JSON.

async fn memory_query(&self, query: MemoryOp) -> Result<MemoryResult>

Handle MemoryQuery — query the memory graph.

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

Dispatch a ClientMessage to the appropriate handler method.