Struct HotPathConfig 

pub struct HotPathConfig {
    pub enabled: bool,
    pub batch_size: usize,
    pub block_timeout: String,
    pub adaptive_batch_size: bool,
    pub min_batch_size: usize,
    pub max_batch_size: usize,
    pub rate_limit_enabled: bool,
    pub rate_limit_per_sec: u32,
    pub rate_limit_burst: u32,
}

Hot path (CDC stream tailing) configuration.

Fields

enabled: bool

Whether hot path replication is enabled.

batch_size: usize

Maximum entries to read per XREAD call (initial batch size).

block_timeout: String

XREAD block timeout as a duration string (e.g., “5s”). Parsed to Duration internally.

adaptive_batch_size: bool

Enable adaptive batch sizing (AIMD - Additive Increase, Multiplicative Decrease). When enabled, batch size adjusts based on replication lag:

• Increases when caught up (empty reads)
• Decreases when lagging (full batches)

min_batch_size: usize

Minimum batch size for adaptive sizing.

max_batch_size: usize

Maximum batch size for adaptive sizing.

rate_limit_enabled: bool

Enable rate limiting for event processing. Prevents thundering herd when many peers reconnect simultaneously.

rate_limit_per_sec: u32

Maximum events per second (sustained rate). Tokens refill at this rate.

rate_limit_burst: u32

Maximum burst size for rate limiting. Allows short bursts above the sustained rate.

Implementations

impl HotPathConfig

pub fn block_timeout_duration(&self) -> Duration

Parse the block_timeout string to a Duration.

pub fn rate_limit_config(&self) -> Option<RateLimitConfig>

Create rate limit configuration from hot path settings.

Returns None if rate limiting is disabled.

Trait Implementations

impl Clone for HotPathConfig

fn clone(&self) -> HotPathConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HotPathConfig

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

Formats the value using the given formatter.

impl Default for HotPathConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for HotPathConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for HotPathConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.