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 outage — gap_ms is the wall-clock interval since the last received message.

Fields

gap_ms: u64

Lagged

Slow consumer dropped messages — every affected book is invalidated and must be rebuilt from the next Snapshot.

Fields

dropped: u64

first_seq: u64

last_seq: u64

BookInvalidated

A specific market’s book is no longer trustworthy — drop cache and wait for next Snapshot (reasons: Reconnect, Lag, SequenceGap, ExchangeReset).

Fields

market_id: String

reason: InvalidationReason

Error

A non-fatal error observed on the connection (session continues).

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.