Crate polkadot_node_subsystem::gen::metered

Metered variant of mpsc channels to be able to extract metrics.

Modules

• oneshot
  Metered variant of oneshot channels to be able to extract delays caused by delayed responses.

Structs

• CoarseDuration
  A duration type to represent an approximate span of time
• Meter
  A peek into the inner state of a meter.
• MeteredReceiver
  A receiver tracking the messages consumed by itself.
• MeteredSender
  The sender component, tracking the number of items sent across it.
• Readout
  A readout of sizes from the meter. Note that it is possible, due to asynchrony, for received to be slightly higher than sent.
• RecvError
  Error when receiving from a closed bounded channel
• UnboundedMeteredReceiver
  A receiver tracking the messages consumed by itself.
• UnboundedMeteredSender
  The sender component, tracking the number of items sent across it.

Enums

• MaybeTimeOfFlight
  Measure the time of flight between insertion and removal of a single type T
• SendError
  A bounded channel error
• TrySendError
  A bounded channel error when trying to send a message (transparently wraps the inner error type)

Functions

• channel
  Create a pair of MeteredSender and MeteredReceiver. No priorities are provided
• channel_with_priority
  Create a pair of MeteredSender and MeteredReceiver. Priority channel is provided
• prepare_with_tof
• unbounded
  Create a wrapped mpsc::channel pair of MeteredSender and MeteredReceiver.