Struct DispatcherBuilder 

pub struct DispatcherBuilder { /* private fields */ }

Builder for configuring a Dispatcher.

Implementations

impl DispatcherBuilder

pub fn new() -> Self

pub fn host(self, host: impl Into<String>) -> Self

pub fn port(self, port: u16) -> Self

pub fn max_connections(self, max: u32) -> Self

pub fn heartbeat_interval(self, ms: u64) -> Self

pub fn heartbeat_timeout(self, ms: u64) -> Self

pub fn max_pool_size(self, max: u32) -> Self

Set the maximum number of workers allowed in the pool. Workers connecting beyond this limit will be rejected.

pub fn min_pool_size(self, min: u32) -> Self

Set the minimum pool size. When the pool drops below this threshold, the on_pool_below_min callback is invoked.

pub fn on_pool_below_min(self, cb: impl Fn(u32) + Send + Sync + 'static) -> Self

Set a callback to be invoked when the pool size drops below min_pool_size. The callback receives the current pool size.

pub fn build(self) -> Dispatcher

Trait Implementations

impl Debug for DispatcherBuilder

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

Formats the value using the given formatter.

impl Default for DispatcherBuilder

fn default() -> Self

Returns the “default value” for a type.