Struct ShutdownCoordinator 

pub struct ShutdownCoordinator {
    phase: ShutdownPhase,
    config: ShutdownConfig,
    started_at: Option<Instant>,
    draining_actors: Vec<ActorId>,
    drained_actors: Vec<ActorId>,
    force_killed: Vec<ActorId>,
}

Manages the graceful shutdown process.

Fields

phase: ShutdownPhase

Current phase.

config: ShutdownConfig

Configuration.

started_at: Option<Instant>

When shutdown was initiated.

draining_actors: Vec<ActorId>

Actors that have been told to drain.

drained_actors: Vec<ActorId>

Actors that have confirmed drain complete.

force_killed: Vec<ActorId>

Actors that were force-killed.

Implementations

impl ShutdownCoordinator

pub fn new(config: ShutdownConfig) -> Self

Create a new shutdown coordinator.

pub fn initiate(&mut self, supervisor: &ActorSupervisor) -> Vec<ActorId>

Initiate graceful shutdown.

Returns the ordered list of actors to drain.

pub fn mark_drained(&mut self, actor: ActorId)

Mark an actor as drained (finished processing in-flight messages).

pub fn is_timeout_expired(&self) -> bool

Check if the drain timeout has expired.

pub fn tick(&mut self) -> (ShutdownPhase, Vec<ActorId>)

Advance the shutdown state machine.

Returns the current phase and any actors that need force-killing.

pub fn phase(&self) -> ShutdownPhase

Current shutdown phase.

pub fn elapsed(&self) -> Option<Duration>

Elapsed time since shutdown was initiated.

pub fn report(&self) -> ShutdownReport

Get shutdown report.

fn compute_shutdown_order(&self, supervisor: &ActorSupervisor) -> Vec<ActorId>

Compute the shutdown order based on the configured strategy.