Struct ShutdownCoordinator 

pub struct ShutdownCoordinator { /* private fields */ }

Coordinates shutdown across all endpoint components

Implementations

impl ShutdownCoordinator

pub fn new() -> Arc<Self>

Create a new shutdown coordinator

pub fn close_start_token(&self) -> CancellationToken

Get a token that is cancelled when shutdown starts

pub fn close_complete_token(&self) -> CancellationToken

Get a token that is cancelled when shutdown completes

pub fn is_shutting_down(&self) -> bool

Check if shutdown has been initiated

pub fn register_task(&self, handle: JoinHandle<()>)

Register a background task for tracking

pub fn spawn_tracked<F>(self: &Arc<Self>, future: F) -> JoinHandle<()>

where F: Future<Output = ()> + Send + 'static,

Spawn a tracked task that respects the shutdown token

pub fn active_task_count(&self) -> usize

Get count of active tasks

pub async fn shutdown(&self)

Execute coordinated shutdown

Trait Implementations

impl Debug for ShutdownCoordinator

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

Formats the value using the given formatter.

impl Default for ShutdownCoordinator

fn default() -> Self

Returns the “default value” for a type.