Struct DemuxStats
pub struct DemuxStats {
pub dropped_queue_full: u64,
pub dropped_association_limit: u64,
pub dropped_reply_source: u64,
pub dropped_invalid: u64,
pub addressed_to_listener: u64,
pub dropped_addressed_to_host: u64,
pub queued_bytes: usize,
}Available on crate features
std and udp only.Expand description
What a DatagramDemux dropped or refused since it started.
Fields§
§dropped_queue_full: u64Datagrams dropped because their association’s queue or DemuxConfig::queued_bytes
was full.
dropped_association_limit: u64Datagrams dropped because they would open an association beyond the limit.
dropped_reply_source: u64Datagrams dropped because a reply could not leave from where they were sent to.
dropped_invalid: u64Datagrams dropped as invalid receives (see DatagramMetadata::validate).
addressed_to_listener: u64Associations whose original destination is this listener itself, given no
ConnectorTarget.
dropped_addressed_to_host: u64Datagrams dropped because they were redirected from this host itself, where a reply socket would catch the proxy’s own forward.
queued_bytes: usizePayload bytes queued now, across all associations.
Trait Implementations§
§impl Clone for DemuxStats
impl Clone for DemuxStats
§fn clone(&self) -> DemuxStats
fn clone(&self) -> DemuxStats
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 DemuxStats
§impl Debug for DemuxStats
impl Debug for DemuxStats
§impl Default for DemuxStats
impl Default for DemuxStats
§fn default() -> DemuxStats
fn default() -> DemuxStats
Returns the “default value” for a type. Read more
impl Eq for DemuxStats
§impl PartialEq for DemuxStats
impl PartialEq for DemuxStats
impl StructuralPartialEq for DemuxStats
Auto Trait Implementations§
impl Freeze for DemuxStats
impl RefUnwindSafe for DemuxStats
impl Send for DemuxStats
impl Sync for DemuxStats
impl Unpin for DemuxStats
impl UnsafeUnpin for DemuxStats
impl UnwindSafe for DemuxStats
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§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
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§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> ⓘ
Converts
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> ⓘ
Converts
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§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more