Skip to content

Remove old routing table; Take both disk and memory WAL readings#6193

Merged
nadav-govari merged 4 commits intonadav/feature-node-based-routingfrom
nadav/pr6
Mar 9, 2026
Merged

Remove old routing table; Take both disk and memory WAL readings#6193
nadav-govari merged 4 commits intonadav/feature-node-based-routingfrom
nadav/pr6

Conversation

@nadav-govari
Copy link
Collaborator

Description

Removes the old routing table, as it's no longer used.

Takes the worse of disk and memory WAL readings for better accuracy.

How was this PR tested?

Unit tests pass.

impl BroadcastIngesterCapacityScoreTask {
pub fn spawn(cluster: Cluster, weak_state: WeakIngesterState) -> JoinHandle<()> {
let mut broadcaster = Self {
cluster,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: rename to capacity_score.rs

@@ -1,1091 +0,0 @@
// Copyright 2021-Present Datadog, Inc.
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: rename the new table routing_table.rs

Base automatically changed from nadav/az-aware to nadav/feature-node-based-routing March 9, 2026 18:47
* Add metrics for az-aware ingest

* finally fix that lint issue

* emit a simple metric instead

* rename

* lints
@nadav-govari nadav-govari merged commit 4c35484 into nadav/feature-node-based-routing Mar 9, 2026
4 checks passed
@nadav-govari nadav-govari deleted the nadav/pr6 branch March 9, 2026 18:57
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants