gsadmin/pulse
1
0
Fork 0
mirror of https://github.com/rcourtman/Pulse.git synced 2026-10-23 20:25:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Advance the partial-reporting fixture through due poll cycles

Browse Source 
Drive each modeled response through a due deadline instead of zeroing it, which legitimately reconstructs the existing future cadence. The production scheduling policy is unchanged.

Contract-Neutral: Test-only due-deadline setup for the telemetry pipeline; production polling and API unchanged.
Change-source: pulse-maintainer
This commit is contained in:
pulse-triage[bot]
2026-10-01 03:43:28 +01:00
parent 00ed443d00
commit 5c6e826cc4
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/monitoring/truenas_poller_test.go
+3 -1
View File
@@ -2272,7 +2272,9 @@ func TestTrueNASPartialReportingPipeline(t *testing.T) {
observedAt := time.Now().UTC().Add(-10 * time.Minute).Truncate(time.Second)
for index, cycle := range cycles {
current.Store(int64(index))
poller.ensureConnectionRuntimeStatusLocked("default", instance.ID).nextPollAt = time.Time{}
// Model the next due poll, not an absent deadline: a zero deadline
// is deliberately reconstructed from the previous attempt's cadence.
poller.ensureConnectionRuntimeStatusLocked("default", instance.ID).nextPollAt = time.Now().Add(-time.Second)
poller.pollAll(context.Background())
summary := poller.ConnectionSummaries("default", []config.TrueNASInstance{instance})[instance.ID]
if summary.Poll == nil || summary.Poll.LastSuccessAt == nil || summary.Poll.LastError != nil || summary.Poll.ConsecutiveFailures != 0 || summary.Observed == nil || summary.Observed.StoragePools != 1 {