TimelessMetrics.Rollup (timeless_metrics v6.0.12)

Sharded rollup engine.

Processes data tier-by-tier with parallel per-shard execution. Each shard maintains its own tier tables and watermarks. The Rollup GenServer acts as a coordinator, spawning parallel tasks for each shard.

Summary

Functions

catch_up(rollup)

Force a late-arrival catch-up scan.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

run(rollup, tier \\ :all)

Force a rollup of a specific tier (or all tiers).

start_link(opts)