Struct FetcherConfig 

pub struct FetcherConfig { /* private fields */ }

Runtime configuration for the block fetcher pipeline.

All instances must be constructed via FetcherConfig::builder or FetcherConfig::new so invariants are validated before any consumer observes the values.

Implementations

impl FetcherConfig

pub fn builder() -> FetcherConfigBuilder

Returns a builder to incrementally construct and validate a configuration.

pub fn new(params: FetcherConfigParams) -> Result<Self>

Constructs a configuration directly from the provided values.

Prefer FetcherConfig::builder for ergonomics when many values use defaults. Callers that already have concrete runtime parameters can use this method to enforce validation without going through the builder.

pub fn rpc_url(&self) -> &str

Full RPC URL (including scheme) configured for the fetcher.

pub fn rpc_user(&self) -> &str

RPC username.

pub fn rpc_password(&self) -> &str

RPC password.

pub fn thread_count(&self) -> usize

Number of worker threads configured for the fetcher.

pub fn max_batch_size_mb(&self) -> usize

Maximum megabytes per batch that workers target.

pub fn reorg_window_size(&self) -> usize

Number of blocks tracked in the reorg window.

pub fn start_height(&self) -> u64

Starting height requested when the pipeline boots.

pub fn rpc_timeout(&self) -> Duration

Per-RPC timeout applied to the JSON-RPC client.

pub fn metrics_interval(&self) -> Duration

Interval used by the telemetry reporter.

pub fn queue_max_size_mb(&self) -> usize

Maximum megabytes of queued block data allowed in the ordered queue.

pub fn tip_idle_backoff(&self) -> Duration

Idle backoff used when workers poll near the blockchain tip.

pub fn tip_refresh_interval(&self) -> Duration

Interval between background tip refresh RPC calls.

pub fn rpc_max_request_body_bytes(&self) -> usize

Maximum allowed HTTP request body bytes for RPC calls.

pub fn rpc_max_response_body_bytes(&self) -> usize

Maximum allowed HTTP response body bytes for RPC calls.

pub fn validate(&self) -> Result<()>

Performs validation on an existing configuration instance.

Trait Implementations

impl Clone for FetcherConfig

fn clone(&self) -> FetcherConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FetcherConfig

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

Formats the value using the given formatter.

impl PartialEq for FetcherConfig

fn eq(&self, other: &FetcherConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for FetcherConfig

impl StructuralPartialEq for FetcherConfig