atproto-jetstream 0.9.7

//! # AT Protocol Jetstream Consumer Library
//!
//! Real-time WebSocket consumer library for AT Protocol Jetstream events with high-performance
//! streaming and compression support. Enables applications to receive live AT Protocol events
//! such as posts, likes, follows, and other repository changes.
//!
//! ## Key Features
//!
//! - **WebSocket Streaming**: Real-time event consumption via WebSocket connections
//! - **Zstandard Compression**: Built-in support for Zstandard (zstd) compressed event streams
//! - **Background Processing**: Asynchronous event processing with configurable concurrency
//! - **Resilient Connections**: Automatic reconnection handling for production reliability
//! - **Event Filtering**: Configurable filtering for specific event types and collections
//! - **Performance Optimized**: Low-latency event processing with minimal overhead
//!
//! ## Architecture
//!
//! The library provides a high-level consumer interface with customizable event handlers:
//!
//! - **`consumer`**: Core WebSocket consumer with event handling and connection management
//!
//! ## 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 use consumer::{
    Consumer, ConsumerError, ConsumerTaskConfig, EventHandler, JetstreamEvent,
    JetstreamEventCommit, JetstreamEventDelete, LoggingHandler,
};

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