Module 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.