Function TestCounterInt64_IsStale

data/shared_state_variable_test.go:564–598

(t *testing.T)

}

func TestCounterInt64_IsStale(t *testing.T) {
	tests := []struct {
		name          string
		lastProcessed time.Time
		staleness     time.Duration
		expected      bool
	}{
		{
			name:          "not stale",
			lastProcessed: time.Now(),
			staleness:     time.Second,
			expected:      false,
		},
		{
			name:          "stale",
			lastProcessed: time.Now().Add(-2 * time.Second),
			staleness:     time.Second,
			expected:      true,
		},
		{
			name:          "exactly at staleness threshold",
			lastProcessed: time.Now().Add(-time.Second),
			staleness:     time.Second,
			expected:      true,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			counter := &counterInt64{}
			counter.updatedAtUnixMs.Store(tt.lastProcessed.UnixMilli())
			assert.Equal(t, tt.expected, counter.IsStale(tt.staleness))
		})
	}
}

// Test that calling setValue directly (as done by remote update watchers or initial value fetch) refreshes the
// internal lastUpdated timestamp so that subsequent IsStale checks reflect the recent update.