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

config: ShutdownConfig

started_at: Option<Instant>

draining_actors: Vec<ActorId>

drained_actors: Vec<ActorId>

force_killed: Vec<ActorId>

Implementations

impl ShutdownCoordinator

pub fn new(config: ShutdownConfig) -> ShutdownCoordinator

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.