Enum ScriptError 

#[non_exhaustive]
pub enum ScriptError {
    StaleLease,
    LeaseExpired,
    LeaseRevoked,
    ExecutionNotActive,
    NoActiveLease,
    ActiveAttemptExists,
    UseClaimResumedExecution,
    NotAResumedExecution,
    ExecutionNotLeaseable,
    LeaseConflict,
    InvalidClaimGrant,
    ClaimGrantExpired,
    NoEligibleExecution,
    BudgetExceeded,
    BudgetSoftExceeded,
    ExecutionNotSuspended,
    AlreadySuspended,
    WaitpointClosed,
    WaitpointNotFound,
    TargetNotSignalable,
    WaitpointPendingUseBufferScript,
    DuplicateSignal,
    PayloadTooLarge,
    SignalLimitExceeded,
    InvalidWaitpointKey,
    InvalidLeaseForSuspend,
    ResumeConditionNotMet,
    WaitpointNotPending,
    PendingWaitpointExpired,
    InvalidWaitpointForExecution,
    WaitpointAlreadyExists,
    WaitpointNotOpen,
    ExecutionNotTerminal,
    MaxReplaysExhausted,
    StreamClosed,
    StaleOwnerCannotAppend,
    RetentionLimitExceeded,
    ExecutionNotEligible,
    ExecutionNotInEligibleSet,
    GrantAlreadyExists,
    ExecutionNotReclaimable,
    InvalidDependency,
    StaleGraphRevision,
    ExecutionAlreadyInFlow,
    CycleDetected,
    FlowNotFound,
    ExecutionNotInFlow,
    DependencyAlreadyExists,
    SelfReferencingEdge,
    FlowAlreadyTerminal,
    DepsNotSatisfied,
    NotBlockedByDeps,
    NotRunnable,
    Terminal,
    InvalidBlockingReason,
    OkAlreadyApplied,
    AttemptNotFound,
    AttemptNotInCreatedState,
    AttemptNotStarted,
    AttemptAlreadyTerminal,
    ExecutionNotFound,
    ExecutionNotEligibleForAttempt,
    ReplayNotAllowed,
    MaxRetriesExhausted,
    StreamNotFound,
    StreamAlreadyClosed,
    InvalidFrameType,
    InvalidOffset,
    Unauthorized,
    BudgetNotFound,
    InvalidBudgetScope,
    BudgetAttachConflict,
    BudgetOverrideNotAllowed,
    QuotaPolicyNotFound,
    RateLimitExceeded,
    ConcurrencyLimitExceeded,
    QuotaAttachConflict,
    InvalidQuotaSpec,
    InvalidInput(String),
    CapabilityMismatch(String),
    InvalidCapabilities(String),
    InvalidPolicyJson(String),
    WaitpointNotTokenBound,
    InvalidKid,
    InvalidSecretHex,
    InvalidGraceMs,
    RotationConflict(String),
    Valkey(Error),
    Parse(String),
}

All error codes returned by FlowFabric Valkey Functions. Matches RFC-010 §10.7 exactly.

Does not derive Serialize/Deserialize/PartialEq/Eq/Hash because the Valkey variant wraps ferriskey::Error, which implements none of those. Call sites compare via matches!/.class() rather than ==, so this is not a regression.

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.

StaleLease

Stop. Lease superseded by reclaim.

LeaseExpired

Stop. Lease TTL elapsed.

LeaseRevoked

Stop. Operator revoked.

ExecutionNotActive

Stop. Check enriched return: epoch match + success = your completion won.

NoActiveLease

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

ActiveAttemptExists

Bug. Active attempt already exists.

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 different execution.

InvalidClaimGrant

Grant missing/mismatched. Request new grant.

ClaimGrantExpired

Grant TTL elapsed. Request new grant.

NoEligibleExecution

Backoff 100ms-1s, retry.

BudgetExceeded

Immediate stop. Call fail_execution(budget_exceeded).

BudgetSoftExceeded

Log warning. Continue.

ExecutionNotSuspended

Already resumed/cancelled. No-op.

AlreadySuspended

Open suspension exists. No-op.

WaitpointClosed

Signal too late. Return to caller.

WaitpointNotFound

Waitpoint may not exist yet. Retry with backoff.

TargetNotSignalable

Execution not suspended, no pending waitpoint.

WaitpointPendingUseBufferScript

Route to buffer_signal_for_pending_waitpoint.

DuplicateSignal

Dedup. Return existing signal_id.

PayloadTooLarge

Payload > 64KB.

SignalLimitExceeded

Max signals reached.

InvalidWaitpointKey

MAC failed. Token invalid or expired.

InvalidLeaseForSuspend

Invalid lease for suspend.

ResumeConditionNotMet

Conditions not satisfied.

WaitpointNotPending

Waitpoint not in pending state.

PendingWaitpointExpired

Pending waitpoint expired before suspension committed.

InvalidWaitpointForExecution

Waitpoint/execution binding mismatch.

WaitpointAlreadyExists

Waitpoint already exists (pending or active).

WaitpointNotOpen

Waitpoint not in an open state.

ExecutionNotTerminal

Cannot replay non-terminal.

MaxReplaysExhausted

Replay limit reached.

StreamClosed

Attempt terminal. No appends.

StaleOwnerCannotAppend

Lease mismatch on stream append.

RetentionLimitExceeded

Frame > 64KB.

ExecutionNotEligible

State changed. Scheduler skips.

