Struct SubscriptionConfig 

pub struct SubscriptionConfig {
    pub max_per_connection: usize,
    pub max_global: usize,
    pub max_result_rows: usize,
    pub rate_limit_per_second: u32,
    pub channel_buffer_size: usize,
    pub slow_consumer_threshold_percent: u8,
    pub selective_updates: SelectiveColumnConfig,
}

Configuration for subscription limits, quotas, and backpressure

Provides configurable limits to prevent resource exhaustion attacks and ensure fair resource sharing between clients.

Fields

max_per_connection: usize

Maximum subscriptions per connection (default: 100)

Prevents a single client from creating too many subscriptions and monopolizing server resources.

max_global: usize

Maximum subscriptions globally across all connections (default: 10,000)

Sets an upper bound on total subscriptions to ensure predictable memory usage and performance.

max_result_rows: usize

Maximum result set size per subscription in rows (default: 10,000)

Limits memory usage per subscription by capping the number of rows that can be returned.

rate_limit_per_second: u32

Rate limit: subscriptions per second per connection (default: 10)

Prevents rapid subscription creation that could degrade performance.

channel_buffer_size: usize

Channel buffer size per subscription (default: 64) Larger values reduce chance of drops but use more memory. Smaller values detect slow consumers faster.

slow_consumer_threshold_percent: u8

Slow consumer threshold as percentage of buffer full (default: 80) When channel depth exceeds this percentage, warn about slow consumer

selective_updates: SelectiveColumnConfig

Configuration for selective column updates

Controls when the server sends partial row updates (only changed columns) instead of full rows, reducing bandwidth for wide tables with few changes.

Trait Implementations

impl Clone for SubscriptionConfig

fn clone(&self) -> SubscriptionConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionConfig

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

Formats the value using the given formatter.

impl Default for SubscriptionConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SubscriptionConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SubscriptionConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.