Module iota_metrics::monitored_mpsc

Provides wrappers to tokio mpsc channels, with metrics on total items sent, received and inflight.

Structs

• Permit
  A newtype for an mpsc::Permit which allows us to inject gauge accounting in the case the permit is dropped w/o sending
• Receiver
  Wraps [mpsc::Receiver] with gauges counting the inflight and received items.
• Sender
  Wraps [mpsc::Sender] with gauges counting the sent and inflight items.
• UnboundedReceiver
  Wraps [mpsc::UnboundedReceiver] with gauges counting the inflight and received items.
• UnboundedSender
  Wraps [mpsc::UnboundedSender] with gauges counting the sent and inflight items.
• WeakSender
  Wraps [mpsc::WeakSender] with gauges counting the sent and inflight items.
• WeakUnboundedSender
  Wraps [mpsc::WeakUnboundedSender] with gauges counting the sent and inflight items.

Traits

• WithPermit
  Sends a value into the channel using the held Permit. After successfully sending the value, it increments the sent gauge (if available) to reflect that an item has been sent.

Functions

• channel
  Wraps [mpsc::channel()] to create a pair of Sender and Receiver
• unbounded_channel
  Wraps [mpsc::unbounded_channel()] to create a pair of UnboundedSender and UnboundedReceiver