Struct EventsHandle 

pub struct EventsHandle { /* private fields */ }

Cloneable handle the axum handlers use. Reads come straight off the shared ring map; writes go through the command channel.

Implementations

impl EventsHandle

pub fn event_log(&self) -> Option<&Arc<EventLog>>

Borrow the optional sqlite event log so /events/{topic}/history route handlers can query historical events.

impl EventsHandle

pub async fn read_topic( &self, topic: &str, since: u64, limit: usize, ) -> Option<ReadResult>

Read events from a topic. Returns None if the topic isn’t known (no events ever arrived for it). For marketdata:<conid>, callers should call Self::ensure_market_data first to register interest.

pub async fn status(&self) -> EventsStatus

Snapshot of status. uptime_seconds is computed at call time from the connector’s start instant.

pub async fn ensure_market_data(&self, conid: i64) -> Result<(), String>

Ensure the upstream WS is subscribed to market data for conid. Idempotent; multiple callers can request the same conid and only one upstream subscribe is sent. Returns Err if the connector task is dead or if the subscribe send failed.

Trait Implementations

impl Clone for EventsHandle

fn clone(&self) -> EventsHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.