pub struct WireTapLifecycle { /* private fields */ }Expand description
A lifecycle handle for a WireTapService implementing graceful-drain-
then-abort teardown via StepLifecycle::shutdown.
Obtain via WireTapService::lifecycle. The handle shares the same
Arc<WireTapShared> as the service, so shutdown observes the live
admission gate and task tracker.
Trait Implementations§
Source§impl Debug for WireTapLifecycle
impl Debug for WireTapLifecycle
Source§impl StepLifecycle for WireTapLifecycle
impl StepLifecycle for WireTapLifecycle
Source§fn start<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn start<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Reopen admission after a shutdown (route restart, ADR-0022).
A start-after-shutdown installs a fresh cancellation token and task
tracker, so taps admitted after the restart are not born cancelled,
and clears the shutdown idempotency flag, so the next shutdown
again closes admission and drains in-flight copies.
fn shutdown<'life0, 'async_trait>(
&'life0 self,
_reason: StepShutdownReason,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Auto Trait Implementations§
impl !Freeze for WireTapLifecycle
impl RefUnwindSafe for WireTapLifecycle
impl Send for WireTapLifecycle
impl Sync for WireTapLifecycle
impl Unpin for WireTapLifecycle
impl UnsafeUnpin for WireTapLifecycle
impl UnwindSafe for WireTapLifecycle
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more