#[non_exhaustive]pub struct SuspendedExecutionEntry {
pub execution_id: ExecutionId,
pub suspended_at_ms: i64,
pub reason: String,
}Expand description
One entry in a ListSuspendedPage — a suspended execution and
the reason it is blocked, answering an operator’s “what’s this
waiting on?” without a follow-up round-trip.
reason carries the free-form reason_code recorded by the
suspending worker at lua/suspension.lua (HSET suspension:current reason_code). It is a String, not a closed enum: the suspension
pipeline accepts arbitrary caller-supplied codes (typical values
are "signal", "timer", "children", "join", but consumers
embed bespoke codes). A future enum projection can classify
known codes once the set is frozen; until then, callers that want
structured routing MUST match on the string explicitly.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.execution_id: ExecutionIdExecution currently in lifecycle_phase=suspended.
suspended_at_ms: i64Score stored on the per-lane suspended ZSET — the scheduled
timeout_at in milliseconds, or the 9999999999999 sentinel
when no timeout was set (see lua/suspension.lua).
reason: StringFree-form reason code from suspension:current.reason_code.
Empty string when the suspension hash is absent or does not
carry a reason_code field (older records). See the struct
rustdoc for the deliberate-String rationale.
Implementations§
Source§impl SuspendedExecutionEntry
impl SuspendedExecutionEntry
Sourcepub fn new(
execution_id: ExecutionId,
suspended_at_ms: i64,
reason: String,
) -> Self
pub fn new( execution_id: ExecutionId, suspended_at_ms: i64, reason: String, ) -> Self
Construct a new entry. Preferred over direct field init for
#[non_exhaustive] forward-compat.
Trait Implementations§
Source§impl Clone for SuspendedExecutionEntry
impl Clone for SuspendedExecutionEntry
Source§fn clone(&self) -> SuspendedExecutionEntry
fn clone(&self) -> SuspendedExecutionEntry
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more