Struct EventsStatus 

pub struct EventsStatus {
    pub connected: bool,
    pub last_message_at: Option<String>,
    pub reconnect_count: u64,
    pub uptime_seconds: u64,
    pub reset_epoch: u64,
    pub topics_subscribed: Vec<String>,
    pub buffer_sizes: BTreeMap<String, usize>,
}

Snapshot of the connector’s state, returned by GET /events/_status.

Fields

connected: bool

true if the underlying WS is currently connected.

last_message_at: Option<String>

RFC 3339 timestamp of the last frame the connector received, if any.

reconnect_count: u64

How many times the connector has reconnected since the process started. Bumps on every successful reconnect, not on each retry.

uptime_seconds: u64

Wall-clock seconds since the connector task spawned.

reset_epoch: u64

Current reset_epoch — bumps on each reconnect or process restart.

topics_subscribed: Vec<String>

Topics currently subscribed at the upstream WS. Always includes "orders" and "pnl"; market data topics appear when a client has polled /events/marketdata?conid=… recently.

buffer_sizes: BTreeMap<String, usize>

Per-topic ring buffer occupancy. Useful for “are we close to wraparound?” capacity planning.

Trait Implementations

impl Clone for EventsStatus

fn clone(&self) -> EventsStatus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventsStatus

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

Formats the value using the given formatter.

impl Default for EventsStatus

fn default() -> EventsStatus

Returns the “default value” for a type.

impl Serialize for EventsStatus

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.