Struct ClientConfig 

pub struct ClientConfig {
    pub receive_timeout: Duration,
    pub exit_on_first_failure: bool,
    pub connect_timeout: Duration,
    pub handshake_retry_delay: Duration,
    pub ws_config: Option<WebSocketConfig>,
    pub disable_nagle: bool,
    pub channel_buffer_size: usize,
    pub send_queue_capacity: usize,
    pub processor_error_policy: ProcessorErrorPolicy,
}

Configuration for the WebSocket client

Fields

receive_timeout: Duration

Receive timeout - disconnect if no message received within this duration

exit_on_first_failure: bool

Whether to exit immediately if the first connection fails

connect_timeout: Duration

Connection timeout for establishing TCP/WebSocket

handshake_retry_delay: Duration

Delay before retrying after handshake failures

ws_config: Option<WebSocketConfig>

WebSocket protocol configuration

disable_nagle: bool

Disable Nagle’s algorithm for lower latency

channel_buffer_size: usize

Channel buffer size for message broadcasting

send_queue_capacity: usize

Outgoing send queue capacity (bounded channel for backpressure)

processor_error_policy: ProcessorErrorPolicy

Policy for handling extension processor errors

Implementations

impl ClientConfig

pub fn new() -> Self

Create a new configuration with default values

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

Set the receive timeout

pub const fn with_exit_on_first_failure(self, exit: bool) -> Self

Set whether to exit on first connection failure

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

Set connect timeout

pub const fn with_handshake_retry_delay(self, delay: Duration) -> Self

Set handshake retry delay

pub fn with_ws_config(self, config: WebSocketConfig) -> Self

Set WebSocket protocol configuration

pub const fn with_nodelay(self, nodelay: bool) -> Self

Disable Nagle’s algorithm

pub const fn with_channel_buffer(self, size: usize) -> Self

Set channel buffer size

pub const fn with_send_queue_capacity(self, cap: usize) -> Self

Set bounded send queue capacity (for backpressure)

pub const fn with_processor_error_policy( self, policy: ProcessorErrorPolicy, ) -> Self

Set processor error handling policy for message extensions

pub const fn fast_reconnect() -> Self

Preset: Fast reconnection for low-latency scenarios

pub const fn stable_connection() -> Self

Preset: Stable connection for long-running scenarios

Trait Implementations

impl Clone for ClientConfig

fn clone(&self) -> ClientConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ClientConfig

fn default() -> Self

Returns the “default value” for a type.

impl From<&ClientConfig> for DispatcherConfig

fn from(config: &ClientConfig) -> Self

Converts to this type from the input type.