Struct ShutdownCoordinator 

pub struct ShutdownCoordinator { /* private fields */ }

Manages the graceful shutdown process.

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.