* [client] Clarify that metrics ingest X-Peer-ID is not a credential The ingest endpoint is intentionally unauthenticated: it accepts telemetry from peers of both cloud and self-hosted deployments, and for a self-hosted peer there is no shared trust anchor to authenticate against. The X-Peer-ID header is a correlation tag whose format check exists to bound InfluxDB tag cardinality. Both the function name (validateAuth) and the 401 response implied an authentication control that was never there, which invites the reading that the check can be bypassed. Rename it to validatePeerIDFormat and return 400, matching the other input validation failures in the same handler. Document the intent in the godoc and the infra README. No behavioural change for clients: push.go classifies responses by 2xx range rather than by status code, so 400 and 401 are handled identically. * [client] Reject metrics ingest bodies whose peer_id tag disagrees with the header validateTag checked tag names against the per-measurement allowlist but only bounded the value length, so the peer_id tag was free-form text up to 64 bytes and could differ from the X-Peer-ID header the request was accepted with. Tie the two together: the tag value must equal the header value. Since the header is already checked to be 16 hex characters, this transitively constrains the tag to the same shape. Every client sends the same value in both places (metrics.go feeds agentInfo.peerID to both push.SetPeerID and the body tags), so well-behaved clients are unaffected. The mismatch is rejected rather than silently overwritten: rewriting the value would re-serialize caller-controlled text back into line protocol and would hide misbehaving senders instead of surfacing them. Rejection also matches the other input validation failures in the same handler, which all return 400. This narrows the value space of the peer_id tag but does not by itself bound InfluxDB series cardinality: a sender that puts the same arbitrary 16 hex characters in both the header and the body still passes. Limiting that needs a per-source rate limit in front of the service. * [client] Document what the metrics ingest peer_id check does and does not bound The README described X-Peer-ID as the correlation tag, but grouping is done by the peer_id tag in the submitted line protocol: that is what is forwarded to InfluxDB, while the header only serves as the value each tag is checked against. It also claimed the format check bounds tag cardinality. It bounds the value space of the tag, not the number of distinct series, so state that explicitly and point out that series cardinality has to be limited outside this service. * [client] Set timeouts on the metrics ingest HTTP server The server ran on http.ListenAndServe with no timeouts, silenced with a nolint:gosec for G114. Without ReadHeaderTimeout a client can hold a connection open by sending headers slowly, and without ReadTimeout or IdleTimeout connections accumulate on an endpoint that takes unauthenticated requests. Construct an http.Server with explicit limits instead, which also drops the nolint. Handler stays nil so the existing DefaultServeMux registrations are unaffected. WriteTimeout is deliberately larger than the 10s upstream client timeout: the response is only written after the forward to InfluxDB completes, so a tighter value would cut off the server's own valid response. * Revert "[client] Document what the metrics ingest peer_id check does and does not bound" This reverts commit837a5d8dda. * Revert "[client] Reject metrics ingest bodies whose peer_id tag disagrees with the header" This reverts commit91d4f6128. Tying the body peer_id tag to the X-Peer-ID header assumed the two always agree, but a profile switch breaks that. UpdateAgentInfo swaps agentInfo.peerID and calls push.SetPeerID with the new value while leaving the sample buffer alone, and the peer_id is baked into each buffered line at record time, so samples from the previous profile ship under the new header. The consequences compound: validateLineProtocol rejects the whole batch on the first bad line, so fresh samples are dropped along with the stale ones, and push.go only resets the buffer after a successful push, so the batch is retried and fails again. Metrics from that client stay stuck until the old samples age out of the buffer, up to maxSampleAge (5 days). Deciding whether the previous profile's unsent samples may be discarded, or whether the push has to be partitioned per identity, is a product call, so restore the previous behaviour for now. The header keeps its format check; the body peer_id tag goes back to being bounded only by maxTagValueLength. * [client] Stop claiming the metrics ingest peer ID format check bounds tag cardinality The X-Peer-ID header is never forwarded to InfluxDB; the stored peer_id tag comes from the request body and is constrained only by the tag allowlist and the maximum tag value length. Align the README and the validatePeerIDFormat godoc with the actual behavior after the header/body match check was reverted.
Client Metrics
Internal documentation for the NetBird client metrics system.
Overview
Client metrics track connection performance and sync durations using InfluxDB line protocol (influxdb.go). Each event is pushed once then cleared.
Metrics collection is always active (for debug bundles). Push to backend is:
- Disabled by default (opt-in via
NB_METRICS_PUSH_ENABLED=true) - Managed at daemon layer (survives engine restarts)
Architecture
Layer Separation
Daemon Layer (connect.go)
├─ Creates ClientMetrics instance once
├─ Starts/stops push lifecycle
└─ Updates AgentInfo on profile switch
│
▼
Engine Layer (engine.go)
└─ Records metrics via ClientMetrics methods
Ingest Server
Clients do not talk to InfluxDB directly. An ingest server sits between clients and InfluxDB:
Client ──POST──▶ Ingest Server (:8087) ──▶ InfluxDB (internal)
│
├─ Checks the X-Peer-ID header format
├─ Validates line protocol
├─ Allowlists measurements, fields, and tags
├─ Rejects out-of-bound values
└─ Serves remote config at /config
- Intentionally unauthenticated — the endpoint receives obfuscated telemetry from the peers of both cloud and self-hosted deployments. For a self-hosted peer there is no shared trust anchor with this server, so there is nothing to authenticate against.
X-Peer-IDis a correlation tag, not a credential — it carries the obfuscated peer identifier so samples from one peer can be grouped. The server only checks that the header is well-formed (16 hex chars); a malformed value is rejected with400 Bad Request, not401. Any well-formed value is accepted by design, and the header must not be relied on for access control. The header itself is not forwarded to InfluxDB — the storedpeer_idtag comes from the request body and is constrained only by the tag allowlist and the maximum tag value length.- The InfluxDB token stays server-side — clients never hold a write credential.
- InfluxDB is not exposed — only accessible within the docker network
- Source:
ingest/main.go
Metrics Collected
Connection Stage Timing
Measurement: netbird_peer_connection
| Field | Timestamps | Description |
|---|---|---|
signaling_to_connection_seconds |
SignalingReceived → ConnectionReady |
ICE/relay negotiation time after the first signal is received from the remote peer |
connection_to_wg_handshake_seconds |
ConnectionReady → WgHandshakeSuccess |
WireGuard cryptographic handshake latency once the transport layer is ready |
total_seconds |
SignalingReceived → WgHandshakeSuccess |
End-to-end connection time anchored at the first received signal |
Tags:
deployment_type: "cloud" | "selfhosted" | "unknown"connection_type: "ice_p2p" | "ice_turn" | "relay" (see below)attempt_type: "initial" | "reconnection"version: NetBird version stringos: Operating system (linux, darwin, windows, android, ios, etc.)arch: CPU architecture (amd64, arm64, etc.)peer_id: obfuscated peer identifier (truncated SHA-256 of the WireGuard public key)connection_pair_id: deterministic identifier for the peer pair, identical on both sides
Note: SignalingReceived is set when the first offer or answer arrives from the remote peer (in both initial and reconnection paths). It excludes the potentially unbounded wait for the remote peer to come online.
connection_type values
Derived from the connection priority (conntype.ConnPriority) by metricsConnType in client/internal/peer/conn.go:
| Value | Priority | Traffic is |
|---|---|---|
ice_p2p |
ICEP2P |
direct peer-to-peer |
ice_turn |
ICETurn |
relayed, through a TURN server |
relay |
Relay |
relayed, through a NetBird relay |
unknown |
None or unrecognised |
no active transport — the sample is not pushed |
Direct traffic is ice_p2p only. ice_turn is relayed despite being negotiated by ICE, matching Conn.isRelayed.
None means no transport is active: not established yet, or reset after a relay drop or a peer-state reset. Such a sample cannot be attributed to a transport, so recordConnectionMetrics drops it instead of pushing it — unknown therefore never appears in the bucket. Connection counts are counts of connections whose transport was known at sampling time.
Samples recorded before 0.77 used a single ice value which covered ICEP2P, ICETurn and None, so historical ice samples overstate direct connections by an unknown amount and must not be compared with ice_p2p.
Sync Duration
Measurement: netbird_sync
| Field | Description |
|---|---|
duration_seconds |
Time to process a sync message from management server |
Tags:
deployment_type: "cloud" | "selfhosted" | "unknown"version: NetBird version stringos: Operating system (linux, darwin, windows, android, ios, etc.)arch: CPU architecture (amd64, arm64, etc.)
Sync Phase Timing
Measurement: netbird_sync_phase
Breaks down where time goes inside a single sync, so the total netbird_sync duration can be attributed to the sub-step that dominates.
| Field | Description |
|---|---|
duration_seconds |
Time spent in one sub-phase of sync processing |
Tags:
phase: the sub-phase —netbird_config,checks,persist,dns_server,routes_classify,routes_apply,filtering,dns_forwarder,forward_rules,offline_peers,removed_peers,modified_peers,added_peers,lazy_excludedeployment_type: "cloud" | "selfhosted" | "unknown"version: NetBird version stringos: Operating system (linux, darwin, windows, android, ios, etc.)arch: CPU architecture (amd64, arm64, etc.)
Note: this is wall-time per phase — it includes both CPU work and time spent waiting on locks. A slow phase points to where the time goes, not why; pair it with lock-wait metrics to tell contention apart from real work.
Login Duration
Measurement: netbird_login
| Field | Description |
|---|---|
duration_seconds |
Time to complete the login/auth exchange with management server |
Tags:
deployment_type: "cloud" | "selfhosted" | "unknown"result: "success" | "failure"version: NetBird version stringos: Operating system (linux, darwin, windows, android, ios, etc.)arch: CPU architecture (amd64, arm64, etc.)
Buffer Limits
The InfluxDB backend limits in-memory sample storage to prevent unbounded growth when pushes fail:
- Max age: Samples older than 5 days are dropped
- Max size: Estimated buffer size capped at 5 MB (~20k samples)
Configuration
Client Environment Variables
| Variable | Default | Description |
|---|---|---|
NB_METRICS_PUSH_ENABLED |
false |
Enable metrics push to backend |
NB_METRICS_SERVER_URL |
(from remote config) | Ingest server URL (e.g., https://ingest.netbird.io) |
NB_METRICS_INTERVAL |
(from remote config) | Push interval (e.g., "1m", "30m", "4h") |
NB_METRICS_FORCE_SENDING |
false |
Skip remote config, push unconditionally |
NB_METRICS_CONFIG_URL |
https://ingest.netbird.io/config |
Remote push config URL |
NB_METRICS_SERVER_URL and NB_METRICS_INTERVAL override their respective values but do not bypass remote config eligibility checks (version range). Use NB_METRICS_FORCE_SENDING=true to skip all remote config gating.
Ingest Server Environment Variables
| Variable | Default | Description |
|---|---|---|
INGEST_LISTEN_ADDR |
:8087 |
Listen address |
INFLUXDB_URL |
http://influxdb:8086/api/v2/write?org=netbird&bucket=metrics&precision=ns |
InfluxDB write endpoint |
INFLUXDB_TOKEN |
(required) | InfluxDB auth token (server-side only) |
CONFIG_METRICS_SERVER_URL |
(empty — disables /config) | server_url in the remote config JSON (the URL clients push metrics to) |
CONFIG_VERSION_SINCE |
0.0.0 |
Minimum client version to push metrics |
CONFIG_VERSION_UNTIL |
99.99.99 |
Maximum client version to push metrics |
CONFIG_PERIOD_MINUTES |
5 |
Push interval in minutes |
The ingest server serves a remote config JSON at GET /config when CONFIG_METRICS_SERVER_URL is set. Clients can use NB_METRICS_CONFIG_URL=http://<ingest>/config to fetch it.
Configuration Precedence
For URL and Interval, the precedence is:
- Environment variable -
NB_METRICS_SERVER_URL/NB_METRICS_INTERVAL - Remote config - fetched from
NB_METRICS_CONFIG_URL - Default - 5 minute interval, URL from remote config
Push Behavior
StartPush()spawns background goroutine with timer- First push happens immediately on startup
- Periodically:
push()→Export()→ HTTP POST to ingest server - On failure: log error, continue (non-blocking)
- On success:
Reset()clears pushed samples StopPush()cancels context and waits for goroutine
Samples are collected with exact timestamps, pushed once, then cleared. No data is resent.
Local Development Setup
1. Configure and Start Services
# From this directory (client/internal/metrics/infra)
cp .env.example .env
# Edit .env to set INFLUXDB_ADMIN_PASSWORD, INFLUXDB_ADMIN_TOKEN, and GRAFANA_ADMIN_PASSWORD
docker compose up -d
This starts:
- Ingest server on http://localhost:8087 — accepts client metrics (unauthenticated by design; expects a well-formed
X-Peer-IDcorrelation tag) - InfluxDB — internal only, not exposed to host
- Grafana on http://localhost:3001
2. Configure Client
export NB_METRICS_PUSH_ENABLED=true
export NB_METRICS_FORCE_SENDING=true
export NB_METRICS_SERVER_URL=http://localhost:8087
export NB_METRICS_INTERVAL=1m
3. Run Client
cd ../../../..
go run ./client/ up
4. View in Grafana
- InfluxDB dashboard: http://localhost:3001/d/netbird-influxdb-metrics
5. Verify Data
# Query via InfluxDB (using admin token from .env)
docker compose exec influxdb influx query \
'from(bucket: "metrics") |> range(start: -1h)' \
--org netbird
# Check ingest server health
curl http://localhost:8087/health
Analyzing a Debug Bundle
Metrics collection is always on, so every debug bundle ships a metrics.txt in InfluxDB line protocol — a timestamped time series of all recorded events (sync durations, sync phases, connection stages, login). You can replay it into the local stack and graph it, without a running client.
The bundle's metrics.txt is a rolling window (capped at 5 days / ~20k samples, see Buffer Limits). For a connection incident the relevant window is short (connection setup is seconds), so a bundle captured during the issue is enough.
1. Start the stack
# From this directory (client/internal/metrics/infra)
INFLUXDB_ADMIN_TOKEN=admin123 INFLUXDB_ADMIN_PASSWORD=admin123 GRAFANA_ADMIN_PASSWORD=admin123 \
docker compose up -d
(admin123 are throwaway local credentials — fine for offline analysis.)
2. Clear any previous data
So you only see this bundle:
docker exec influxdb influx delete --org netbird --bucket metrics --token admin123 \
--start 1970-01-01T00:00:00Z --stop 2100-01-01T00:00:00Z
3. Import the bundle's metrics.txt
InfluxDB is not exposed on the host, so import inside the container:
docker cp /path/to/bundle/metrics.txt influxdb:/tmp/m.txt
docker exec influxdb influx write --org netbird --bucket metrics --precision ns \
--token admin123 --file /tmp/m.txt
Re-importing the same file is idempotent (same measurement+tags+timestamp overwrites).
4. View the dashboards
Grafana on http://localhost:3001 (login admin / admin123), datasource pre-provisioned:
- Where sync time goes: http://localhost:3001/d/netbird-sync-phases/netbird-sync-phases-where-time-goes
- General client metrics: http://localhost:3001/d/netbird-influxdb-metrics
Set the time range to cover the bundle's timestamps (e.g. "Last 7 days" or an absolute range matching when the bundle was taken) — with the default short range the panels look empty.
Bundles are distinguishable by the version tag; add a tag at import time (e.g. sed 's/^netbird_\([a-z_]*\),/netbird_\1,bundle=mycase,/' metrics.txt) if you want to compare several side by side.