Struct WorkerObservers 

pub struct WorkerObservers {
    pub current_job: Arc<Mutex<Option<CurrentJob>>>,
    pub recent_jobs: Arc<Mutex<VecDeque<RecentJob>>>,
    pub last_heartbeat: Arc<Mutex<Option<HeartbeatStatus>>>,
    pub recent_logs: Arc<Mutex<VecDeque<LogEntry>>>,
}

Bundle of in-process observation slots the WS session writes to and the optional native UI reads from. Default gives empty slots so existing (headless) call sites stay one-liners. Cheap to clone — every field is an Arc.

Fields

current_job: Arc<Mutex<Option<CurrentJob>>>

recent_jobs: Arc<Mutex<VecDeque<RecentJob>>>

last_heartbeat: Arc<Mutex<Option<HeartbeatStatus>>>

recent_logs: Arc<Mutex<VecDeque<LogEntry>>>

Bounded ring of every log entry the worker has emitted, kept for the UI’s Logs tab. Separate from the WS ship queue (which is drained every second) so the display doesn’t blank out between ticks.

Trait Implementations

impl Clone for WorkerObservers

fn clone(&self) -> WorkerObservers

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkerObservers

fn default() -> WorkerObservers

Returns the “default value” for a type.