Struct RunSnapshot 

pub struct RunSnapshot {

    pub run_id: String,
    pub definition_digest: String,
    pub semantics_digest: String,
    pub status: StrategyRunStatus,
    pub sequence: u64,
    pub input: Value,
    pub active_states: BTreeSet<String>,
    pub completed_states: BTreeSet<String>,
    pub state_visits: BTreeMap<String, u64>,
    pub join_arrivals: BTreeMap<String, JoinLedger>,
    pub input_plan: InputPlan,
    pub shared: BTreeMap<String, SharedResourceState>,
    pub bindings: BTreeMap<String, InputBinding>,
    pub actor_sessions: BTreeMap<String, String>,
    pub slot_ordinals: BTreeMap<String, u8>,
    pub slot_candidate_counts: BTreeMap<String, u8>,
    pub attempt_lineage: BTreeMap<String, u8>,
    pub merge_sources: BTreeMap<String, String>,
    pub fallbacks: Vec<FallbackReceipt>,
    pub conversation_id: Option<String>,
    pub assistant_membership_id: Option<String>,
    pub route_receipt: Option<Value>,
    pub cwd: Option<String>,
    pub pending_callbacks: Vec<PendingCallback>,
    pub commands: BTreeMap<String, RunCommand>,
    pub diagnostic_code: Option<String>,
}

Fields

run_id: String

definition_digest: String

semantics_digest: String

status: StrategyRunStatus

sequence: u64

input: Value

active_states: BTreeSet<String>

completed_states: BTreeSet<String>

state_visits: BTreeMap<String, u64>

join_arrivals: BTreeMap<String, JoinLedger>

Per-visit arrivals, so an old visit of a predecessor can never satisfy a new join round.

input_plan: InputPlan

The run’s declared causal input plan.

shared: BTreeMap<String, SharedResourceState>

Versioned shared state. Reading it without naming a revision is not expressible: the only readers are bindings, and a binding records one.

bindings: BTreeMap<String, InputBinding>

The exact binding every entered node visit received.

actor_sessions: BTreeMap<String, String>

slot_ordinals: BTreeMap<String, u8>

slot_candidate_counts: BTreeMap<String, u8>

attempt_lineage: BTreeMap<String, u8>

merge_sources: BTreeMap<String, String>

fallbacks: Vec<FallbackReceipt>

conversation_id: Option<String>

The Conversation this run answers to, when it is conversation-bound.

assistant_membership_id: Option<String>

The Assistant Membership this run answers to.

route_receipt: Option<Value>

The committed route receipt recorded at admission.

cwd: Option<String>

pending_callbacks: Vec<PendingCallback>

Callback-mode edges whose targets wait for the master agent’s decision, in the deterministic order the waits were entered. The decision event always settles the first entry.

commands: BTreeMap<String, RunCommand>

diagnostic_code: Option<String>

Implementations

impl RunSnapshot

pub fn empty( run_id: impl Into<String>, definition_digest: impl Into<String>, semantics_digest: impl Into<String>, ) -> Self

Trait Implementations

impl Clone for RunSnapshot

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 RunSnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RunSnapshot

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RunSnapshot

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RunSnapshot

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 RunSnapshot