Struct CarriedWorker 

pub struct CarriedWorker {
    pub id: String,
    pub subagent_id: u64,
    pub agent: String,
    pub status: String,
    pub archive_path: Option<PathBuf>,
    pub stopped_by_reload: bool,
    pub wake_lost: bool,
    pub wake: bool,
    pub elapsed_secs: u64,
    pub preview: String,
}

A worker carried across a daemon reload (ReloadSession::workers).

A reload execvs the daemon: worker threads cannot survive it. So the checkpoint stops every running worker (its archive is the resumable state), and the new image re-registers each id against its archive and tells the parent, which would otherwise wait for a completion that never comes.

Fields

id: String

subagent_id: u64

agent: String

status: String

running never appears: the checkpoint has stopped them.

archive_path: Option<PathBuf>

The resume archive, when the worker’s finalizer wrote one.

stopped_by_reload: bool

A daemon reload (this one or an earlier one) stopped this run, not the user. A label for status and the wake’s wording; whether the parent is told again is Self::wake.

wake_lost: bool

Finished on its own, and its completion wake never reached the parent: still queued in the old image’s event queue (which the exec discards), or not yet pushed when the checkpoint ended.

wake: bool

The next image must wake the parent about this worker: this reload stopped it, its completion wake was lost, or the reload wake an earlier image posted is still undelivered. Exactly once per stop: a later reload does not repeat a delivered wake.

elapsed_secs: u64

preview: String

Latest words of the worker (≤ 300 chars), for the wake preview.

Implementations

impl CarriedWorker

pub fn needs_wake(&self) -> bool

Whether the parent must be woken about this worker after the reload.

Trait Implementations

impl Clone for CarriedWorker

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CarriedWorker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CarriedWorker

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for CarriedWorker

impl PartialEq for CarriedWorker

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for CarriedWorker

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for CarriedWorker