atproto-jetstream 0.8.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

//! WebSocket-based event stream consumer for AT Protocol Jetstream with Zstandard compression.
//!
//! Provides binary:
//! - `atproto-jetstream-consumer`: Consume and log Jetstream events from AT Protocol relays

#![warn(missing_docs)]

pub mod consumer;

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

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