Struct MessageHistory 

pub struct MessageHistory { /* private fields */ }

Bounded ring-buffer of recent GTP messages.

The capacity is fixed at construction time; older messages are discarded once the buffer is full. Insertion is O(1); resync queries are O(n) over the buffer (typically small).

Implementations

impl MessageHistory

pub fn with_capacity(capacity: usize) -> Self

Builds a history that retains up to capacity messages.

Panics

Panics if capacity == 0.

pub fn push(&mut self, msg: GtpMessage) -> bool

Records a message. Returns true if it was newly added, false if (sender_id, message_id) was already present (idempotent insert).

pub fn len(&self) -> usize

Number of messages currently in the buffer.

pub fn is_empty(&self) -> bool

true if the buffer is empty.

pub fn contains(&self, sender_id: MemberId, message_id: u64) -> bool

Returns true if (sender_id, message_id) is present.

pub fn since<'a>( &'a self, watermark: &'a Watermark, ) -> impl Iterator<Item = &'a GtpMessage> + 'a

Returns every message produced after the given watermark, in insertion order. Use this to satisfy a peer’s resync request.

pub fn since_for_sender( &self, sender_id: MemberId, since_message_id: u64, ) -> impl Iterator<Item = &GtpMessage>

Returns every message from a single sender produced strictly after since_message_id.

pub fn clear(&mut self)

Drops every message in the buffer.