Struct ConsumerTaskConfig 

pub struct ConsumerTaskConfig {
    pub user_agent: String,
    pub compression: bool,
    pub zstd_dictionary_location: String,
    pub jetstream_hostname: String,
    pub collections: Vec<String>,
    pub dids: Vec<String>,
    pub max_message_size_bytes: Option<u64>,
    pub cursor: Option<i64>,
    pub require_hello: bool,
}

Configuration for the Jetstream consumer task

Fields

user_agent: String

User-Agent header value for WebSocket connections

compression: bool

Enable Zstandard compression for messages

zstd_dictionary_location: String

Path to Zstandard dictionary file (required if compression is enabled)

jetstream_hostname: String

Hostname of the Jetstream instance to connect to

collections: Vec<String>

AT Protocol collections to subscribe to (empty for all)

dids: Vec<String>

DIDs to filter events for (empty for all)

max_message_size_bytes: Option<u64>

Maximum message size in bytes (None for unlimited)

cursor: Option<i64>

Optional cursor position to start streaming from

require_hello: bool

Whether to require a hello message before receiving events

Trait Implementations

impl Clone for ConsumerTaskConfig

fn clone(&self) -> ConsumerTaskConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerTaskConfig

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

Formats the value using the given formatter.