Documentation
¶
Overview ¶
Package cacher provides various blobref fetching caching mechanisms.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
}
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).
Source Files
Click to show internal directories.
Click to hide internal directories.