risingwave_dml

Module txn_channel

Source

Structs§

PermitValue
Permits
Semaphore-based permits to control the back-pressure.
Receiver
The receiver of the txn channel with permit-based back-pressure.
Sender
The sender of the transaction channel with permit-based back-pressure.
TxnMsgWithPermits

Functions§

txn_channel
Create a channel for transaction messages.