Module utils 

Stream Utilities

Utility functions and helpers for common stream operations.

Structs

BatchProcessor

Batch processor for processing multiple events efficiently

EventFilter

Event filter builder for creating complex event filters

EventSampler

Event sampler for sampling events at a specified rate

SimpleRateLimiter

Simple rate limiter for controlling event publishing rate

StreamMultiplexer

Stream multiplexer for consuming from multiple streams

StreamStats

Stream statistics aggregator

Functions

create_dev_stream

Helper to create a stream with sensible defaults for development

create_prod_stream

Helper to create a stream with production settings