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 crabtalk runtime, swappable via Daemon::reload.

Implementations

impl Daemon

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

Rebuild the runtime from disk and swap it in atomically.

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 compact_session(&self, session: u64) -> Result<String>

Handle Compact — compact a session’s history into a summary.

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.

fn subscribe_events(&self) -> impl Stream<Item = Result<AgentEventMsg>> + Send

Handle SubscribeEvents — stream agent 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 reload(&self) -> Result<()>

Handle Reload — hot-reload runtime from disk.

async fn get_stats(&self) -> Result<DaemonStats>

Handle GetStats — return daemon-level stats.

async fn create_cron(&self, req: CreateCronMsg) -> Result<CronInfo>

Handle CreateCron — create a new cron entry and start its timer.

async fn delete_cron(&self, id: u64) -> Result<bool>

Handle DeleteCron — remove a cron entry and stop its timer.

async fn list_crons(&self) -> Result<CronList>

Handle ListCrons — return all cron entries.

async fn reply_to_ask(&self, session: u64, content: String) -> Result<()>

Handle ReplyToAsk — deliver a user reply to a pending ask_user tool call.

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

Dispatch a ClientMessage to the appropriate handler method.