Crate atproto_jetstream 

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

Re-exports

pub use consumer::Consumer;

pub use consumer::ConsumerTaskConfig;

pub use consumer::EventHandler;

pub use consumer::JetstreamEvent;

pub use consumer::JetstreamEventCommit;

pub use consumer::JetstreamEventDelete;

pub use consumer::LoggingHandler;

pub use errors::ConsumerError;

Modules

consumer

Async stream consumer for Jetstream events.

errors

Structured Error Types for AT Protocol Jetstream

Structs

CancellationToken

A token which can be used to signal a cancellation request to one or more tasks.