Crate atrg_firehose 

AT Protocol firehose consumer for at-rust-go.

Subscribes to com.atproto.sync.subscribeRepos on a relay and delivers decoded events through a bounded channel with backpressure.

This crate is deliberately independent of atrg-core to avoid cyclic dependencies. It defines its own FirehoseConfig that atrg-core maps its firehose configuration into before calling spawn_firehose.

Re-exports

pub use consumer::spawn_firehose;

pub use event::FirehoseCommit;

pub use event::FirehoseEvent;

pub use event::OpAction;

pub use event::RepoOp;

pub use metrics::FirehoseMetrics;

Modules

backoff

Exponential backoff with jitter for firehose reconnection.

car

Minimal CAR v1 file decoder for extracting CBOR blocks.

consumer

Firehose WebSocket consumer with bounded backpressure.

event

Firehose event types for com.atproto.sync.subscribeRepos.

metrics

Firehose consumer metrics.

Structs

FirehoseConfig

Configuration for the firehose consumer.

Type Aliases

FirehoseHandler

Type alias for firehose event handler functions.