risingwave_stream::executor::exchange

Module permit

source
Expand description

Channel implementation for permit-based back-pressure.

Modules§

Structs§

  • Message with its required permits.
  • Semaphore-based permits to control the back-pressure.
  • The receiver of the exchange service with permit-based back-pressure.
  • The sender of the exchange service with permit-based back-pressure.

Functions§