Struct RecvLimits 

pub struct RecvLimits {
    pub max_records: usize,
    pub max_bytes: u64,
}

Available on crate feature transport only.

Limits for a single byte-aware TransportReceiver::recv_limited poll.

A bare recv takes only a RECORD cap, so a single poll can build a WorkBatch whose total bytes are arbitrarily larger than any memory budget (and, for the Kafka recv-arena, allocate one arena for the whole poll). RecvLimits adds the missing BYTE bound: the governed driver passes the self-regulation byte budget here so a single governed recv never retains more than max_bytes (plus the one-oversized-record floor) of inbound payload before the sub-block split runs.

max_records is the existing poll-safety record cap (a tiny-record flood cannot blow the count even within the byte budget). max_bytes is the new payload-bytes ceiling for the poll.

Fields

max_records: usize

Hard cap on the number of records returned by one poll (>= 1).

max_bytes: u64

Soft cap on the SUM of payload.len() returned by one poll. A transport that has accumulated at least one record stops draining once the accumulated payload bytes reach this value, so the poll never retains more than max_bytes + one oversized record. A transport with no byte-aware drain (the default impl) ignores this and bounds by max_records only.

Trait Implementations

impl Clone for RecvLimits

fn clone(&self) -> RecvLimits

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RecvLimits

impl Debug for RecvLimits

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

Formats the value using the given formatter.

impl Eq for RecvLimits

impl PartialEq for RecvLimits

fn eq(&self, other: &RecvLimits) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RecvLimits