Struct WorkerPoolBuilder 

pub struct WorkerPoolBuilder { /* private fields */ }

Builder for WorkerPool with a fluent API.

Built-in algorithms

Use algorithm to select a built-in algorithm by name (e.g., "most_liquid").

Custom algorithms

Use with_algorithm to plug in any type implementing Algorithm via a factory closure, bypassing the built-in registry entirely. See the custom_algorithm example for a full walkthrough.

Implementations

impl WorkerPoolBuilder

pub fn new() -> Self

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

Sets the pool name.

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

Sets the algorithm by name (built-in registry lookup).

Available built-in algorithms: "most_liquid".

pub fn with_algorithm<A, F>(self, name: impl Into<String>, factory: F) -> Self

where A: Algorithm + 'static, A::GraphManager: MarketEventHandler + EdgeWeightUpdaterWithDerived + 'static, F: Fn(AlgorithmConfig) -> A + Clone + Send + Sync + 'static,

Sets a custom algorithm implementation via a factory closure.

The factory is called once per worker thread to create an algorithm instance. This bypasses the built-in registry, so any type implementing Algorithm can be used.

Example

builder.with_algorithm("my_algo", |config| MyAlgorithm::new(config))

pub fn algorithm_config(self, config: AlgorithmConfig) -> Self

Sets the algorithm configuration.

pub fn num_workers(self, n: usize) -> Self

Sets the number of worker threads.

pub fn task_queue_capacity(self, capacity: usize) -> Self

Sets the task queue capacity.

pub fn build( self, market_data: SharedMarketDataRef, derived_data: SharedDerivedDataRef, event_rx: Receiver<MarketEvent>, derived_event_rx: Receiver<DerivedDataEvent>, ) -> Result<(WorkerPool, TaskQueueHandle), UnknownAlgorithmError>

Builds and spawns the worker pool.

Creates an internal task queue and returns both the worker pool and a handle for enqueueing tasks.

Errors

Returns an error if the algorithm name is not registered.

Trait Implementations

impl Default for WorkerPoolBuilder

fn default() -> Self

Returns the “default value” for a type.