Struct ConnectionConfig 

pub struct ConnectionConfig {
    pub endpoint: Endpoint,
    pub reconnect: ReconnectConfig,
    pub connect_timeout: Duration,
    pub depth: Depth,
    pub heartbeat_timeout: Option<Duration>,
    pub channel_capacity: Option<usize>,
    pub backpressure_policy: BackpressurePolicy,
    pub circuit_breaker: Option<CircuitBreakerConfig>,
}

Configuration for the WebSocket connection

Fields

endpoint: Endpoint

WebSocket endpoint

reconnect: ReconnectConfig

Reconnection settings

connect_timeout: Duration

Connection timeout

depth: Depth

Orderbook depth to subscribe with

heartbeat_timeout: Option<Duration>

Heartbeat timeout - disconnect if no heartbeat received within this duration Kraken sends heartbeats every ~5 seconds; default timeout is 30 seconds

channel_capacity: Option<usize>

Event channel capacity (None = unbounded)

backpressure_policy: BackpressurePolicy

Backpressure policy when channel is full

circuit_breaker: Option<CircuitBreakerConfig>

Circuit breaker configuration (None = disabled)

Implementations

impl ConnectionConfig

pub fn new() -> Self

Create a new config with default values

pub fn with_endpoint(self, endpoint: Endpoint) -> Self

Set the endpoint

pub fn with_reconnect(self, config: ReconnectConfig) -> Self

Set reconnection config

pub fn without_reconnect(self) -> Self

Disable automatic reconnection

pub fn with_timeout(self, timeout: Duration) -> Self

Set connection timeout

pub fn with_depth(self, depth: Depth) -> Self

Set orderbook depth

pub fn with_heartbeat_timeout(self, timeout: Duration) -> Self

Set heartbeat timeout

If no message is received within this duration, the connection is considered dead and will be reconnected.

pub fn without_heartbeat_timeout(self) -> Self

Disable heartbeat timeout monitoring

pub fn with_channel_capacity( self, capacity: usize, policy: BackpressurePolicy, ) -> Self

Set bounded channel capacity for backpressure handling

When the channel is full and a new event arrives:

• DropNewest: The new event is dropped (default)
• Block: The sender blocks until space is available (may cause connection issues)

Recommended capacity: 1000-10000 depending on message rate

pub fn with_unbounded_channel(self) -> Self

Use unbounded channel (no backpressure, unlimited memory growth)

pub fn with_circuit_breaker(self, config: CircuitBreakerConfig) -> Self

Enable circuit breaker with custom configuration

The circuit breaker prevents repeated connection attempts when the service appears unhealthy, giving it time to recover.

pub fn without_circuit_breaker(self) -> Self

Disable circuit breaker

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.

impl Default for ConnectionConfig

fn default() -> Self

Returns the “default value” for a type.