aggregation

Overview ¶

Package main demonstrates dureq group aggregation — collecting individual items into groups that are automatically flushed and processed as a single aggregated job.

Scenario: Event analytics pipeline

1. Multiple producers emit individual page-view events for different users
2. Events are grouped by user ID
3. After a grace period (no new events) or when the group reaches max size, all events for that user are aggregated into a single batch payload
4. A handler processes the aggregated batch of events at once

This reduces per-event overhead and enables efficient bulk inserts.