Struct GracefulShutdown 

pub struct GracefulShutdown { /* private fields */ }

Graceful shutdown coordinator.

Implementations

impl GracefulShutdown

pub fn new( registry: Arc<NodeRegistry>, leader_election: Option<Arc<LeaderElection>>, config: ShutdownConfig, ) -> Self

pub fn is_shutdown_requested(&self) -> bool

pub fn in_flight_count(&self) -> u32

pub fn increment_in_flight(&self)

pub fn decrement_in_flight(&self)

pub fn subscribe(&self) -> Receiver<bool>

Subscribe to shutdown notifications.

Late subscribers immediately see true if shutdown was already requested.

pub fn should_accept_work(&self) -> bool

pub async fn shutdown(&self) -> Result<()>