Struct WorkloopRecord 

pub struct WorkloopRecord {
    pub loop_id: WorkflowId,
    pub namespace: String,
    pub spec: WorkloopSpec,
    pub window_seq: u64,
    pub next_window_at: Option<DateTime<Utc>>,
    pub next_check_at: Option<DateTime<Utc>>,
    pub last_iteration_closed_window: Option<u64>,
    pub invariant_health: BTreeMap<String, InvariantHealthState>,
    pub registered_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
}

One durable workloop registration: the declared spec plus the engine’s cadence and health bookkeeping.

Fields

loop_id: WorkflowId

The loop’s workflow identity (primary key).

namespace: String

Namespace the loop runs in.

spec: WorkloopSpec

The declared spec — re-validated on decode by WorkloopSpec’s own serde boundary, so a stored record cannot drift out of its declared invariants.

window_seq: u64

Sequence number of the last cadence window that fired (0 = none yet; fired windows are one-based).

next_window_at: Option<DateTime<Utc>>

When the next cadence window fires; None on a signal-only loop.

next_check_at: Option<DateTime<Utc>>

When the sweeper must next evaluate this loop: the minimum of next_window_at and the earliest duration-form tolerance deadline. None = nothing left to check engine-side (a signal-only loop whose alarms are all latched); sleeping loops with a future value cost the sweeper nothing.

last_iteration_closed_window: Option<u64>

The window sequence of the last recorded iteration close, if any — what the dead-man switch compares against the fired window (R4.3).

invariant_health: BTreeMap<String, InvariantHealthState>

Per-invariant health accounting, keyed by invariant name.

registered_at: DateTime<Utc>

When the loop was registered.

updated_at: DateTime<Utc>

Most recent mutation instant.

Implementations

impl WorkloopRecord

pub fn encode(&self) -> Result<Vec<u8>, StoreError>

Encode the stable backend-neutral representation.

Errors

Returns StoreError::Serialization when serialization fails.

pub fn decode(bytes: &[u8]) -> Result<Self, StoreError>

Decode and re-validate a stored representation (the spec’s serde boundary re-runs every declaration check).

Errors

Returns StoreError::Serialization for malformed bytes or a spec that no longer satisfies its declaration invariants.

Trait Implementations

impl Clone for WorkloopRecord

fn clone(&self) -> WorkloopRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkloopRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkloopRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for WorkloopRecord

impl PartialEq for WorkloopRecord

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for WorkloopRecord

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 WorkloopRecord