Method getFromCacheByRev

db/revision_cache_lru.go:209–235

(ctx context.Context, docID, revID string, collectionID uint32, loadOnCacheMiss, includeDelta bool)

}

func (rc *LRURevisionCache) getFromCacheByRev(ctx context.Context, docID, revID string, collectionID uint32, loadOnCacheMiss, includeDelta bool) (DocumentRevision, error) {
	value := rc.getValue(ctx, docID, revID, collectionID, loadOnCacheMiss)
	if value == nil {
		return DocumentRevision{}, nil
	}

	// for revID pathway we should always load from backup if required
	docRev, statEvent, err := value.load(ctx, rc.backingStores[collectionID], includeDelta, true)
	rc.statsRecorderFunc(statEvent)

	if !statEvent && err == nil {
		// cache miss so we had to load doc, increment memory count
		rc.incrRevCacheMemoryUsage(ctx, value.getItemBytes())
		// check for memory based eviction
		rc.revCacheMemoryBasedEviction(ctx)
		// given err is nil if we get to this code we can safely assign error returned from addToHLVMapPostLoad to err
		// and in the event we do error adding to the HLV map post load we will remove the value from the rev cache below
		// and return the error to the caller
		rc.addToHLVMapPostLoad(ctx, docID, docRev.RevID, docRev.CV, collectionID)
	}

	if err != nil {
		rc.removeValue(value, collectionID) // don't keep failed loads in the cache
	}

	return docRev, err
}

func (rc *LRURevisionCache) getFromCacheByCV(ctx context.Context, docID string, cv *Version, collectionID uint32, loadCacheOnMiss bool, includeDelta bool, loadBackup bool) (DocumentRevision, error) {
	value := rc.getValueByCV(ctx, docID, cv, collectionID, loadCacheOnMiss)