Struct InputState 

pub struct InputState {

    pub input_id: InputId,
    pub current_state: InputLifecycleState,
    pub policy: Option<PolicySnapshot>,
    pub terminal_outcome: Option<InputTerminalOutcome>,
    pub durability: Option<InputDurability>,
    pub idempotency_key: Option<IdempotencyKey>,
    pub attempt_count: u32,
    pub recovery_count: u32,
    pub history: Vec<InputStateHistoryEntry>,
    pub reconstruction_source: Option<ReconstructionSource>,
    pub persisted_input: Option<Input>,
    pub last_run_id: Option<RunId>,
    pub last_boundary_sequence: Option<u64>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
}

Full state of an input in the runtime.

Fields

input_id: InputId

The input ID.

current_state: InputLifecycleState

Current lifecycle state.

policy: Option<PolicySnapshot>

Policy snapshot applied to this input.

terminal_outcome: Option<InputTerminalOutcome>

Terminal outcome (set when state becomes terminal).

durability: Option<InputDurability>

Durability requirement (retained for recovery correctness).

idempotency_key: Option<IdempotencyKey>

Idempotency key (retained for dedup across restarts).

attempt_count: u32

Number of times this input has been applied (for crash-loop detection).

recovery_count: u32

Number of times this input has been recovered.

history: Vec<InputStateHistoryEntry>

State transition history.

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.

last_run_id: Option<RunId>

Last run that touched this input.

last_boundary_sequence: Option<u64>

Boundary receipt sequence for the last applied run.

created_at: DateTime<Utc>

When the input was created.

updated_at: DateTime<Utc>

When the input was last updated.

Implementations

impl InputState

pub fn new_accepted(input_id: InputId) -> Self

Create a new InputState in the Accepted state.

pub fn is_terminal(&self) -> bool

Check if the input is in a terminal state.

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: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for InputState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.