Method AddOrUpdate

internal/cache/persistent_lru_cache.go:253–264

(bm blob.Metadata)

}

func (h *contentMetadataHeap) AddOrUpdate(bm blob.Metadata) {
	if i, exists := h.index[bm.BlobID]; exists {
		// only accept newer timestamps
		if bm.Timestamp.After(h.data[i].Timestamp) {
			h.totalDataBytes += bm.Length - h.data[i].Length
			h.data[i] = bm
			heap.Fix(h, i)
		}
	} else {
		heap.Push(h, bm)
	}
}

func (h *contentMetadataHeap) Pop() any {
	old := h.data