Struct reth_metrics::common::mpsc::MeteredPollSender

pub struct MeteredPollSender<T> { /* private fields */ }

Available on crate feature common only.

A wrapper type around [PollSender] that updates metrics on send.

Implementations

impl<T: Send + 'static> MeteredPollSender<T>

pub fn new(sender: PollSender<T>, scope: &'static str) -> Self

Creates a new MeteredPollSender wrapping around the provided [PollSender].

pub const fn inner(&self) -> &PollSender<T>

Returns the underlying [PollSender].

pub fn poll_reserve( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(), PollSendError<T>>>

Calls the underlying [PollSender]’s poll_reserve, incrementing the appropriate metrics depending on the result.

pub fn send_item(&mut self, item: T) -> Result<(), PollSendError<T>>

Calls the underlying [PollSender]’s send_item, incrementing the appropriate metrics depending on the result.

Trait Implementations

impl<T> Clone for MeteredPollSender<T>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for MeteredPollSender<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 72 bytes