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>,
    pub subscriptions: BTreeMap<String, SubscriptionState>,
    pub subscribe_refusals: u64,
    pub session_rollovers: u64,
    pub connector_restarts: u64,
    pub persist_failures: u64,
}

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. Seeded from the boot time (Unix ms) and bumped once per successful reconnect — never on a failed attempt.

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.

subscriptions: BTreeMap<String, SubscriptionState>

Whether CPAPI has actually honoured each standing subscription (orders, pnl). topics_subscribed above records what we ASKED for; this records what we GOT. The difference is the whole story of a fill that never arrived: CPAPI answers sor+{} with {"error":"unable to subscribe"} more often than not, and a socket that outlives a Gateway re-login keeps heartbeating with every subscription dead. A consumer confirming fills should treat anything but subscribed on orders as “the stream will not tell you”.

subscribe_refusals: u64

How many subscribe refusals CPAPI has sent since the process started.

session_rollovers: u64

How many times the connector tore its socket down because the Gateway’s session id changed underneath it (a re-login).

connector_restarts: u64

How many times the connector task panicked and was restarted by its supervisor since the process started.

persist_failures: u64

sqlite history appends that failed since the process started.

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.