Function TestManager_UnchangedFileDoesntTriggerReload

runtimeconfig/manager_test.go:717–753

(t *testing.T)

}

func TestManager_UnchangedFileDoesntTriggerReload(t *testing.T) {
	reloadPeriod := 100 * time.Millisecond

	cfg := newTestOverridesManagerConfig(t, reloadPeriod, nil)

	synctest.Test(t, func(t *testing.T) {
		loadCounter := atomic.NewInt32(0)
		cfg.Loader = func(reader io.Reader) (interface{}, error) {
			loadCounter.Inc()
			return valueLoader(reader)
		}

		overridesManager, err := New(cfg, "overrides", nil, log.NewNopLogger())
		require.NoError(t, err)

		ch := overridesManager.CreateListenerChannel(10) // must be big enough to hold all modifications.

		require.NoError(t, services.StartAndAwaitRunning(context.Background(), overridesManager))

		time.Sleep(reloadPeriod + time.Millisecond)
		synctest.Wait()
		require.Equal(t, int32(1), loadCounter.Load())

		// Let's make some modifications to the config
		const mods = 3
		for i := 0; i < mods; i++ {
			writeValueToFile(t, cfg.LoadPath[0], value{Value: i})
			time.Sleep(reloadPeriod + time.Millisecond)
			synctest.Wait()
		}

		require.NoError(t, services.StopAndAwaitTerminated(context.Background(), overridesManager))

		assert.Equal(t, mods+1, int(loadCounter.Load())) // + 1 for initial load, before modifications
		assert.Equal(t, mods+1, len(ch))                 // Loaded values
	})
}

func TestManager_GetConfigNilBeforeStarting(t *testing.T) {
	cfg := newTestOverridesManagerConfig(t, time.Second, valueLoader)