Struct EventLog 

pub struct EventLog { /* private fields */ }

Implementations

impl EventLog

pub fn new(capacity: usize) -> Self

pub async fn publish( &self, session_id: Uuid, run_id: Option<Uuid>, event: AgentEvent, ) -> EventEnvelope

pub async fn subscribe( &self, session_id: Uuid, after_id: Option<u64>, ) -> EventSubscription

pub async fn snapshot_bounds(&self, session_id: Uuid) -> Option<(u64, u64)>

Trait Implementations

impl Clone for EventLog

fn clone(&self) -> EventLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.