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.

Enums

• TryRecvError
  An error returned from [Receiver::try_recv()].
• TrySendError
  An error returned from [Sender::try_send()].

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.