Struct ConnectionDrainHook 

pub struct ConnectionDrainHook { /* private fields */ }

Drain active connections before shutdown

Implementations

impl ConnectionDrainHook

pub fn new( active_connections: Arc<AtomicUsize>, drain_timeout: Duration, ) -> Self

Create a new connection drain hook

Arguments

• active_connections - Shared atomic counter of active connections
• drain_timeout - Maximum time to wait for all connections to close

pub fn with_poll_interval(self, interval: Duration) -> Self

Set a custom poll interval (default is 100ms)

Trait Implementations

impl ShutdownHook for ConnectionDrainHook

fn name(&self) -> &str

Human-readable name of this hook (used in logging)

fn on_shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the hook. Errors are logged but do not prevent other hooks from running.