Function flush_ilp_batch

nodedb/src/control/server/ilp_batch.rs:73–85

Dispatch an ILP batch to the Data Plane with series-aware routing. Groups lines by `(measurement, sorted_tags)` hash to route each series to a deterministic core. This eliminates cross-core contention: each core owns a subset of series. For batches with a single measurement (common case), all lines go to one dispatch — no overhead from grouping.

(
    state: &SharedState,
    tenant_id: TenantId,
    batch: &str,
)

/// For batches with a single measurement (common case), all lines go to
/// one dispatch — no overhead from grouping.
pub(super) async fn flush_ilp_batch(
    state: &SharedState,
    tenant_id: TenantId,
    batch: &str,
) -> crate::Result<u64> {
    // Quota enforcement — reject before WAL append or dispatch.
    state.check_tenant_quota(tenant_id)?;
    state.tenant_request_start(tenant_id);

    let result = flush_ilp_batch_inner(state, tenant_id, batch).await;
    state.tenant_request_end(tenant_id);
    result
}

/// Inner dispatch logic for ILP batch (separated for clean quota bookkeeping).
async fn flush_ilp_batch_inner(