Struct StreamConfig 

pub struct StreamConfig {
    pub host: String,
    pub collections: Vec<String>,
    pub zstd_dict: Option<String>,
    pub channel_capacity: usize,
    pub max_lag_events: usize,
}

Configuration for the Jetstream consumer.

This mirrors the fields from atrg-core’s JetstreamConfig but lives in this crate so that atrg-stream has zero dependency on atrg-core.

Fields

host: String

Jetstream relay host, e.g. "jetstream1.us-east.bsky.network".

collections: Vec<String>

NSID collections to subscribe to, e.g. ["app.bsky.feed.post"].

zstd_dict: Option<String>

Optional path or URL to a ZSTD dictionary for decompression.

channel_capacity: usize

Bounded back-pressure channel size (default: 1024).

max_lag_events: usize

Event lag threshold before shedding/warning (default: 10_000).

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.