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

Create a new graceful shutdown coordinator.

pub fn is_shutdown_requested(&self) -> bool

Check if shutdown has been requested.

pub fn in_flight_count(&self) -> u32

Get the current in-flight count.

pub fn increment_in_flight(&self)

Increment the in-flight counter.

pub fn decrement_in_flight(&self)

Decrement the in-flight counter.

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

Subscribe to shutdown notifications.

pub fn should_accept_work(&self) -> bool

Check if new work should be accepted.

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

Perform graceful shutdown.