Enum ContentionKind 

#[non_exhaustive]
pub enum ContentionKind {
    UseClaimResumedExecution,
    NotAResumedExecution,
    ExecutionNotLeaseable,
    LeaseConflict,
    InvalidClaimGrant,
    ClaimGrantExpired,
    NoEligibleExecution,
    WaitpointNotFound,
    WaitpointPendingUseBufferScript,
    StaleGraphRevision,
    ExecutionNotActive {
        terminal_outcome: String,
        lease_epoch: String,
        lifecycle_phase: String,
        attempt_id: String,
    },
    ExecutionNotEligible,
    ExecutionNotInEligibleSet,
    ExecutionNotReclaimable,
    NoActiveLease,
    RateLimitExceeded,
    ConcurrencyLimitExceeded,
    RetryExhausted,
}

Contention sub-kinds (retryable per RFC-010 §10.7). Caller should re-dispatch or re-read and retry.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

UseClaimResumedExecution

Re-dispatch to claim_resumed_execution.

NotAResumedExecution

Re-dispatch to claim_execution.

ExecutionNotLeaseable

State changed since grant. Request new grant.

LeaseConflict

Another worker holds lease. Request a different execution.

InvalidClaimGrant

Grant missing/mismatched. Request new grant.

ClaimGrantExpired

Grant TTL elapsed. Request new grant.

NoEligibleExecution

No execution currently available.

WaitpointNotFound

Waitpoint may not exist yet. Retry with backoff.

WaitpointPendingUseBufferScript

Route to buffer_signal_for_pending_waitpoint.

StaleGraphRevision

Graph revision changed. Re-read adjacency, retry.

ExecutionNotActive

Execution is not in active state (lease superseded, etc.) Carries the Lua-side detail payload for replay reconciliation.

Fields

terminal_outcome: String

lease_epoch: String

lifecycle_phase: String

attempt_id: String

ExecutionNotEligible

State changed. Scheduler skips.

ExecutionNotInEligibleSet

Removed by another scheduler.

ExecutionNotReclaimable

Already reclaimed/cancelled. Skip.

NoActiveLease

Target has no active lease (already revoked/expired/unowned).

RateLimitExceeded

Window full; caller should backoff retry_after_ms.

ConcurrencyLimitExceeded

Concurrency cap hit.

RetryExhausted

Returned after 3 attempts of a SERIALIZABLE transaction in Postgres (cancel_flow, deliver_signal, suspend). Caller falls back to the appropriate reconciler.

Classified Retryable via the blanket Contention(_) arm so consumer retry-loops don’t treat it as terminal; the reconciler backstop catches repeat exhaustion.

Trait Implementations

impl Clone for ContentionKind

fn clone(&self) -> ContentionKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContentionKind

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

Formats the value using the given formatter.

impl PartialEq for ContentionKind

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ContentionKind

impl StructuralPartialEq for ContentionKind