Struct FyndBuilder 

pub struct FyndBuilder { /* private fields */ }

Builder for assembling the full solver pipeline. Configures the Tycho market-data feed, gas price fetcher, derived-data computation manager, one or more worker pools, encoder, and router.

Implementations

impl FyndBuilder

pub fn new( chain: Chain, tycho_url: impl Into<String>, rpc_url: impl Into<String>, protocols: Vec<String>, min_tvl: f64, ) -> Self

Creates a new builder with the required parameters.

pub fn chain(&self) -> Chain

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

Sets the Tycho API key.

pub fn min_tvl(self, min_tvl: f64) -> Self

Overrides the minimum TVL filter set in FyndBuilder::new.

pub fn tycho_use_tls(self, use_tls: bool) -> Self

Enables or disables TLS for the Tycho WebSocket connection (default: true).

pub fn min_token_quality(self, quality: i32) -> Self

Sets the minimum token quality score; tokens below this threshold are excluded (default: 100).

pub fn traded_n_days_ago(self, days: u64) -> Self

Filters out pools whose last trade is older than days days (default: 3).

pub fn tvl_buffer_ratio(self, ratio: f64) -> Self

Multiplies reported TVL by ratio before applying the min_tvl filter (default: 1.1).

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

Sets how often the gas price is refreshed from the RPC node (default: 30 s).

pub fn reconnect_delay(self, delay: Duration) -> Self

Sets the delay before reconnecting to Tycho after a disconnection (default: 5 s).

pub fn blacklisted_components(self, components: HashSet<String>) -> Self

Replaces the set of component addresses that are excluded from routing.

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

Sets the worker router timeout (default: 10s).

pub fn worker_router_min_responses(self, min: usize) -> Self

Sets the minimum number of solver responses before early return (default: 0).

pub fn encoder(self, encoder: Encoder) -> Self

Overrides the default encoder.

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

Shorthand: adds a single pool named "default" using a built-in algorithm by name.

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,

Shorthand: adds a single pool with a custom Algorithm implementation.

The factory closure is called once per worker thread.

pub fn add_pool(self, name: impl Into<String>, config: &PoolConfig) -> Self

Adds a named pool using the given PoolConfig.

pub fn build(self) -> Result<Solver, SolverBuildError>

Assembles and starts all solver components.

Errors

Returns SolverBuildError if any component fails to initialize.