Enum ConnectionEvent 

pub enum ConnectionEvent {
    Connecting,
    Connected,
    Authenticated,
    Unauthenticated {
        message: String,
    },
    Disconnected {
        code: Option<u16>,
        reason: String,
        intent: DisconnectIntent,
    },
    Reconnecting {
        attempt: u32,
    },
    ReconnectFailed {
        attempts: u32,
    },
    HeartbeatTimeout {
        elapsed: Duration,
    },
    Error {
        message: String,
        code: i32,
    },
}

Events emitted by WebSocket connection.

Consumers attribute events to their source client via the events() / state_events() Receiver they were yielded from — tokio::select! arms naturally label by source, and code that merges streams from multiple clients is expected to wrap with its own labeling adapter (3 lines via tokio_stream::StreamExt::map). The SDK does not pre-empt that decision by stuffing a label on every event.

Variants

Connecting

Connection attempt started

Connected

Connection established

Authenticated

Authentication successful

Unauthenticated

Authentication rejected by the server (parallels old SDKs’ unauthenticated event)

Fields

message: String

Server-provided rejection message.

Disconnected

Connection closed.

intent classifies the originator: Client for local-initiated, Server for a peer Close frame, Network for transport errors / EOF / heartbeat timeout.

Fields

code: Option<u16>

WebSocket close code, if the peer supplied one.

reason: String

Human-readable close reason (may be empty).

intent: DisconnectIntent

Who initiated the disconnect.

Reconnecting

Reconnection attempt started

Fields

attempt: u32

Current attempt number (1-indexed).

ReconnectFailed

Reconnection failed after max attempts

Fields

attempts: u32

Total attempts performed before giving up.

HeartbeatTimeout

Heartbeat timeout: no inbound frame received within the configured heartbeat_timeout window. Emitted by the dispatch loop when the read-site timeout fires; the dispatch loop returns immediately afterwards, which lets the reconnect path take over.

Fields

elapsed: Duration

Wall-clock interval that elapsed since the last inbound frame.

Error

Error occurred

Fields

message: String

Diagnostic message describing the error.

code: i32

Numeric error code (mirrors MarketDataError::to_error_code).

Trait Implementations

impl Clone for ConnectionEvent

fn clone(&self) -> ConnectionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionEvent

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

Formats the value using the given formatter.

impl PartialEq for ConnectionEvent

fn eq(&self, other: &ConnectionEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ConnectionEvent