Module consumer 

Consumer API for polling and filtering events.

This module provides:

• JSON predicate filtering
• Cross-shard poll merging
• Cursor-based pagination
• Optional timestamp ordering

Re-exports

pub use filter::json_path_get;

pub use filter::Filter;

pub use filter::FilterBuilder;

pub use merge::CompositeCursor;

pub use merge::ConsumeRequest;

pub use merge::ConsumeResponse;

pub use merge::Ordering;

pub use merge::PollMerger;

Modules

filter

JSON predicate filtering for event consumption.

merge

Cross-shard poll merge layer.