core/

Package bytebufferpool provides a self-calibrating pool of byte buffers, bucketed by capacity, that reduces GC pressure on byte-heavy hot paths such as codec marshaling and broker payload encoding.

Package chain provides a generic chain-of-responsibility helper shared by the middleware and resilience packages, which define the same Handler/Middleware decorator shape but over different handler types.

Package collection provides concurrency-safe generic collections used by the resilience primitives: a rolling window for time-bucketed statistics and a safe map that avoids the Go map-delete memory-growth issue.

Package contextx provides context helpers.

Package executors provides batching executors that coalesce sporadic tasks into fewer, larger executions: periodical (time-driven), bulk (count-driven), delay (debounced), chunk (byte-size-driven) and less (rate-limited).

Package limit provides a channel-based semaphore for bounding concurrency.

Package mathx provides small numeric helpers used by the core components: a deviation-based jitter around a value and a probabilistic boolean.

Package mr provides a generic MapReduce with a bounded worker pool, guarded channel writes and first-error cancellation.

Package stat exposes smoothed system-level statistics.

Package syncx provides small concurrency primitives used across the core components: a single-flight group with freshness reporting and a spin lock for very short critical sections.

Package timex provides a Ticker abstraction with a fake implementation for deterministic, clock-injectable tests of periodic logic.