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