Expand description
Deterministic tick-to-bar aggregation shared by stored bars and in-memory replay series.
Historical replay builds its analysis bars from ticks while it runs, and a research workflow needs the same bars on disk so that a parameter search over bars agrees with a confirmation run over ticks. Both paths therefore use the bucket arithmetic and accumulation rules in this module, and a parity test asserts that they produce identical bars for the same input.
The module is intentionally free of storage and dataframe dependencies so that it compiles for consumers that only need the models.
Structs§
- BarAggregator
- Accumulates ticks into fixed-duration bars using the replay engine’s bucket rules.
- Bucket
Spec - Fixed-duration bucket geometry.
Enums§
- Price
Basis - Quote side used to derive one bar price from a tick.
Functions§
- bucket_
bounds - Half-open
[open, close)bucket containingtimestamp. - is_
executable_ quote - Whether a two-sided quote is executable, matching the replay feed’s acceptance rule.