Struct InputState 

pub struct InputState {
    pub input_id: InputId,
    pub policy: Option<PolicySnapshot>,
    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 */
}

Full state of an input in the runtime.

Canonical lifecycle state (phase, terminal_outcome, history, last_run_id, last_boundary_sequence, updated_at) is owned by the embedded InputLifecycleAuthority. All transitions must flow through InputState::apply. Direct mutation of canonical fields is not possible.

Operational fields (input_id, policy, durability, idempotency_key, etc.) are caller-managed and do not participate in the state machine.

Fields

input_id: InputId

The input ID.

policy: Option<PolicySnapshot>

Policy snapshot applied to this input.

durability: Option<InputDurability>

Durability requirement (retained for recovery correctness).

idempotency_key: Option<IdempotencyKey>

Idempotency key (retained for dedup across restarts).

recovery_count: u32

Number of times this input has been recovered.

reconstruction_source: Option<ReconstructionSource>

How to reconstruct this input (for derived inputs).

persisted_input: Option<Input>

Persisted input payload used to rebuild queued work after recovery.

created_at: DateTime<Utc>

When the input was created.

Implementations

impl InputState

pub fn new_accepted(input_id: InputId) -> Self

Create a new InputState in the Accepted state.

pub fn current_state(&self) -> InputLifecycleState

Current lifecycle state.

pub fn is_terminal(&self) -> bool

Check if the input is in a terminal state.

pub fn terminal_outcome(&self) -> Option<&InputTerminalOutcome>

Terminal outcome (set when state becomes terminal).

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

State transition history.

pub fn last_run_id(&self) -> Option<&RunId>

Last run that touched this input.

pub fn last_boundary_sequence(&self) -> Option<u64>

Boundary receipt sequence for the last applied run.

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

When the input was last updated.

pub fn attempt_count(&self) -> u32

Number of times this input has been staged for a run (retry budget).

Owned by InputLifecycleAuthority. No shadow copy on InputState.

pub fn apply( &mut self, input: InputLifecycleInput, ) -> Result<InputLifecycleTransition, InputLifecycleError>

Apply a lifecycle input through the authority.

This is the ONLY way to mutate canonical lifecycle state.

pub fn can_accept(&self, input: &InputLifecycleInput) -> bool

Check if a transition would be accepted without applying it.

pub fn set_terminal_outcome(&mut self, outcome: InputTerminalOutcome)

Set the terminal outcome after a transition (for Superseded/Coalesced which need caller-provided data).

pub fn authority(&self) -> &InputLifecycleAuthority

Get a reference to the authority (for advanced read-only operations).

pub fn authority_mut(&mut self) -> &mut InputLifecycleAuthority

Get a mutable reference to the authority (for recovery paths).

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.

impl<'de> Deserialize<'de> for InputState

fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error>

Deserialize this value from the given Serde deserializer.

impl Serialize for InputState

fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.