1 2 3 4 5 6 7 8 9 10 11 12 13
//! Consumer API for polling and filtering events. //! //! This module provides: //! - JSON predicate filtering //! - Cross-shard poll merging //! - Cursor-based pagination //! - Optional timestamp ordering pub mod filter; pub mod merge; pub use filter::{json_path_get, Filter, FilterBuilder}; pub use merge::{CompositeCursor, ConsumeRequest, ConsumeResponse, Ordering, PollMerger};