Struct ShutdownCoordinator 

pub struct ShutdownCoordinator { /* private fields */ }

Shutdown coordinator

Manages graceful shutdown with grace period and timeout enforcement.

Implementations

impl ShutdownCoordinator

pub fn new(grace_period: Duration) -> Self

Create a new shutdown coordinator

Arguments

• grace_period - Maximum time to wait for graceful shutdown

pub fn token(&self) -> CancellationToken

Get a cancellation token

Tokens can be cloned and passed to async tasks for shutdown signaling.

pub fn is_shutting_down(&self) -> bool

Check if shutdown has been initiated

pub fn initiate_shutdown(&self)

Initiate graceful shutdown

This will:

1. Set shutdown initiated flag
2. Cancel all tokens
3. Start grace period timer

pub async fn wait_for_shutdown(&self) -> bool

Wait for shutdown to complete or timeout

Returns true if shutdown completed within grace period, false if timeout occurred.

Examples

use adaptive_pipeline_bootstrap::shutdown::ShutdownCoordinator;
use std::time::Duration;

let coordinator = ShutdownCoordinator::new(Duration::from_secs(5));

// In main application loop
coordinator.initiate_shutdown();

// Wait for all tasks to complete
if coordinator.wait_for_shutdown().await {
    println!("Shutdown completed gracefully");
} else {
    println!("Shutdown timed out, forcing exit");
}

coordinator.complete_shutdown();

pub fn complete_shutdown(&self)

Signal that shutdown is complete

Call this after all cleanup is done to notify waiters.

pub async fn wait_with_timeout(&self, timeout: Duration) -> bool

Wait for shutdown with custom timeout

Trait Implementations

impl Clone for ShutdownCoordinator

fn clone(&self) -> ShutdownCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ShutdownCoordinator

fn default() -> Self

Returns the “default value” for a type.