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.

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

Handle Hub — install or uninstall a hub package.

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

Dispatch a ClientMessage to the appropriate handler method.