pub struct MissDetectionConfig { /* private fields */ }
Expand description
Configuration for sample miss detection
Enabling sample miss detection allows AdvancedSubscribers
to detect missed samples
through sample_miss_listener
and to recover missed samples through recovery
.
Implementations§
Source§impl MissDetectionConfig
impl MissDetectionConfig
Sourcepub fn heartbeat(self, period: Duration) -> Self
pub fn heartbeat(self, period: Duration) -> Self
Allow last sample miss detection through periodic heartbeat.
Periodically send the last published Sample’s sequence number to allow last sample recovery.
heartbeat
and sporadic_heartbeat
are mutually exclusive. Enabling one will disable the other.
AdvancedSubscribers
can recover last sample with the
heartbeat
option.
Sourcepub fn sporadic_heartbeat(self, period: Duration) -> Self
pub fn sporadic_heartbeat(self, period: Duration) -> Self
Allow last sample miss detection through sporadic heartbeat.
Each period, the last published Sample’s sequence number is sent with CongestionControl::Block
but only if it changed since last period.
heartbeat
and sporadic_heartbeat
are mutually exclusive. Enabling one will disable the other.
AdvancedSubscribers
can recover last sample with the
heartbeat
option.
Trait Implementations§
Source§impl Default for MissDetectionConfig
impl Default for MissDetectionConfig
Source§fn default() -> MissDetectionConfig
fn default() -> MissDetectionConfig
Auto Trait Implementations§
impl Freeze for MissDetectionConfig
impl RefUnwindSafe for MissDetectionConfig
impl Send for MissDetectionConfig
impl Sync for MissDetectionConfig
impl Unpin for MissDetectionConfig
impl UnwindSafe for MissDetectionConfig
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more