pub enum BackpressureLevel {
None,
Low,
Medium,
High,
Critical,
}Expand description
The current backpressure state of a node.
Variants§
None
No backpressure; producer may run at full rate.
Low
Mild backpressure; producer should throttle slightly.
Medium
Moderate backpressure; producer should throttle significantly.
High
Severe backpressure; producer should pause.
Critical
Critical backpressure; producer must stop immediately.
Implementations§
Source§impl BackpressureLevel
impl BackpressureLevel
Sourcepub fn rate_multiplier(&self) -> f64
pub fn rate_multiplier(&self) -> f64
Recommended rate multiplier (fraction of nominal rate to apply).
1.0 = no throttling; 0.0 = stop completely.
Sourcepub fn from_fill_ratio(ratio: f64) -> Self
pub fn from_fill_ratio(ratio: f64) -> Self
Derive a backpressure level from a queue fill ratio (0.0–1.0).
Trait Implementations§
Source§impl Clone for BackpressureLevel
impl Clone for BackpressureLevel
Source§fn clone(&self) -> BackpressureLevel
fn clone(&self) -> BackpressureLevel
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Copy for BackpressureLevel
Source§impl Debug for BackpressureLevel
impl Debug for BackpressureLevel
impl Eq for BackpressureLevel
Source§impl Ord for BackpressureLevel
impl Ord for BackpressureLevel
Source§fn cmp(&self, other: &BackpressureLevel) -> Ordering
fn cmp(&self, other: &BackpressureLevel) -> Ordering
1.21.0 (const: unstable) · Source§fn max(self, other: Self) -> Selfwhere
Self: Sized,
fn max(self, other: Self) -> Selfwhere
Self: Sized,
Compares and returns the maximum of two values. Read more
Source§impl PartialEq for BackpressureLevel
impl PartialEq for BackpressureLevel
Source§impl PartialOrd for BackpressureLevel
impl PartialOrd for BackpressureLevel
impl StructuralPartialEq for BackpressureLevel
Auto Trait Implementations§
impl Freeze for BackpressureLevel
impl RefUnwindSafe for BackpressureLevel
impl Send for BackpressureLevel
impl Sync for BackpressureLevel
impl Unpin for BackpressureLevel
impl UnsafeUnpin for BackpressureLevel
impl UnwindSafe for BackpressureLevel
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Comparable<K> for Q
impl<Q, K> Comparable<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request