Skip to main content

Module aggregator

Module aggregator 

Source
Expand description

Stats aggregator: receives StatsEvent from the runtime’s fan-out adapter and flushes counter deltas into per-skill stats.json sidecars.

Flush triggers: every 64 events or every 2 seconds, whichever comes first.

Structs§

StatsAggregator
StatsEvent
Mirrors Event::SkillExecuted without coupling mur-common to the runtime’s Event enum.

Constants§

FLUSH_EVERY
FLUSH_EVERY_EVENTS