Documentation
¶
Index ¶
- type DiskCache
- func (c *DiskCache) Contains(ctx context.Context, d *repb.Digest) (bool, error)
- func (c *DiskCache) ContainsMulti(ctx context.Context, digests []*repb.Digest) (map[*repb.Digest]bool, error)
- func (c *DiskCache) Delete(ctx context.Context, d *repb.Digest) error
- func (c *DiskCache) Get(ctx context.Context, d *repb.Digest) ([]byte, error)
- func (c *DiskCache) GetMulti(ctx context.Context, digests []*repb.Digest) (map[*repb.Digest][]byte, error)
- func (c *DiskCache) Reader(ctx context.Context, d *repb.Digest, offset int64) (io.Reader, error)
- func (c *DiskCache) Set(ctx context.Context, d *repb.Digest, data []byte) error
- func (c *DiskCache) SetMulti(ctx context.Context, kvs map[*repb.Digest][]byte) error
- func (c *DiskCache) Start() error
- func (c *DiskCache) Stop() error
- func (c *DiskCache) WithPrefix(prefix string) interfaces.Cache
- func (c *DiskCache) Writer(ctx context.Context, d *repb.Digest) (io.WriteCloser, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DiskCache ¶
type DiskCache struct {
// contains filtered or unexported fields
}
Blobstore is *almost* sufficient here, but blobstore doesn't handle record expirations in a way that make sense for a cache. So we keep a record (in memory) of file atime (Last Access Time) and size, and then when our cache reaches fullness we remove the most stale files. Rather than serialize this ledger, we regenerate it from scratch on startup by looking at the filesystem itself.
func (*DiskCache) ContainsMulti ¶
func (*DiskCache) WithPrefix ¶
func (c *DiskCache) WithPrefix(prefix string) interfaces.Cache
Source Files
Click to show internal directories.
Click to hide internal directories.