Method getPartialCacheHit

internal/cache/persistent_lru_cache.go:98–114

(ctx context.Context, key string, length int64, output *gather.WriteBuffer)

}

func (c *PersistentCache) getPartialCacheHit(ctx context.Context, key string, length int64, output *gather.WriteBuffer) {
	// cache hit
	c.reportHitBytes(int64(output.Length()))

	mtime, err := c.cacheStorage.TouchBlob(ctx, blob.ID(key), c.sweep.TouchThreshold)

	c.listCacheMutex.Lock()
	defer c.listCacheMutex.Unlock()

	if err == nil {
		c.listCache.AddOrUpdate(blob.Metadata{
			BlobID:    blob.ID(key),
			Length:    length,
			Timestamp: mtime,
		})
	}
}

func (c *PersistentCache) deleteInvalidBlob(ctx context.Context, key string) {
	if err := c.cacheStorage.DeleteBlob(ctx, blob.ID(key)); err != nil && !errors.Is(err, blob.ErrBlobNotFound) {