Function TestCounterInt64_SetValueUpdatesLastUpdated

data/shared_state_variable_test.go:602–619

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.

(t *testing.T)

// 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.
func TestCounterInt64_SetValueUpdatesLastUpdated(t *testing.T) {
	counter := &counterInt64{
		ignoreRollbackOf: 1024,
		registry: &sharedStateRegistry{
			logger: &log.Logger,
		},
	}

	// Simulate a write originating from the remote sync by calling setValue directly.
	counter.processNewValue(UpdateSourceTest, 123)

	// Immediately after the write the counter must not be considered stale for any reasonable staleness window.
	assert.False(t, counter.IsStale(time.Second), "counter should not be stale right after setValue call")

	// After advancing the clock beyond the staleness window the value should be considered stale.
	time.Sleep(15 * time.Millisecond)
	assert.True(t, counter.IsStale(10*time.Millisecond), "counter should become stale once the window elapses")
}

func TestCounterInt64_TryUpdate_RollbackLogic(t *testing.T) {
	tests := []struct {