Struct WatchPage 

pub struct WatchPage {
    pub handle_id: String,
    pub subagent_id: u64,
    pub agent_name: String,
    pub model: String,
    pub status: String,
    pub steerable: bool,
    pub next_seq: u64,
    pub truncated: bool,
    pub more: bool,
    pub events: Vec<WatchEvent>,
    pub at_ms: Vec<u64>,
    pub now_ms: Option<u64>,
}

One page of a worker’s journal (SessionQuery::SubagentWatch reply).

Fields

handle_id: String

subagent_id: u64

agent_name: String

model: String

The model the worker runs on. Empty from older peers.

status: String

running, completed, cancelled, timed_out or failed.

steerable: bool

The worker accepts steering (it is running and has a steer channel).

next_seq: u64

Ask for since = next_seq next time.

truncated: bool

Entries before the requested since were dropped (journal cap).

more: bool

More entries are ready right now (this page hit its byte budget).

events: Vec<WatchEvent>

at_ms: Vec<u64>

When each of events was recorded (same length), in ms on the journal’s clock. A coalesced delta entry carries its first part’s time. Empty from older peers: clients then time events by arrival.

now_ms: Option<u64>

The journal’s clock when this page was read, so a client can turn at_ms into “this long ago”. Absent from older peers.

Implementations

impl WatchPage

pub fn without_tool_queue(self) -> WatchPage

This page for a client that did not ask for queue entries (SessionQuery::SubagentWatch { tool_queue: false }, i.e. every client that predates them): WatchEvent has no #[serde(other)], so such a client would fail to decode the whole page.

Trait Implementations

impl Clone for WatchPage

fn clone(&self) -> WatchPage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WatchPage

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

Formats the value using the given formatter.

impl Default for WatchPage

fn default() -> WatchPage

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for WatchPage

fn deserialize<__D>( __deserializer: __D, ) -> Result<WatchPage, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WatchPage

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for WatchPage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WatchPage