Struct ShutdownCoordinator 

pub struct ShutdownCoordinator { /* private fields */ }

Manages the shutdown drain process for a coordinator.

Implementations

impl ShutdownCoordinator

pub fn new(drain_timeout: Duration) -> Self

Create a new shutdown coordinator with the given drain timeout.

pub fn drain_timeout(&self) -> Duration

The configured drain timeout.

pub fn await_signal(&self, signal: &ShutdownSignal) -> bool

Wait for a shutdown signal, then return. The caller is responsible for draining sessions and cleaning up.