Module engine 

Schema-agnostic windowing state-machine engines. An engine owns accumulator state, late rejection, eviction and diff routing; the caller (the “face”) owns extraction and output construction, handing over pre-bucketed events and translating WindowResults into diffs.

Modules

config

rolling

rolling_incremental

rolling_top_k

tumbling

tumbling_carry

Structs

BufferKey

EmitKey

GroupMeta

The highest window start seen for a group, used to drop late events for already-closed windows.

MetaKey

State-cache key for a group’s GroupMeta, tagged into a keyspace distinct from the per-window accumulators.

RunningKey

WindowResult

A finalized window the engine produced; the face turns it into a diff.

WindowStateKey

Enums

AccumulatorEvent

One contribution routed to a window accumulator.

EmitKind

How a finalized window value should be emitted downstream.

ExpiryAnchor

Which coordinate a window’s expiry-index entry is ordered by, and so which coordinate its seal horizon is measured from.

Functions

meta_key_for