Struct WorkerObservers 

pub struct WorkerObservers {

    pub current_job: Arc<Mutex<Option<CurrentJob>>>,
    pub active_jobs: Arc<Mutex<Vec<CurrentJob>>>,
    pub thumbnails: Thumbnails,
    pub recent_jobs: Arc<Mutex<VecDeque<RecentJob>>>,
    pub local_jobs: Arc<Mutex<VecDeque<RecentJob>>>,
    pub local_api_url: Arc<Mutex<Option<String>>>,
    pub last_heartbeat: Arc<Mutex<Option<HeartbeatStatus>>>,
    pub session_state: Arc<Mutex<SessionState>>,
    pub gpu_runtime: Arc<Mutex<Option<GpuRuntimeStatus>>>,
    pub catalog: Arc<Mutex<Catalog>>,
    pub catalog_path: Arc<Mutex<Option<PathBuf>>>,
    pub recent_logs: Arc<Mutex<VecDeque<LogEntry>>>,
    pub recent_logs_seq: Arc<AtomicU64>,
}

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>>>

active_jobs: Arc<Mutex<Vec<CurrentJob>>>

Every running job, whatever its source (see crate::job_run::JobRun).

thumbnails: Thumbnails

Thumbnails of recent image jobs.

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

local_jobs: Arc<Mutex<VecDeque<RecentJob>>>

Finished jobs submitted to the local API (the in-app “local queue”), kept separate from studio-claimed jobs.

local_api_url: Arc<Mutex<Option<String>>>

URL the always-on local image API is reachable at, once bound.

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

session_state: Arc<Mutex<SessionState>>

Current WS lifecycle state, so the UI can show a connecting / reconnecting / auth-failed status instead of silent nothing.

gpu_runtime: Arc<Mutex<Option<GpuRuntimeStatus>>>

GPU-runtime readiness, probed once at startup. None until probed.

catalog: Arc<Mutex<Catalog>>

The local model catalog, shared between the local API (which serves from it) and the WS session (which mirrors studio-offered models into it). Empty until spawn_local_api loads it.

catalog_path: Arc<Mutex<Option<PathBuf>>>

Where the catalog persists (None = don’t persist, e.g. an unreadable file).

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.

recent_logs_seq: Arc<AtomicU64>

Entries ever pushed into recent_logs; the newest entry’s sequence number. Written under the recent_logs lock.

Implementations

impl WorkerObservers

pub fn with_global_worker_log() -> Self

Observers whose worker log is the process-wide ring the installed crate::job_log::WorkerLogLayer fills: the daemon’s.

pub fn worker_log(&self) -> WorkerLogRing

The worker log ring, as a handle.

Trait Implementations

impl Clone for WorkerObservers

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkerObservers

fn default() -> Self

Returns the “default value” for a type.