Struct InputState 

pub struct InputState {
    pub input_id: InputId,
    pub history: Vec<InputStateHistoryEntry>,
    pub updated_at: DateTime<Utc>,
    pub policy: Option<PolicySnapshot>,
    pub runtime_semantics: Option<RuntimeInputSemantics>,
    pub directed_run_started_attribution: Option<DirectedRunStartedAttribution>,
    pub durability: Option<InputDurability>,
    pub idempotency_key: Option<IdempotencyKey>,
    pub recovery_count: u32,
    pub reconstruction_source: Option<ReconstructionSource>,
    pub persisted_input: Option<Input>,
    pub created_at: DateTime<Utc>,
    /* private fields */
}

Fields

input_id: InputId

history: Vec<InputStateHistoryEntry>

updated_at: DateTime<Utc>

policy: Option<PolicySnapshot>

runtime_semantics: Option<RuntimeInputSemantics>

Runtime-stamped run semantics captured at admission and persisted so recovery does not reclassify execution kind from payload shape.

directed_run_started_attribution: Option<DirectedRunStartedAttribution>

Typed input family plus digest of the exact canonical RunStarted content for a directed FlowStep/Peer input. This compact witness survives terminal payload retirement and binds host-journal reconstruction without retaining the original O(payload) input.

durability: Option<InputDurability>

idempotency_key: Option<IdempotencyKey>

recovery_count: u32

reconstruction_source: Option<ReconstructionSource>

persisted_input: Option<Input>

Original ingress material retained only while crash redelivery, durable-tail attribution, or directed-terminal materialization may still need it. Authoritative terminal commits retire this payload after completion/publication obligations close; terminal history is carried by the seed and receipts above.

created_at: DateTime<Utc>

Implementations

impl InputState

pub fn new_accepted(input_id: InputId) -> Self

Create a fresh InputState. Paired DSL state starts in the Accepted phase via InputStateSeed::new_accepted; callers that need the bundle use StoredInputState::new_accepted.

pub fn history(&self) -> &[InputStateHistoryEntry]

pub fn updated_at(&self) -> DateTime<Utc>

Trait Implementations

impl Clone for InputState

fn clone(&self) -> InputState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InputState

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

Formats the value using the given formatter.