Module permit

Module permit 

Source
Expand description

Channel implementation for permit-based back-pressure.

Modules§

for_test
The configuration for tests.

Structs§

ChannelMetrics
MessageWithPermits
Message with its required permits.
Permits
Semaphore-based permits to control the back-pressure.
Receiver
The receiver of the exchange service with permit-based back-pressure.
Sender
The sender of the exchange service with permit-based back-pressure.

Functions§

channel_for_test
channel_from_config_with_metrics
channel_with_metrics
Create a channel for the exchange service with metrics.