cacher

Documentation

Overview

Package cacher provides various blobref fetching caching mechanisms.

Index

• type CachingFetcher
  • func NewCachingFetcher(cache blobserver.Cache, fetcher blob.StreamingFetcher) *CachingFetcher
  • func (cf *CachingFetcher) Fetch(br blob.Ref) (file types.ReadSeekCloser, size int64, err error)
  • func (cf *CachingFetcher) FetchStreaming(br blob.Ref) (file io.ReadCloser, size int64, err error)
• type DiskCache
  • func NewDiskCache(fetcher blob.StreamingFetcher) (*DiskCache, error)
  • func (dc *DiskCache) Clean()

Types

type CachingFetcher

type CachingFetcher struct {
	// contains filtered or unexported fields
}

A CachingFetcher is a blob.StreamingFetcher and a blob.SeekFetcher.

func NewCachingFetcher

func NewCachingFetcher(cache blobserver.Cache, fetcher blob.StreamingFetcher) *CachingFetcher

NewCachingFetcher returns a CachingFetcher that fetches from fetcher and writes to and serves from cache.

func (*CachingFetcher) Fetch

func (cf *CachingFetcher) Fetch(br blob.Ref) (file types.ReadSeekCloser, size int64, err error)

func (*CachingFetcher) FetchStreaming

func (cf *CachingFetcher) FetchStreaming(br blob.Ref) (file io.ReadCloser, size int64, err error)

type DiskCache

type DiskCache struct {
	*CachingFetcher

	// Root is the temp directory being used to store files.
	// It is available mostly for debug printing.
	Root string
	// contains filtered or unexported fields
}

A DiskCache is a blob.StreamingFetcher and blob.SeekFetcher that serves from a local temp directory and is backed by a another blob.StreamingFetcher (usually the pkg/client HTTP client).

func NewDiskCache

func NewDiskCache(fetcher blob.StreamingFetcher) (*DiskCache, error)

NewDiskCache returns a new DiskCache from a StreamingFetcher, which is usually the pkg/client HTTP client (which typically has much higher latency and lower bandwidth than local disk).

func (*DiskCache) Clean

func (dc *DiskCache) Clean()

Clean cleans some or all of the DiskCache.