Expand description

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

Modules

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

Structs

  • A duration type to represent an approximate span of time
  • A peek into the inner state of a meter.
  • A receiver tracking the messages consumed by itself.
  • The sender component, tracking the number of items sent across it.
  • A readout of sizes from the meter. Note that it is possible, due to asynchrony, for received to be slightly higher than sent.
  • A receiver tracking the messages consumed by itself.
  • The sender component, tracking the number of items sent across it.

Enums

  • Measure the time of flight between insertion and removal of a single type T

Functions

  • Create a wrapped mpsc::channel pair of MeteredSender and MeteredReceiver.
  • Create a wrapped mpsc::channel pair of MeteredSender and MeteredReceiver.