Struct Replica 

pub struct Replica {
    pub observers: WorkerObservers,
    pub cfg: SharedConfig,
    pub busy: Arc<AtomicBool>,
    pub paused: Arc<AtomicBool>,
    pub registration: SharedRegistration,
    pub status: Arc<Mutex<Option<DaemonStatus>>>,
    pub models: Arc<Mutex<Vec<ModelEntry>>>,
    pub link: Arc<Mutex<LinkState>>,
    pub selected_job: Arc<Mutex<Option<String>>>,
    pub selected_log: Arc<Mutex<Option<(String, JobLog)>>>,
    /* private fields */
}

The UI’s copy of the daemon’s state. Cheap to clone.

Fields

observers: WorkerObservers

The daemon’s observers, as the tabs read them.

cfg: SharedConfig

The daemon’s operator-editable config and worker id (no secrets).

busy: Arc<AtomicBool>

paused: Arc<AtomicBool>

registration: SharedRegistration

status: Arc<Mutex<Option<DaemonStatus>>>

The last snapshot, whole.

models: Arc<Mutex<Vec<ModelEntry>>>

link: Arc<Mutex<LinkState>>

selected_job: Arc<Mutex<Option<String>>>

The job whose log the UI shows; the poller keeps its log fresh.

selected_log: Arc<Mutex<Option<(String, JobLog)>>>

Implementations

impl Replica

pub fn registered(&self) -> bool

Whether the daemon is registered with the studio.

pub fn apply_status(&self, status: DaemonStatus)

Mirror a snapshot into the replica.

pub fn missing_thumbnails(&self) -> Vec<String>

Job ids whose thumbnail the daemon has and the replica lacks.

pub fn logs_after(&self) -> u64

The sequence number to ask new log entries after.

pub fn apply_logs(&self, page: LogsPage)

Append a page of log entries; a page from a restarted daemon (its sequence number went backwards) replaces the ring.

pub fn clear(&self)

Forget everything the daemon said, so nothing stale is shown.

Trait Implementations

impl Clone for Replica

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 Replica

fn default() -> Self

Returns the “default value” for a type.