Struct PersistedRun 

pub struct PersistedRun {
    pub version: u32,
    pub revision: u64,
    pub run: SopRun,
    pub last_progress_at: String,
    pub redacted: bool,
    pub trigger_source: SopTriggerSource,
}

Fields

version: u32

= SOP_STORE_VERSION at write time.

revision: u64

Monotonic per-run write counter; last-writer guard on rehydrate + CAS.

run: SopRun

The full run FSM state (every mode, not just deterministic).

last_progress_at: String

ISO-8601; bumped on every transition. The reaper ages out stalled Running.

redacted: bool

True once step_results/outputs have been run through the leak detector.

trigger_source: SopTriggerSource

Origin of the run, for per-source caps + audit.

Implementations

impl PersistedRun

pub fn new( run: SopRun, last_progress_at: String, trigger_source: SopTriggerSource, ) -> PersistedRun

Wrap a run at the current store version with revision 0.

pub fn run_id(&self) -> &str

The run id this envelope is keyed by.

Trait Implementations

impl Clone for PersistedRun

fn clone(&self) -> PersistedRun

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PersistedRun

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PersistedRun

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PersistedRun

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.