Module sc_utils::mpsc

Code to meter unbounded channels.

Structs

• TracingUnboundedReceiver
  Wrapper Type around async_channel::Receiver that decreases the global measure when a message is polled.
• TracingUnboundedSender
  Wrapper Type around async_channel::Sender that increases the global measure when a message is added.

Functions

• tracing_unbounded
  Wrapper around async_channel::unbounded that tracks the in- and outflow via UNBOUNDED_CHANNELS_COUNTER and warns if the message queue grows above the warning threshold.