Struct Config 

pub struct Config {
    pub threads: usize,
    pub sequential: bool,
    pub reverse: bool,
    pub buffer_window_bytes: Option<u64>,
    pub slot_range: Range<u64>,
    pub clickhouse_enabled: bool,
    pub spawn_clickhouse: bool,
    pub builtin_plugins: Vec<BuiltinPlugin>,
    pub clickhouse_dsn: Option<String>,
    pub tui: bool,
}

Runtime configuration for JetstreamerRunner.

Fields

threads: usize

Number of simultaneous firehose streams to spawn.

sequential: bool

Whether to process with a single firehose worker and ripget-backed sequential streaming.

reverse: bool

When true (sequential mode only), iterate epochs from highest to lowest.

buffer_window_bytes: Option<u64>

Optional override for ripget sequential window size in bytes.

slot_range: Range<u64>

The range of slots to process, inclusive of the start and exclusive of the end slot.

clickhouse_enabled: bool

Whether to connect to ClickHouse for plugin output.

spawn_clickhouse: bool

Whether to spawn a local ClickHouse instance automatically.

builtin_plugins: Vec<BuiltinPlugin>

Built-in plugins requested via CLI flags.

clickhouse_dsn: Option<String>

ClickHouse DSN supplied via --clickhouse-dsn. When set, it overrides the JETSTREAMER_CLICKHOUSE_DSN env var and any prior with_clickhouse_dsn builder call.

tui: bool

Whether to render the interactive terminal dashboard instead of log output.

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.

impl Eq for Config

impl PartialEq for Config

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Config