Function TestImmediateRevCacheItemBasedEviction

db/revision_cache_test.go:1052–1113

(t *testing.T)

}

func TestImmediateRevCacheItemBasedEviction(t *testing.T) {
	testCases := []struct {
		name       string
		UseCVCache bool
	}{
		{
			name:       "Rev cache pathway",
			UseCVCache: false,
		},
		{
			name:       "CV cache pathway",
			UseCVCache: true,
		},
	}
	for _, testCase := range testCases {
		t.Run(testCase.name, func(t *testing.T) {
			cacheHitCounter, cacheMissCounter, getDocumentCounter, getRevisionCounter, cacheNumItems, memoryBytesCounted := base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}
			backingStoreMap := CreateTestSingleBackingStoreMap(&testBackingStore{nil, &getDocumentCounter, &getRevisionCounter}, testCollectionID)
			cacheOptions := &RevisionCacheOptions{
				MaxItemCount: 1,
				MaxBytes:     0, // turn off memory based eviction
			}
			ctx := base.TestCtx(t)
			var err error

			cache := NewLRURevisionCache(cacheOptions, backingStoreMap, &cacheHitCounter, &cacheMissCounter, &cacheNumItems, &memoryBytesCounted)
			// load up item to hit max capacity
			cache.Put(ctx, DocumentRevision{BodyBytes: []byte(`{"some":"test"}`), DocID: "doc1", RevID: "1-abc", CV: &Version{Value: 123, SourceID: "test"}, History: Revisions{"start": 1}}, testCollectionID)

			// eviction starts from here in test
			cache.Put(ctx, DocumentRevision{BodyBytes: []byte(`{"some":"test"}`), DocID: "newDoc", RevID: "1-abc", CV: &Version{Value: 123, SourceID: "test"}, History: Revisions{"start": 1}}, testCollectionID)

			assert.Equal(t, int64(15), memoryBytesCounted.Value())
			assert.Equal(t, int64(1), cacheNumItems.Value())

			cache.Upsert(ctx, DocumentRevision{BodyBytes: []byte(`{"some":"test"}`), DocID: "doc2", RevID: "1-abc", CV: &Version{Value: 123, SourceID: "test"}, History: Revisions{"start": 1}}, testCollectionID)

			assert.Equal(t, int64(15), memoryBytesCounted.Value())
			assert.Equal(t, int64(1), cacheNumItems.Value())

			var docRev DocumentRevision
			if testCase.UseCVCache {
				docRev, err = cache.GetWithCV(ctx, "doc3", &Version{Value: 123, SourceID: "test"}, testCollectionID, RevCacheOmitDelta, false)
				require.NoError(t, err)
			} else {
				docRev, err = cache.GetWithRev(ctx, "doc3", "1-abc", testCollectionID, RevCacheOmitDelta)
				require.NoError(t, err)
			}
			assert.NotNil(t, docRev.BodyBytes)

			assert.Equal(t, int64(118), memoryBytesCounted.Value())
			assert.Equal(t, int64(1), cacheNumItems.Value())

			docRev, err = cache.GetActive(ctx, "doc4", testCollectionID)
			require.NoError(t, err)
			assert.NotNil(t, docRev.BodyBytes)

			assert.Equal(t, int64(118), memoryBytesCounted.Value())