Enum EventKind 

pub enum EventKind {
    SubscriberPanicked,
    SubscriberOverflow,
    ShutdownRequested,
    AllStoppedWithinGrace,
    GraceExceeded,
    TaskStarting,
    TaskStopped,
    TaskFailed,
    TimeoutHit,
    BackoffScheduled,
    TaskAddRequested,
    TaskAdded,
    TaskRemoveRequested,
    TaskRemoved,
    ActorExhausted,
    ActorDead,
    ControllerRejected,
    ControllerSubmitted,
    ControllerSlotTransition,
}

Classification of runtime events.

Variants

SubscriberPanicked

Subscriber panicked during event processing.

Sets:

• task: subscriber name
• reason: panic info/message
• at: wall-clock timestamp
• seq: global sequence

SubscriberOverflow

Subscriber dropped an event (queue full or worker closed).

Sets:

• task: subscriber name
• reason: reason string (e.g., “full”, “closed”)
• at: wall-clock timestamp
• seq: global sequence

ShutdownRequested

Shutdown requested (OS signal observed).

Sets:

• at: wall-clock timestamp
• seq: global sequence

AllStoppedWithinGrace

All tasks stopped within configured grace period.

Sets:

• at: wall-clock timestamp
• seq: global sequence

GraceExceeded

Grace period exceeded; some tasks did not stop in time.

Sets:

• at: wall-clock timestamp
• seq: global sequence

TaskStarting

Task is starting an attempt.

Sets:

• task: task name
• attempt: attempt number (1-based, per actor)
• at: wall-clock timestamp
• seq: global sequence

TaskStopped

Task has stopped (finished successfully or was cancelled gracefully).

Sets:

• task: task name
• at: wall-clock timestamp
• seq: global sequence

TaskFailed

Task failed with a (non-fatal) error for this attempt.

Sets:

• task: task name
• attempt: attempt number
• reason: failure message
• at: wall-clock timestamp
• seq: global sequence

TimeoutHit

Task exceeded its configured timeout for this attempt.

Sets:

• task: task name
• attempt: attempt number
• timeout_ms: configured attempt timeout (ms)
• at: wall-clock timestamp
• seq: global sequence

BackoffScheduled

Next attempt scheduled (after success or failure).

Sets:

• task: task name
• attempt: previous attempt number
• delay_ms: delay before the next attempt (ms)
• backoff_source: Success or Failure
• reason: last failure message (only for failure-driven backoff)
• at: wall-clock timestamp
• seq: global sequence

TaskAddRequested

Request to add a new task to the supervisor.

Sets:

• task: logical task name
• spec (private): task spec to spawn
• at: wall-clock timestamp
• seq: global sequence

TaskAdded

Task was successfully added (actor spawned and registered).

Sets:

• task: task name
• at: wall-clock timestamp
• seq: global sequence

TaskRemoveRequested

Request to remove a task from the supervisor.

Sets:

• task: task name
• at: wall-clock timestamp
• seq: global sequence

TaskRemoved

Task was removed from the supervisor (after join/cleanup).

Sets:

• task: task name
• at: wall-clock timestamp
• seq: global sequence

ActorExhausted

Actor exhausted its restart policy and will not restart.

Emitted when:

• RestartPolicy::Never → task completed (success or handled case)
• RestartPolicy::OnFailure → task completed successfully

Sets:

• task: task name
• attempt: last attempt number
• reason: optional message
• at: wall-clock timestamp
• seq: global sequence

ActorDead

Actor terminated permanently due to a fatal error.

Emitted when:

• Task returned TaskError::Fatal
• (Future) max retries exceeded

Sets:

• task: task name
• attempt: last attempt number
• reason: fatal error message
• at: wall-clock timestamp
• seq: global sequence

ControllerRejected

Controller submission rejected (queue full, add failed, etc).

Sets:

• task: slot name
• reason: rejection reason (“queue_full”, “add_failed: …”, etc)

ControllerSubmitted

Task submitted successfully to controller slot.

Sets:

• task: slot name
• reason: “admission={admission} status={status} depth={N}”

ControllerSlotTransition

Slot transitioned state (Running → Terminating, etc).

Sets:

• task: slot name
• reason: “running→terminating” (Replace), “terminating→idle”, etc

Trait Implementations

impl Clone for EventKind

fn clone(&self) -> EventKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventKind

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

Formats the value using the given formatter.

impl PartialEq for EventKind

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

impl Eq for EventKind

impl StructuralPartialEq for EventKind