Struct StreamClientConfig 

pub struct StreamClientConfig {
    pub connection: ConnectionConfig,
    pub backpressure: BackpressureConfig,
    pub enable_metrics: bool,
}

Common client configuration

Fields

connection: ConnectionConfig

Connection configuration

backpressure: BackpressureConfig

Backpressure configuration

enable_metrics: bool

Whether performance monitoring is enabled (default: false)

Implementations

impl StreamClientConfig

pub fn high_throughput() -> Self

Creates a high-throughput configuration optimized for high-concurrency scenarios.

This configuration prioritizes throughput over latency by:

• Implementing a drop strategy for backpressure to avoid blocking
• Setting a large permit buffer (5,000) to handle burst traffic

Ideal for scenarios where you need to process large volumes of data and can tolerate occasional message drops during peak loads.

pub fn low_latency() -> Self

Creates a low-latency configuration optimized for real-time scenarios.

This configuration prioritizes latency over throughput by:

• Processing events immediately without buffering
• Implementing a blocking backpressure strategy to ensure no data loss
• Setting optimal permits (4000) for balanced throughput and latency

Ideal for scenarios where every millisecond counts and you cannot afford to lose any events, such as trading applications or real-time monitoring.

Trait Implementations

impl Clone for StreamClientConfig

fn clone(&self) -> StreamClientConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamClientConfig

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

Formats the value using the given formatter.

impl Default for StreamClientConfig

fn default() -> Self

Returns the “default value” for a type.