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.

Errors

Returns StreamError::ConfigError 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).

pub fn with_reconnect_attempts(self, n: u32) -> Result<Self, StreamError>

Shortcut to set only the reconnect attempt limit without replacing the entire reconnect policy.

Errors

Returns StreamError::ConfigError if n is zero.

pub fn with_channel_capacity(self, capacity: usize) -> Result<Self, StreamError>

Override the downstream channel capacity.

Errors

Returns StreamError::ConfigError if capacity is zero.

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.