Struct CoordinatedShutdown 

pub struct CoordinatedShutdown { /* private fields */ }

Implementations

impl CoordinatedShutdown

pub fn new() -> Self

pub fn add_task<F>(&self, phase: Phase, name: impl Into<String>, hook: F)

where F: Fn() -> BoxFuture<'static, ()> + Send + Sync + 'static,

pub fn configure_phase(&self, phase: Phase, config: PhaseConfig)

Configure the timeout / recovery policy for a single phase.

pub fn is_running(&self) -> bool

Has shutdown already been initiated? CoordinatedShutdown.IsRunning.

pub async fn run(&self)

Run every phase’s hooks sequentially within a phase and phases in ascending order. Idempotent: repeated calls are no-ops.

pub async fn run_from(&self, start: Phase)

Run only phases at or after start.

Trait Implementations

impl Clone for CoordinatedShutdown

fn clone(&self) -> CoordinatedShutdown

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CoordinatedShutdown

fn default() -> CoordinatedShutdown

Returns the “default value” for a type.