Enum SupervisorEvent 

pub enum SupervisorEvent {
    TaskRegistered {
        id: String,
        name: String,
    },
    TaskSetupStarted {
        id: String,
        name: String,
    },
    TaskSetupCompleted {
        id: String,
        name: String,
    },
    TaskSetupFailed {
        id: String,
        name: String,
        error: String,
    },
    TaskStarted {
        id: String,
        name: String,
        attempt: usize,
    },
    TaskFinished {
        id: String,
        name: String,
        attempt: usize,
    },
    TaskFailed {
        id: String,
        name: String,
        attempt: usize,
        error: String,
    },
    TaskPanicked {
        id: String,
        name: String,
        attempt: usize,
        panic_info: String,
    },
    TaskBackoff {
        id: String,
        name: String,
        attempt: usize,
        delay: Duration,
    },
    TaskStopped {
        id: String,
        name: String,
    },
    TaskPaused {
        id: String,
        name: String,
    },
    TaskResumed {
        id: String,
        name: String,
    },
    TaskMaxAttemptsReached {
        id: String,
        name: String,
        attempts: usize,
    },
    TaskRestartPrevented {
        id: String,
        name: String,
        attempt: usize,
    },
    TaskRemoved {
        id: String,
        name: String,
    },
    CircuitBreakerTripped {
        id: String,
        name: String,
        consecutive_failures: usize,
    },
    CircuitBreakerReset {
        id: String,
        name: String,
    },
    CircuitBreakerHalfOpen {
        id: String,
        name: String,
    },
    SupervisorShutdownStarted,
    SupervisorShutdownCompleted,
    TaskConfigUpdated {
        id: String,
        name: String,
        field: String,
        old_value: String,
        new_value: String,
    },
}

Lifecycle events emitted by the supervisor

Variants

TaskRegistered

A new task was registered

Fields

id: String

name: String

TaskSetupStarted

A task started its setup phase

Fields

id: String

name: String

TaskSetupCompleted

A task completed its setup phase successfully

Fields

id: String

name: String

TaskSetupFailed

A task setup failed

Fields

id: String

name: String

error: String

TaskStarted

A task’s execution started (or restarted)

Fields

id: String

name: String

attempt: usize

TaskFinished

A task’s execution finished successfully

Fields

id: String

name: String

attempt: usize

TaskFailed

A task’s execution failed with an error

Fields

id: String

name: String

attempt: usize

error: String

TaskPanicked

A task’s execution panicked

Fields

id: String

name: String

attempt: usize

panic_info: String

TaskBackoff

A task is entering backoff before restart

Fields

id: String

name: String

attempt: usize

delay: Duration

TaskStopped

A task was manually stopped

Fields

id: String

name: String

TaskPaused

A task was paused

Fields

id: String

name: String

TaskResumed

A task was resumed

Fields

id: String

name: String

TaskMaxAttemptsReached

A task reached its maximum restart attempts

Fields

id: String

name: String

attempts: usize

TaskRestartPrevented

A task restart was prevented by a hook

Fields

id: String

name: String

attempt: usize

TaskRemoved

A task was removed from the supervisor

Fields

id: String

name: String

CircuitBreakerTripped

A task’s circuit breaker tripped (opened)

Fields

id: String

name: String

consecutive_failures: usize

CircuitBreakerReset

A task’s circuit breaker was reset (closed)

Fields

id: String

name: String

CircuitBreakerHalfOpen

A task’s circuit breaker entered half-open state

Fields

id: String

name: String

SupervisorShutdownStarted

Supervisor is shutting down

SupervisorShutdownCompleted

Supervisor completed shutdown

TaskConfigUpdated

A task’s configuration was updated at runtime

Fields

id: String

name: String

field: String

old_value: String

new_value: String

Trait Implementations

impl Clone for SupervisorEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SupervisorEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SupervisorEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SupervisorEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.