Function TestBypassSingleChannelCache

db/channel_cache_single_test.go:691–717

(t *testing.T)

}

func TestBypassSingleChannelCache(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelInfo, base.KeyCache)

	terminator := make(chan bool)
	defer close(terminator)

	// Seed the query handler with 100 docs across 10 channels
	queryHandler := &testQueryHandler{}
	for seq := 1; seq <= 100; seq++ {
		channelName := fmt.Sprintf("chan_%d", seq%10)
		queryEntry := testLogEntryForChannels(seq, []string{channelName})
		queryHandler.seedEntries(LogEntries{queryEntry})
	}

	bypassCache := &bypassChannelCache{
		channel:      channels.NewID("chan_1", base.DefaultCollectionID),
		queryHandler: queryHandler,
	}

	entries, err := bypassCache.GetChanges(base.TestCtx(t), getChangesOptionsWithZeroSeq(t))
	assert.NoError(t, err)
	require.Len(t, entries, 10)

	validFrom, cachedEntries := bypassCache.GetCachedChanges(getChangesOptionsWithZeroSeq(t))
	assert.Equal(t, uint64(math.MaxUint64), validFrom)
	require.Len(t, cachedEntries, 0)
}

func BenchmarkChannelCacheUniqueDocs_Ordered(b *testing.B) {