Enum ActionQueueEvent 

pub enum ActionQueueEvent {
    TaskReachedTerminalSuccess {
        task_id: TaskId,
    },
    RunChangedState {
        task_id: TaskId,
        new_state: RunState,
    },
    BudgetThresholdCrossed {
        task_id: TaskId,
        dimension: BudgetDimension,
        pct: u8,
    },
    CustomEvent {
        key: String,
    },
    ActorRegistered {
        actor_id: ActorId,
    },
    ActorDeregistered {
        actor_id: ActorId,
    },
    ActorHeartbeatTimeout {
        actor_id: ActorId,
    },
    LedgerEntryAppended {
        tenant_id: TenantId,
        ledger_key: String,
    },
}

An event that occurred within the dispatch loop, evaluated against subscriptions.

Variants

TaskReachedTerminalSuccess

A task reached terminal success (all runs completed).

Fields

task_id: TaskId

The task that completed.

RunChangedState

A run of the given task transitioned to a new state.

Fields

task_id: TaskId

The owning task.

new_state: RunState

The new run state.

BudgetThresholdCrossed

A budget dimension crossed a percentage threshold for the given task.

Fields

task_id: TaskId

The task whose budget crossed a threshold.

dimension: BudgetDimension

The budget dimension.

pct: u8

The percentage (0-100) at which the threshold was crossed.

CustomEvent

An application-defined custom event.

Fields

key: String

The application-defined event key.

ActorRegistered

A remote actor registered with the hub.

Fields

actor_id: ActorId

The actor that registered.

ActorDeregistered

A remote actor deregistered (explicit or heartbeat timeout).

Fields

actor_id: ActorId

The actor that deregistered.

ActorHeartbeatTimeout

A remote actor’s heartbeat timed out.

Fields

actor_id: ActorId

The actor whose heartbeat timed out.

LedgerEntryAppended

A ledger entry was appended in the platform layer.

Fields

tenant_id: TenantId

The tenant whose ledger received the entry.

ledger_key: String

The ledger key (e.g. "audit", "decision").

Trait Implementations

impl Clone for ActionQueueEvent

fn clone(&self) -> ActionQueueEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActionQueueEvent

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

Formats the value using the given formatter.

impl PartialEq for ActionQueueEvent

fn eq(&self, other: &ActionQueueEvent) -> 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 ActionQueueEvent

impl StructuralPartialEq for ActionQueueEvent