Struct EventBusConfigBuilder 

pub struct EventBusConfigBuilder { /* private fields */ }

Builder for EventBusConfig.

Implementations

impl EventBusConfigBuilder

pub fn num_shards(self, n: u16) -> Self

Set the number of shards.

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

Set the ring buffer capacity per shard.

pub fn backpressure_mode(self, mode: BackpressureMode) -> Self

Set the backpressure mode.

pub fn batch(self, config: BatchConfig) -> Self

Set the batch configuration.

pub fn adapter(self, config: AdapterConfig) -> Self

Set the adapter configuration.

pub fn scaling(self, policy: ScalingPolicy) -> Self

Enable dynamic scaling with the given policy.

pub fn with_dynamic_scaling(self) -> Self

Enable dynamic scaling with default policy. The policy’s max_shards will be based on num_shards (resolved at build time).

pub fn without_scaling(self) -> Self

Disable dynamic scaling (use fixed shard count).

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

Set the adapter operation timeout.

pub fn adapter_batch_retries(self, retries: u32) -> Self

Set the number of retries for failed on_batch calls. 0 = no retries (default). Useful for Redis/JetStream under intermittent failures.

pub fn producer_nonce_path(self, path: impl Into<PathBuf>) -> Self

Persist the producer nonce at path so it survives process restart. Recommended for any deployment using JetStream / Redis adapters where retries-after-crash should dedup against the prior incarnation. See EventBusConfig::producer_nonce_path for the full doc.

pub fn build(self) -> Result<EventBusConfig, ConfigError>

Build the configuration, validating all settings.

Trait Implementations

impl Debug for EventBusConfigBuilder

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

Formats the value using the given formatter.

impl Default for EventBusConfigBuilder

fn default() -> EventBusConfigBuilder

Returns the “default value” for a type.