Struct Ring 

struct Ring {
    frames: VecDeque<Frame>,
    bytes: usize,
    bound: Option<ReplayBounds>,
    slack: ReplayBounds,
    evicted: u64,
    streams: HashMap<u64, u64>,
    next_stream: u64,
}

The replay buffer’s frames, and how much it holds.

Fields

frames: VecDeque<Frame>

bytes: usize

What frames come to, in encoded bytes.

bound: Option<ReplayBounds>

The most it holds, or None while a boot is numbering, when it holds every frame. See Repos::listening.

slack: ReplayBounds

How far past bound it holds frames an open stream has not sent.

evicted: u64

The newest sequence number evicted, or 0 before the first eviction. A stream whose position is below it has lost a frame.

streams: HashMap<u64, u64>

Each open stream’s position, by stream: the frames after it are the ones that stream has yet to send.

next_stream: u64

The key the next stream is given in streams.

Implementations

impl Ring

fn push(&mut self, frame: Frame)

Buffers frame, first evicting the oldest frames until it fits.

A frame an open stream has yet to send is kept while the buffer is within its bound plus its slack.

fn pinned(&self) -> Option<u64>

The lowest position of any open stream that has not already lost a frame. A stream that has is ended when it next reads, so keeping frames for it would only hold memory.

Trait Implementations

impl Debug for Ring

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

Formats the value using the given formatter.