Struct ProgressState 

pub struct ProgressState { /* private fields */ }

Mutable progress buffer shared between handler and heartbeat service.

Implementations

impl ProgressState

pub fn new(initial: Option<Value>) -> Self

pub fn has_pending(&self) -> bool

Whether there is a pending update that has not been acked.

pub fn latest(&self) -> Option<&Value>

Get a reference to the latest progress value.

pub fn clone_latest(&self) -> Option<Value>

Clone the latest progress value.

pub fn set_progress(&mut self, percent: u8, message: Option<&str>)

Set progress: percent (clamped 0-100), optional message. Preserves existing metadata sub-object.

pub fn merge_metadata(&mut self, updates: &Map<String, Value>) -> bool

Shallow-merge keys into the metadata sub-object. Returns false if the existing metadata sub-object is a non-object type (no-op).

pub fn pending_snapshot(&self) -> Option<(Value, u64)>

Snapshot for flush: returns (value, generation) if there is a pending update.

pub fn ack(&mut self, generation: u64)

Advance acked_generation after a successful flush. Only advances if generation is newer than current acked.

Trait Implementations

impl Debug for ProgressState

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

Formats the value using the given formatter.