Struct ConnectionConfig 

pub struct ConnectionConfig {
    pub url: String,
    pub channel_capacity: usize,
    pub reconnect: ReconnectPolicy,
    pub ping_interval: Duration,
}

Configuration for a WebSocket feed connection.

Fields

url: String

WebSocket URL to connect to (e.g. "wss://stream.binance.com:9443/ws").

channel_capacity: usize

Capacity of the downstream channel that receives incoming messages.

reconnect: ReconnectPolicy

Reconnect policy applied on disconnection.

ping_interval: Duration

Ping interval to keep the connection alive (default: 20 s).

Implementations

impl ConnectionConfig

pub fn new( url: impl Into<String>, channel_capacity: usize, ) -> Result<Self, StreamError>

Build a connection configuration for url with the given downstream channel capacity.

Returns an error if url is empty or channel_capacity is zero.

pub fn with_reconnect(self, policy: ReconnectPolicy) -> Self

Override the default reconnect policy.

pub fn with_ping_interval(self, interval: Duration) -> Self

Override the keepalive ping interval (default: 20 s).

Trait Implementations

impl Clone for ConnectionConfig

fn clone(&self) -> ConnectionConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionConfig

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

Formats the value using the given formatter.