vinzenz/hyperhive
vinzenz/hyperhive
Watch
0
0
Fork
You've already forked hyperhive
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

otel: add deltatocumulative processor to the hive collector pipeline

Browse source 
hive-metric counters are delta by default; VictoriaMetrics has no
delta-to-cumulative processor of its own and official guidance is to
feed it cumulative. Converting at the hive tier, closest to the
origin, means every downstream consumer (swarm tier, VictoriaMetrics,
upstream) sees ordinary cumulative counters and existing PromQL idioms
(rate()/increase()) keep working unchanged. Default config is a no-op
passthrough for anything already cumulative (Claude Code's own export,
hostmetrics, Prometheus scrapes) -- verified against the actual
collector binary (otelcol-contrib validate), not assumed: an empty
config validates clean, an invalid key is rejected.
This commit is contained in:
damocles 2026-08-30 19:58:06 +02:00
commit a7b0ae7b8c
1 changed files with 18 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

20
nix/host-modules/otel.nix
View file

@ -489,6 +489,18 @@ in
};
};
# Converts any DELTA-temporality counter to CUMULATIVE before it
# leaves this hive. `hive-metric` counters are delta by default
# (agent ergonomics — see its own docs); the swarm's store
# (VictoriaMetrics) has no `deltatocumulative` of its own and
# official guidance is to feed it cumulative. Default config
# (`{ }`) is a no-op passthrough for anything already cumulative
# — Claude Code's own export, `hostmetrics`, and any Prometheus
# scrape all stay exactly as they were. Verified against the
# collector binary rather than assumed: an empty config validates
# clean, an invalid key is rejected (`otelcol-contrib validate`).
processors.deltatocumulative = { };
service.pipelines.metrics = {
# EXTENDED, not replaced. Assigning here instead of appending
# would drop `otlp` — the hive would stop receiving from its
@ -512,8 +524,12 @@ in
# samples scraped from a target both arrive at the store with
# the identity of the machine that collected them, and a
# reading is only comparable across hives once it says where
# it came from.
processors = [ "resourcedetection" ];
# it came from. `deltatocumulative` first, so a delta counter is
# already fixed up by the time it picks up its host identity.
processors = [
"deltatocumulative"
"resourcedetection"
];
exporters = [ swarmName ];
};
}