Method Upsert

db/revision_cache_lru.go:336–353

Upsert a revision in the cache.

(ctx context.Context, docRev DocumentRevision, collectionID uint32)

// Upsert a revision in the cache.
func (rc *LRURevisionCache) Upsert(ctx context.Context, docRev DocumentRevision, collectionID uint32) {
	// similar to PUT operation we should have the CV defined by this point (updateHLV is called before calling this)
	key := IDandCV{DocID: docRev.DocID, Source: docRev.CV.SourceID, Version: docRev.CV.Value, CollectionID: collectionID}
	legacyKey := IDAndRev{DocID: docRev.DocID, RevID: docRev.RevID, CollectionID: collectionID}

	numItemsRemoved, value := rc.upsertDocToCache(ctx, key, legacyKey, docRev, collectionID)
	if numItemsRemoved > 0 {
		rc.cacheNumItems.Add(-numItemsRemoved)
	}

	docRev.CalculateBytes()
	// add new item bytes to overall count
	rc.incrRevCacheMemoryUsage(ctx, docRev.MemoryBytes)
	value.store(docRev)

	// check we aren't over memory capacity, if so perform eviction
	rc.revCacheMemoryBasedEviction(ctx)
}

func (rc *LRURevisionCache) upsertDocToCache(ctx context.Context, cvKey IDandCV, legacyKey IDAndRev, docRev DocumentRevision, collectionID uint32) (int64, *revCacheValue) {
	rc.lock.Lock()