Ingest data-server M1/tick files at the ingestion boundary #7
Reference in New Issue
Block a user
Delete Branch "%!s()"
Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?
The harness is currently fed hand-built synthetic streams. C3 (docs/design/
INDEX.md) defines the one merge boundary; this issue wires aura's first real
data source there.
Scope
Pull
data-server(~/dev/libs/data-server, Brummel/data-server) as a cargo gitdependency. Transpose its AoS records (
M1Parsed/TickParsed, withtime_ms: i64Unix-ms) into aura's SoA columns (C7) and normalizetime_ms->canonical epoch-ns
timestampat the single ingestion boundary (C3). Historyis shared read-only as
Arc<[T]>chunks (data-server is built for this; C12).Feed the existing k-way merge (cycle 0004) from this real source instead of
hand-fed streams.
C3/C4 keep cycle semantics identical between backtest and live: one input record
= one cycle, advanced in global timestamp order, ties broken by source order.
Note: this is the one network/external dependency. It is deliberately absent
from the bare skeleton so the workspace compiles offline (INDEX, External
components); it is pulled in only when this task starts.
Anchors
Arc<[T]>across sims.Acceptance
time_ms(Unix-ms) normalized to epoch-nstimestampat the boundary.