mlua-swarm 0.1.2

Swarm engine host built on mlua — long-running stateful runtime with Role/Verb gate, CapToken, 3-stage pipeline, and Middleware overlay.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//! Engine error type.

use crate::types::{Role, Verb};
use thiserror::Error;

/// All ways an engine operation can fail.
#[derive(Debug, Error)]
pub enum EngineError {
    /// A required lock was busy and the operation gave up without retrying.
    #[error("lock busy ({0})")]
    LockBusy(&'static str),

    /// A required lock was still busy after the configured retry budget was
    /// exhausted.
    #[error("lock busy after retry ({0})")]
    LockBusyAfterRetry(&'static str),

    /// The presented `CapToken`'s HMAC signature did not verify.
    #[error("token signature invalid")]
    BadSignature,

    /// The presented `CapToken` is past its `expire_at`.
    #[error("token expired")]
    TokenExpired,

    /// The presented `CapToken` has no uses left (`max_uses` budget spent).
    #[error("token uses exhausted")]
    TokenUsesExhausted,

    /// No server-side record exists for the token's nonce.
    #[error("token not found in store (nonce={0})")]
    TokenNotFound(String),

    /// The token's `Role` is not allow-listed for the requested `Verb` (see
    /// `RoleVerbGate`).
    #[error("role violation: role={role:?} verb={verb:?}")]
    RoleViolation {
        /// The role the token was minted for.
        role: Role,
        /// The verb that was rejected.
        verb: Verb,
    },

    /// No task exists with the given id.
    #[error("task not found: {0}")]
    TaskNotFound(String),

    /// No session is attached to the task.
    #[error("session not found")]
    SessionNotFound,

    /// The resume key presented does not match any pending resume point.
    #[error("resume key not found")]
    ResumeKeyNotFound,

    /// A generic named resource (other than task/session/token) was not
    /// found.
    #[error("resource not found: {0}")]
    ResourceNotFound(String),

    /// The requested state transition is not valid from the task's current
    /// state.
    #[error("invalid state transition: {0}")]
    InvalidTransition(String),

    /// Dispatching an attempt failed; the string carries the underlying
    /// reason.
    #[error("dispatch failed: {0}")]
    DispatchFailed(String),

    /// A poll operation exceeded its deadline without observing completion.
    #[error("poll timeout")]
    PollTimeout,

    /// The task was cancelled.
    #[error("cancelled")]
    Cancelled,

    /// A sub-task spawn would exceed the configured `max_spawn_depth`.
    #[error("spawn depth exceeded: {current} >= max {max}")]
    SpawnDepthExceeded {
        /// The depth that would result from this spawn.
        current: u32,
        /// The configured maximum allowed depth.
        max: u32,
    },

    /// The presented token is bound to a different task than the one
    /// referenced by the call.
    #[error("token task mismatch: token bound to {bound}, arg was {arg}")]
    TokenTaskMismatch {
        /// The task id the token is actually bound to.
        bound: String,
        /// The task id that was passed in the call.
        arg: String,
    },

    /// Catch-all for invariant violations that don't have a dedicated
    /// variant yet.
    #[error("internal: {0}")]
    Internal(String),
}