Function BenchmarkDocChanged

db/change_cache_test.go:1919–2008

Cases for DocChanged benchmarking - single thread, ordered sequence arrival, non-initialized cache, 100 channels - single thread, ordered sequence arrival, initialized cache, 100 channels - single thread, unordered sequence arrival, non-initialized cache, 100 channels - single thread, unordered sequ

(b *testing.B)

//   - non-unique doc ids?

func BenchmarkDocChanged(b *testing.B) {
	base.SetUpBenchmarkLogging(b, base.LevelError, base.KeyCache, base.KeyChanges)
	processEntryBenchmarks := []struct {
		name           string
		feed           *testDocChangedFeed
		warmCacheCount int
	}{
		{
			"SingleThread_OrderedFeed_NoActiveChannels",
			NewTestDocChangedFeed(100, 1),
			0,
		},
		{
			"SingleThread_OrderedFeed_ActiveChannels",
			NewTestDocChangedFeed(100, 1),
			100,
		},
		{
			"SingleThread_OrderedFeed_ManyActiveChannels",
			NewTestDocChangedFeed(35000, 1),
			35000,
		},
		{
			"SingleThread_NonOrderedFeed_NoActiveChannels",
			NewTestDocChangedFeed(100, 10),
			0,
		},
		{
			"SingleThread_NonOrderedFeed_ActiveChannels",
			NewTestDocChangedFeed(100, 10),
			100,
		},
		{
			"SingleThread_NonOrderedFeed_ManyActiveChannels",
			NewTestDocChangedFeed(35000, 10),
			35000,
		},
	}

	for _, bm := range processEntryBenchmarks {
		b.Run(bm.name, func(b *testing.B) {
			ctx := base.TestCtx(b)
			context, err := NewDatabaseContext(ctx, "db", base.GetTestBucket(b), false, DatabaseContextOptions{})
			require.NoError(b, err)
			defer context.Close(ctx)

			err = context.StartOnlineProcesses(ctx)
			require.NoError(b, err)

			collection := GetSingleDatabaseCollection(b, context)
			collectionID := collection.GetCollectionID()

			ctx = context.AddDatabaseLogContext(ctx)
			changeCache := &changeCache{}
			if err := changeCache.Init(ctx, context, context.channelCache, nil, nil, context.MetadataKeys); err != nil {
				log.Printf("Init failed for changeCache: %v", err)
				b.Fail()
			}