Struct DaemonState 

pub struct DaemonState {
    pub queue: Mutex<VecDeque<QueuedJob>>,
    pub active: Mutex<Option<RunningJob>>,
    pub recent: Mutex<RingBuffer<JobRecord>>,
    pub replay: Mutex<ReplayBuffer>,
    pub events: Sender<Event>,
    pub next_job_id: AtomicU64,
    pub accepting: CancellationToken,
    pub shutdown: CancellationToken,
    pub started_at: u64,
    pub daemon_pid: u32,
    pub account: Option<String>,
    pub queue_notify: Notify,
}

Fields

queue: Mutex<VecDeque<QueuedJob>>

active: Mutex<Option<RunningJob>>

recent: Mutex<RingBuffer<JobRecord>>

replay: Mutex<ReplayBuffer>

Per-job event history for attach <id> to a finished job. The collector task (spawned in serve_resumed) populates this from the broadcast channel; the Attach handler dumps it before EndOfStream. Bounded per-job and across jobs so a runaway process can’t OOM the daemon.

events: Sender<Event>

next_job_id: AtomicU64

accepting: CancellationToken

Set when Stop is received. The accept loop and worker_loop check this to refuse new jobs and exit when idle. Active connections keep streaming until their job completes.

shutdown: CancellationToken

Set for a hard stop (force=true) or when the queue drains after a graceful stop. Signals all subscribers and the accept loop to exit.

started_at: u64

daemon_pid: u32

account: Option<String>

queue_notify: Notify

Implementations

impl DaemonState

pub fn new( account: Option<String>, daemon_pid: u32, started_at: u64, ) -> Arc<Self>

pub fn allocate_job_id(&self) -> JobId

pub async fn enqueue(&self, job: QueuedJob) -> u32

Insert a job. Priority items sit at the boundary between existing priority items and non-priority items; non-priority items append. Returns the queue position the caller should report: 0 if it will run next (queue empty and no active), 1+ otherwise. The “active” job is NOT counted because it is already running.

pub async fn toggle_priority(&self, job_id: JobId) -> Result<(), JobNotFound>

pub async fn cancel(&self, job_id: JobId) -> Result<(), JobNotFound>

pub async fn snapshot(&self) -> StatusSnapshot

pub async fn broadcast_snapshot(&self)

Snapshot + broadcast on the events channel. Called whenever the queue, active job, or recent ring changes so Subscribe stream clients (the TUI, daemon status) refresh without re-polling.

pub async fn recent_exit_code(&self, job_id: JobId) -> Option<i32>

Look up a recently-finished job by id. Used by stream_events to recover the terminal exit code after a broadcast lag.