atproto-jetstream 0.11.0

AT Protocol Jetstream event consumer library with WebSocket streaming and compression support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! WebSocket consumer for AT Protocol Jetstream events.
//!
//! Real-time event streaming with Zstandard compression, automatic reconnection,
//! and configurable event filtering for AT Protocol repository changes.
//!
//! ## Command-Line Tools
//!
//! When built with the `clap` feature, provides Jetstream consumer tools:
//!
//! - **`atproto-jetstream-consumer`**: Connect to AT Protocol Jetstream and consume real-time events with Zstandard compression

#![forbid(unsafe_code)]
#![warn(missing_docs)]

pub mod consumer;
pub mod errors;

pub use consumer::{
    Consumer, ConsumerTaskConfig, EventHandler, JetstreamEvent, JetstreamEventCommit,
    JetstreamEventDelete, LoggingHandler,
};
pub use errors::ConsumerError;

// Re-export CancellationToken for convenience
pub use tokio_util::sync::CancellationToken;