ExecutionNotInEligibleSet

Another scheduler got it. Skip.

GrantAlreadyExists

Grant already issued. Skip.

ExecutionNotReclaimable

Already reclaimed/cancelled. Skip.

InvalidDependency

Edge doesn’t exist.

StaleGraphRevision

Re-read adjacency, retry.

ExecutionAlreadyInFlow

Already in another flow.

CycleDetected

Edge would create cycle.

FlowNotFound

Flow does not exist.

ExecutionNotInFlow

Execution is not a member of the specified flow.

DependencyAlreadyExists

Dependency edge already exists.

SelfReferencingEdge

Self-referencing edge (upstream == downstream).

FlowAlreadyTerminal

Flow is already in a terminal state (cancelled/completed/failed).

DepsNotSatisfied

Dependencies not yet satisfied (for promote_blocked_to_eligible).

NotBlockedByDeps

Not blocked by dependencies (for promote/unblock).

NotRunnable

Execution not runnable (for block/unblock/promote).

Terminal

Execution is terminal (for block/promote).

InvalidBlockingReason

Invalid blocking reason for block_execution_for_admission.

OkAlreadyApplied

Usage seq already processed. No-op.

AttemptNotFound

Attempt index doesn’t exist.

AttemptNotInCreatedState

Attempt not created. Internal sequencing error.

AttemptNotStarted

Attempt not running.

AttemptAlreadyTerminal

Already ended. No-op.

ExecutionNotFound

Execution doesn’t exist.

ExecutionNotEligibleForAttempt

Wrong state for new attempt.

ReplayNotAllowed

Not terminal or limit reached.

MaxRetriesExhausted

Retry limit reached.

StreamNotFound

No frames appended yet. Normal for new attempts.

StreamAlreadyClosed

Already closed. No-op.

InvalidFrameType

Unrecognized frame type.

InvalidOffset

Invalid Stream ID.

Unauthorized

Auth failed.

BudgetNotFound

Budget doesn’t exist.

InvalidBudgetScope

Malformed scope.

BudgetAttachConflict

Budget already attached or conflicts.

BudgetOverrideNotAllowed

No operator privileges.

QuotaPolicyNotFound

Quota doesn’t exist.

RateLimitExceeded

Window full. Backoff retry_after_ms.

ConcurrencyLimitExceeded

Concurrency cap hit.

QuotaAttachConflict

Quota already attached.

InvalidQuotaSpec

Malformed quota definition.

InvalidInput(String)

Caller supplied a non-numeric value where a number is required.

CapabilityMismatch(String)

Worker caps do not satisfy execution’s required_capabilities. Payload is the sorted-CSV of missing tokens. RETRYABLE: execution stays in the eligible ZSET for a worker with matching caps.

InvalidCapabilities(String)

Caller supplied a malformed or oversized capability list (defense against 1MB-repeated-token payloads). TERMINAL from this call’s perspective: the caller must fix its config before retrying.

InvalidPolicyJson(String)

ff_create_execution received a policy_json that is not valid JSON or whose routing_requirements is structurally wrong (not an object, required_capabilities not an array). TERMINAL: the submitter must send a well-formed policy. Kept distinct from invalid_capabilities so tooling can distinguish “payload never parsed” from “payload parsed but contents rejected”.

WaitpointNotTokenBound

Pending waitpoint record is missing its HMAC token field. Returned by ff_suspend_execution when activating a pending waitpoint whose waitpoint_token field is absent or empty (pre-HMAC-upgrade record or a corrupted write). Surfacing this at activation time instead of letting every subsequent signal delivery silently reject with missing_token makes the degraded state visible at the right step. TERMINAL: the pending waitpoint is unrecoverable without a fresh one.

InvalidKid

Rotation FCALL: new_kid empty or contains :.

InvalidSecretHex

Rotation FCALL: new_secret_hex empty, odd length, or non-hex.

InvalidGraceMs

Rotation FCALL: grace_ms not a non-negative integer.

RotationConflict(String)

Rotation FCALL: same kid already installed with a different secret. Carries the kid so operators see which one conflicted. Refuse — the operator must pick a fresh kid or restore the stored secret.

Valkey(Error)

Valkey connection or protocol error. Preserves ferriskey::ErrorKind so callers can distinguish transient/permanent/NOSCRIPT/MOVED/etc.

Parse(String)

Failed to parse FCALL return value.

Implementations

impl ScriptError

pub fn valkey_kind(&self) -> Option<ErrorKind>

Returns the underlying ferriskey ErrorKind if this is a transport error.

pub fn class(&self) -> ErrorClass

Classify this error for SDK action dispatch.

pub fn from_code(code: &str) -> Option<Self>

Parse an error code string (from Lua return) into a ScriptError.

pub fn from_code_with_detail(code: &str, detail: &str) -> Option<Self>

Like from_code, but preserves the Lua-side detail payload for variants that carry a String. Lua returns {0, code, detail} for capability_mismatch (missing CSV), invalid_capabilities (bounds reason), invalid_input (field name). The plain from_code discards the detail; callers that log or surface the detail should use this variant. Returns None only when the code is unknown — the detail is always folded in when applicable.

Trait Implementations

impl Debug for ScriptError

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

Formats the value using the given formatter.

impl Display for ScriptError

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

Formats the value using the given formatter.

impl Error for ScriptError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl From<Error> for ScriptError

fn from(source: Error) -> Self

Converts to this type from the input type.