Module sc_utils::mpsc

source ·
Expand description

Features to meter unbounded channels

Structs

  • TracingUnboundedReceiver
    Wrapper Type around UnboundedReceiver that decreases the global measure when a message is polled
  • TracingUnboundedSender
    Wrapper Type around UnboundedSender that increases the global measure when a message is added

Functions

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