Struct TopicRing 

pub struct TopicRing { /* private fields */ }

FIFO ring of ObservedEvent keyed by cursor. Single owner; not Send + Sync on its own — wrap in Arc<RwLock<…>> for cross-task access.

Implementations

impl TopicRing

pub fn new(topic: impl Into<String>, capacity: usize, reset_epoch: u64) -> Self

Construct a ring with the given capacity for a specific topic and reset epoch.

pub fn topic(&self) -> &str

Topic name this ring captures (e.g. "orders").

pub fn reset_epoch(&self) -> u64

Current reset_epoch.

pub fn len(&self) -> usize

Number of events currently buffered.

pub fn is_empty(&self) -> bool

Whether the ring contains no events.

pub fn head_cursor(&self) -> u64

Smallest cursor currently buffered. Equal to next_cursor when empty.

pub fn next_cursor(&self) -> u64

Cursor that the next push will use. Useful in tests.

pub fn push(&mut self, payload: Value, received_at: String) -> u64

Push a new event with the given payload + RFC 3339 receive timestamp. Returns the assigned cursor. If the ring is at capacity, the oldest event is evicted (and head_cursor advances).

pub fn read_since(&self, since: u64, limit: usize) -> ReadResult

Read events whose cursor is strictly greater than since, capped at limit. since == 0 means “everything currently buffered”.

Returns ReadResult::CursorExpired when since < head_cursor - 1 AND the ring has evicted at least one event the caller hasn’t seen — i.e. there’s a real gap, not just “you’ve read everything”.

Trait Implementations

impl Debug for TopicRing

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

Formats the value using the given formatter.