From 96e6091dbe5e1d0f0110f3a0b8f3d74885d2de13 Mon Sep 17 00:00:00 2001 From: Nik Weidenbacher Date: Fri, 27 Feb 2026 18:24:27 +0000 Subject: [PATCH] internet-latency-collector: increase RIPE Atlas sampling interval to 10m --- CHANGELOG.md | 2 ++ .../internet-latency-collector/cmd/collector/main.go | 6 +++--- .../internal/ripeatlas/collector_test.go | 8 ++++---- 3 files changed, 9 insertions(+), 7 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index da84c5837..7ccb33d0d 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -39,6 +39,8 @@ All notable changes to this project will be documented in this file. - SetFeatureFlagCommand added to manage on-chain feature flags for conditional behavior rollouts - Dependencies - Upgrade Solana SDK workspace dependencies from 2.2.7 to 2.3.x (`solana-sdk`, `solana-client`, `solana-program-test`, and others) +- Internet telemetry + - Reduce RIPE Atlas sampling interval from 6 minutes to 10 minutes to work around service limit of 100_000 samples per day ## [v0.8.11](https://github.com/malbeclabs/doublezero/compare/client/v0.8.10...client/v0.8.11) - 2026-02-27 diff --git a/controlplane/internet-latency-collector/cmd/collector/main.go b/controlplane/internet-latency-collector/cmd/collector/main.go index 4f0e1b194..84d0a5a0c 100644 --- a/controlplane/internet-latency-collector/cmd/collector/main.go +++ b/controlplane/internet-latency-collector/cmd/collector/main.go @@ -29,9 +29,9 @@ import ( const ( defaultStateDir = "/var/lib/doublezero-internet-latency-collector/state" defaultAtlasProbesPerLocation = 1 - defaultRipeAtlasSamplingInterval = 6 * time.Minute + defaultRipeAtlasSamplingInterval = 10 * time.Minute defaultRipeAtlasMeasurementInterval = 1 * time.Hour - defaultRipeAtlasExportInterval = 6 * time.Minute + defaultRipeAtlasExportInterval = 10 * time.Minute defaultWheresitupSamplingInterval = 6 * time.Minute defaultLedgerSubmissionInterval = 1 * time.Minute defaultWheresitupStateFile = "wheresitup_jobs_to_process.json" @@ -94,7 +94,7 @@ var runCmd = &cobra.Command{ Use: "run", Short: "Run ongoing data collection operations (service mode)", Long: `Run continuous collector that creates WhereItUp jobs every interval, -RIPE Atlas measurements hourly, and exports RIPE Atlas results every 2 minutes.`, +RIPE Atlas measurements hourly, and exports RIPE Atlas results periodically.`, Run: func(cmd *cobra.Command, args []string) { log := collector.NewLogger(collector.LogLevel(logLevel)) diff --git a/controlplane/internet-latency-collector/internal/ripeatlas/collector_test.go b/controlplane/internet-latency-collector/internal/ripeatlas/collector_test.go index a307eda11..6450ec8a2 100644 --- a/controlplane/internet-latency-collector/internal/ripeatlas/collector_test.go +++ b/controlplane/internet-latency-collector/internal/ripeatlas/collector_test.go @@ -852,8 +852,8 @@ func TestInternetLatency_RIPEAtlas_ExpectedDailyCreditsMetric(t *testing.T) { }, } - // Test with 6 minute interval (240 samples per day) - samplingInterval := 6 * time.Minute + // Test with 10 minute interval (144 samples per day) + samplingInterval := 10 * time.Minute err := c.RunRipeAtlasMeasurementCreation(t.Context(), false, 1, t.TempDir(), samplingInterval) require.NoError(t, err) @@ -862,11 +862,11 @@ func TestInternetLatency_RIPEAtlas_ExpectedDailyCreditsMetric(t *testing.T) { // - lon gets measurement from nyc (1 source) // - nyc gets no measurements (0 sources) // Total sources = 2 + 1 + 0 = 3 - // Expected daily credits = 3 sources * 240 samples/day = 720 + // Expected daily credits = 3 sources * 144 samples/day = 432 // Note: We can't directly check the metric value in tests, but we can verify // the log output contains the expected calculation - t.Log("Test completed - metric should show 720 expected daily credits") + t.Log("Test completed - metric should show 432 expected daily credits") } func TestInternetLatency_RIPEAtlas_RunRipeAtlasMeasurementCreation(t *testing.T) {