Struct BoundedReplay 

pub struct BoundedReplay {
    pub events: Vec<(u64, Event)>,
    pub bytes_read: u64,
    pub budget_exceeded: bool,
}

A replay that may stop before the partition tail at a caller byte budget.

Fields

events: Vec<(u64, Event)>

Ordered (position, event) pairs read before the budget tripped.

bytes_read: u64

Sum of every returned event payload’s encoded body length.

budget_exceeded: bool

Whether the caller’s byte budget stopped the replay early.

Trait Implementations

impl Clone for BoundedReplay

fn clone(&self) -> BoundedReplay

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BoundedReplay

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

Formats the value using the given formatter.