Struct ThreadBrokerBuilder 

pub struct ThreadBrokerBuilder<C: Consumer, P: Producer> { /* private fields */ }

Builder for ThreadBroker.

Implementations

impl<C: Consumer, P: Producer> ThreadBrokerBuilder<C, P>

pub fn budget(self, threads: usize) -> Self

Total threads to divide. Required.

pub fn initial_producer_slots(self, slots: usize) -> Self

Start the producer at this many slots instead of the coarse default.

The default start is deliberately low, because growth is cheap and many workloads never need decode threads at all. A caller that already knows better — from a previous run, or from an explicit user request — can skip the climb. Still clamped to the per-input floor and the budget.

pub fn steady_state_policy(self, policy: SteadyStatePolicy) -> Self

Choose whether a settled broker keeps watching for regime changes.

See SteadyStatePolicy for the responsiveness/overhead tradeoff.

pub fn sample_interval(self, interval: Duration) -> Self

See BrokerConfig::sample_interval.

pub fn steady_probe_interval(self, interval: Duration) -> Self

Set the interval between responsive steady-state probes.

This does not change the high-resolution convergence cadence. The producer is asked to use roughly four monitoring observations per probe, subject to any accuracy floor imposed by its adapter.

pub fn warmup(self, warmup: Duration) -> Self

See BrokerConfig::warmup.

pub fn smoothing_windows(self, windows: usize) -> Self

See BrokerConfig::smoothing_windows.

pub fn deadband_threads(self, threads: usize) -> Self

See BrokerConfig::deadband_threads.

pub fn blackout_samples(self, samples: usize) -> Self

See BrokerConfig::blackout_samples.

pub fn ratify_samples(self, samples: usize) -> Self

See BrokerConfig::ratify_samples.

pub fn opening_policy(self, policy: OpeningPolicy) -> Self

See BrokerConfig::opening_policy.

pub fn regression_tolerance(self, fraction: f64) -> Self

See BrokerConfig::regression_tolerance.

pub fn resurvey_distance(self, threads: usize) -> Self

See BrokerConfig::resurvey_distance.

pub fn resurvey_persistence(self, duration: Duration) -> Self

See BrokerConfig::resurvey_persistence.

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

See BrokerConfig::resize_timeout.

pub fn min_consumer_threads(self, threads: usize) -> Self

See BrokerConfig::min_consumer_threads.

pub fn min_producer_slots(self, slots: usize) -> Self

See BrokerConfig::min_producer_slots.

pub fn build(self) -> Result<ThreadBroker<C, P>, BrokerConfigError>

Validate and finish.

Errors

Rejects a budget too small to split, a zero sampling interval, and a warm-up shorter than two sampling intervals — the last because a broker that decides on one sample is deciding on the startup transient, which is the failure the warm-up exists to prevent.