Struct Daemon 

pub struct Daemon {
    pub runtime: Arc<RwLock<Arc<Runtime<ProviderRegistry, 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<ProviderRegistry, 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. Note: reload does not restart managed services — that requires a full daemon restart. Services field is cleared to avoid re-spawning.

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: SendMsg) -> Result<SendResponse>

Handle Send — run agent and return complete response.

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

Handle Stream — run agent and stream response events.

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.

fn hub( &self, package: String, action: HubAction, filters: Vec<String>, ) -> 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 service_query(&self, service: String, query: String) -> Result<String>

Handle ServiceQuery — route to a named service.

async fn get_service_schema(&self, service: String) -> Result<String>

Handle GetServiceSchema — return JSON Schema for one service’s config.

async fn get_all_schemas(&self) -> Result<HashMap<String, String>>

Handle GetAllSchemas — return JSON Schemas for all services.

async fn list_services(&self) -> Result<Vec<ServiceInfoMsg>>

Handle GetServices — list registered services with status.

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

Handle SetServiceConfig — update a single service’s config.

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

Handle Reload — hot-reload runtime from disk.

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

Dispatch a ClientMessage to the appropriate handler method.