Struct ShutdownController 

pub struct ShutdownController { /* private fields */ }

Controller for coordinating graceful shutdown.

Provides mechanisms to:

• Subscribe to shutdown signals
• Trigger shutdown programmatically
• Wait for in-flight operations to complete
• Set shutdown timeout

Implementations

impl ShutdownController

pub fn new() -> Self

Create a new shutdown controller.

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

Subscribe to shutdown notifications.

Returns a receiver that will be notified when shutdown is initiated.

pub fn is_shutdown(&self) -> bool

Check if shutdown has been initiated.

pub fn shutdown_signal(&self) -> ShutdownSignal

Get a future that resolves when shutdown is initiated.

pub async fn shutdown(&self, grace_period: Duration) -> bool

Initiate graceful shutdown.

This will:

1. Set the shutdown flag
2. Notify all subscribers
3. Wait for active operations to complete (with timeout)

Returns true if all operations completed gracefully, false if timed out.

pub fn register_operation(&self) -> OperationGuard

Register an active operation.

Returns a guard that decrements the counter when dropped.

pub fn active_operations(&self) -> usize

Get the number of active operations.

Trait Implementations

impl Clone for ShutdownController

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ShutdownController

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ShutdownController

fn default() -> Self

Returns the “default value” for a type.