Struct Sender

pub struct Sender {
    pub tx: UnboundedSender<TxnMsgWithPermits>,
    permits: Arc<Permits>,
    max_chunk_permits: usize,
}

The sender of the transaction channel with permit-based back-pressure.

Fields

tx: UnboundedSender<TxnMsgWithPermits>

permits: Arc<Permits>

max_chunk_permits: usize

The maximum permits required by a chunk. If there’re too many rows in a chunk, we only acquire these permits.

Implementations

impl Sender

pub async fn send( &self, txn_msg: TxnMsg, notificator: Sender<usize>, ) -> Result<(), SendError<TxnMsg>>

Send a message, waiting until there are enough permits. Used to send transaction data messages.

Returns error if the receive half of the channel is closed, including the message passed.

pub fn send_immediate( &self, txn_msg: TxnMsg, notificator: Sender<usize>, ) -> Result<(), SendError<TxnMsg>>

Send a message without permit acquiring. Used to send transaction control messages.

Returns error if the receive half of the channel is closed, including the message passed.

pub fn is_closed(&self) -> bool

Trait Implementations

impl Clone for Sender

fn clone(&self) -> Sender

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Sender

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.