Struct StatusBroadcaster 

pub struct StatusBroadcaster { /* private fields */ }

Daemon-wide status broadcaster.

Producers (fetch, lifecycle, etc.) call publish to update the current state. Subscribers (admin clients) connect to the admin socket; each gets a snapshot of the current state on connect, then the live event stream.

Implementations

impl StatusBroadcaster

pub fn new(initial: StatusEvent) -> Self

Build a fresh broadcaster seeded with initial. Typical initial value is StatusEvent::Starting.

pub fn publish(&self, event: StatusEvent)

Publish a new state. Updates the snapshot (so subsequent connects see this) AND fans out to all current subscribers.

pub fn current(&self) -> StatusEvent

Snapshot of the current state. Used by the admin accept loop to write the first frame on connect.

pub fn latest_capabilities(&self) -> Option<StatusEvent>

Most recent capability advertisement, if any. The admin accept loop writes this before the snapshot frame so one-shot readers see capabilities even when they connect after Ready.

pub fn subscribe(&self) -> Receiver<StatusEvent>

Subscribe to the live event stream. The receiver yields every event published after this call.

Trait Implementations

impl Clone for StatusBroadcaster

fn clone(&self) -> StatusBroadcaster

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.