Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
76 changes: 44 additions & 32 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

12 changes: 9 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -39,9 +39,15 @@ The backend is being rebuilt on the Planner's physical DAG:
| Query engine: answer planned instant queries from stored panes and raw samples | done |
| Query engine: keep query-time panes across evaluations (`MatAtQueryKeptAcrossEvaluations`) | done |

Panes close `--allowed-lateness-ms` (default 15 s) after the newest sample
passes their end; later samples for them are dropped. The first pane after
startup is skipped because it may be partial.
Ingestion runs on `--ingestion-workers` threads and queries on
`--query-threads` threads (each default one per core). Series are sharded
across the ingestion workers by a hash of their label set; a pane closes
`--allowed-lateness-ms` (default 15 s) after every worker's newest sample
passes its end, and later samples for it are dropped. The first pane after
startup is skipped because it may be partial. Each query, including every
step of a range query, runs on one query thread; queries read the stored
panes concurrently, by shared reference. The data plane uses jemalloc as its
allocator.

An instant query whose text is one of the plan's queries is answered by the
plan (`x-asap-execution: plan`). Its stored inputs read the panes ending at
Expand Down
1 change: 1 addition & 0 deletions data_plane/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ edition.workspace = true
asap-planner.workspace = true
asap-executor.workspace = true
sha2 = "0.10"
tikv-jemallocator = "0.6"
serde.workspace = true
serde_json.workspace = true
thiserror.workspace = true
Expand Down
Loading