Struct DebugEventStore 

pub struct DebugEventStore { /* private fields */ }

Event store for debug sessions with subscription support.

Uses interior mutability (Mutex) so it can be shared via Arc between the executor (which owns the DebugAwareEventStore) and the protocol handler.

Implementations

impl DebugEventStore

pub fn new(session_id: String) -> Self

Creates a new DebugEventStore with the given session ID and default capacity.

pub fn with_capacity(session_id: String, max_events: usize) -> Self

Creates a new DebugEventStore with the given session ID and max event capacity.

pub fn session_id(&self) -> &str

Returns the session ID.

pub fn max_events(&self) -> usize

Returns the max event capacity.

pub fn append(&self, event: NetEvent)

Appends an event, evicting oldest if at capacity, and broadcasts to subscribers.

pub fn events(&self) -> Vec<NetEvent>

Returns a snapshot of all retained events.

pub fn event_count(&self) -> usize

Total number of events ever appended (including evicted).

pub fn size(&self) -> usize

Number of retained events.

pub fn is_empty(&self) -> bool

Returns true if no events are retained.

pub fn evicted_count(&self) -> usize

Number of events evicted from the store.

pub fn subscribe(&self) -> (Receiver<NetEvent>, Subscription)

Subscribe to receive events as they occur.

Returns a crossbeam_channel::Receiver for receiving events and a Subscription handle for cancellation.

pub fn subscriber_count(&self) -> usize

Number of active subscribers.

pub fn events_from(&self, from_index: usize) -> Vec<NetEvent>

Returns events starting from a specific global index.

pub fn events_since(&self, from: u64) -> Vec<NetEvent>

Returns all events since the specified timestamp.

pub fn events_between(&self, from: u64, to: u64) -> Vec<NetEvent>

Returns events within a time range [from, to).

pub fn close(&self)

Closes the store, removing all subscribers.

Trait Implementations

impl Debug for DebugEventStore

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

Formats the value using the given formatter.