Function TestSourceLoader_Read_DataChanges

pkg/server/source_loader_test.go:128–161

(t *testing.T)

}

func TestSourceLoader_Read_DataChanges(t *testing.T) {
	t.Parallel()
	synctest.Test(t, func(t *testing.T) {
		inner := &mockSource{
			name: "test.yaml",
			data: []byte("initial data"),
		}
		ctx := t.Context()
		refreshInterval := 50 * time.Millisecond
		sl := newSourceLoader(ctx, inner, refreshInterval)

		// First read gets initial data
		data, err := sl.Read(ctx)
		require.NoError(t, err)
		assert.Equal(t, []byte("initial data"), data)

		// Change the data in the mock
		inner.setData([]byte("updated data"))

		// Immediate read still gets old cached data
		data, err = sl.Read(ctx)
		require.NoError(t, err)
		assert.Equal(t, []byte("initial data"), data)

		synctest.Wait()
		time.Sleep(60 * time.Millisecond) //nolint:forbidigo // fake time inside a synctest bubble; returns instantly
		synctest.Wait()

		// Read after interval should get updated data from background refresh
		data, err = sl.Read(ctx)
		require.NoError(t, err)
		assert.Equal(t, []byte("updated data"), data)
	})
}

func TestSourceLoader_Read_ZeroRefreshInterval(t *testing.T) {
	t.Parallel()