Enum SessionEvent 

pub enum SessionEvent {
    Connected,
    Reconnected {
        gap_ms: u64,
    },
    Lagged {
        dropped: u64,
        first_seq: u64,
        last_seq: u64,
    },
    BookInvalidated {
        market_id: String,
        reason: InvalidationReason,
    },
    Error {
        message: String,
    },
}

Connection-level events, emitted on a channel separate from WsUpdate so a reconnect is observable as a single global signal rather than per-market.

Variants

Connected

Initial socket establishment.

Reconnected

Socket re-established after an observed outage. gap_ms is the wall-clock interval between the last received message and this event. Callers who maintain per-market books should discard them and wait for the next WsUpdate::Snapshot for each subscribed market.

Fields

gap_ms: u64

Lagged

Outbound dispatch channel overflowed — a slow consumer missed deltas. Unlike tokio::sync::broadcast which silently skips ahead, openpx raises this explicitly and invalidates every affected book, because a missed delta corrupts book state in a way the caller cannot detect from the stream alone.

Fields

dropped: u64

first_seq: u64

last_seq: u64

BookInvalidated

A specific market’s book is no longer trustworthy. Caller should discard its cache for that market_id and wait for the next WsUpdate::Snapshot.

Fields

market_id: String

reason: InvalidationReason

Error

A non-fatal error observed on the connection. The session continues; the caller is informed in case they want to log or alert.

Fields

message: String

Implementations

impl SessionEvent

pub fn reconnected(gap: Duration) -> Self

Construct a Reconnected event from a Duration-shaped gap. Saturating cast at u64::MAX keeps the type stable for callers serializing to JSON.

pub fn error(err: WebSocketError) -> Self

Convenience constructor that stringifies the upstream error.

Trait Implementations

impl Clone for SessionEvent

fn clone(&self) -> SessionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionEvent

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

Formats the value using the given formatter.

impl Serialize for SessionEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.