statcache

Documentation

Index

• func NewCachedStatBlobStore(log *zap.Logger, cache Cache, delegate blobstore.Blobs) blobstore.Blobs
• type BadgerCache
  • func NewBadgerCache(log *zap.Logger, dir string) (*BadgerCache, error)
  • func (b *BadgerCache) Close() error
  • func (b *BadgerCache) Delete(ctx context.Context, namespace []byte, key []byte) error
  • func (b *BadgerCache) Get(ctx context.Context, namespace []byte, key []byte) (blobstore.FileInfo, bool, error)
  • func (b *BadgerCache) Set(ctx context.Context, namespace []byte, key []byte, value blobstore.FileInfo) error
• type BlobInfo
  • func (b BlobInfo) Stat(ctx context.Context) (blobstore.FileInfo, error)
• type Cache
• type CachedStatBlobstore
  • func (s *CachedStatBlobstore) Delete(ctx context.Context, ref blobstore.BlobRef) error
  • func (s *CachedStatBlobstore) DeleteWithStorageFormat(ctx context.Context, ref blobstore.BlobRef, formatVer blobstore.FormatVersion) error
  • func (s *CachedStatBlobstore) EmptyTrash(ctx context.Context, namespace []byte, trashedBefore time.Time) (int64, [][]byte, error)
  • func (s *CachedStatBlobstore) Stat(ctx context.Context, ref blobstore.BlobRef) (blobstore.BlobInfo, error)
  • func (s *CachedStatBlobstore) StatWithStorageFormat(ctx context.Context, ref blobstore.BlobRef, formatVer blobstore.FormatVersion) (blobstore.BlobInfo, error)
  • func (s *CachedStatBlobstore) WalkNamespace(ctx context.Context, namespace []byte, startFromPrefix string, ...) error
• type FileInfo
  • func (f FileInfo) ModTime() time.Time
  • func (f FileInfo) Size() int64
• type Lie
  • func (l Lie) Close() error
  • func (l Lie) Delete(ctx context.Context, namespace []byte, key []byte) error
  • func (l Lie) Get(ctx context.Context, namespace []byte, key []byte) (blobstore.FileInfo, bool, error)
  • func (l Lie) Set(ctx context.Context, namespace []byte, key []byte, value blobstore.FileInfo) error

Functions

func NewCachedStatBlobStore

func NewCachedStatBlobStore(log *zap.Logger, cache Cache, delegate blobstore.Blobs) blobstore.Blobs

NewCachedStatBlobStore creates a new cached blobstore.

Types

type BadgerCache

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

BadgerCache implements Cache with saving file size / mod time to badger database.

func NewBadgerCache

func NewBadgerCache(log *zap.Logger, dir string) (*BadgerCache, error)

NewBadgerCache creates a new BadgerCache.

func (*BadgerCache) Close

func (b *BadgerCache) Close() error

Close implements Cache.

func (*BadgerCache) Delete

func (b *BadgerCache) Delete(ctx context.Context, namespace []byte, key []byte) error

Delete implements Cache.

func (*BadgerCache) Get

func (b *BadgerCache) Get(ctx context.Context, namespace []byte, key []byte) (blobstore.FileInfo, bool, error)

Get implements Cache.

func (*BadgerCache) Set

func (b *BadgerCache) Set(ctx context.Context, namespace []byte, key []byte, value blobstore.FileInfo) error

Set implements Cache.

type BlobInfo

type BlobInfo struct {
	blobstore.BlobInfo
	// contains filtered or unexported fields
}

BlobInfo is the cached version of blobstore.Blobinfo.

func (BlobInfo) Stat

func (b BlobInfo) Stat(ctx context.Context) (blobstore.FileInfo, error)

Stat implements blobstore.Blobinfo.

type Cache

type Cache interface {
	Get(ctx context.Context, namespace []byte, key []byte) (blobstore.FileInfo, bool, error)
	Set(ctx context.Context, namespace []byte, key []byte, value blobstore.FileInfo) error
	Delete(ctx context.Context, namespace []byte, key []byte) error
	Close() error
}

Cache can store file metadata (size/mod time) and make it available (quickly).

type CachedStatBlobstore

type CachedStatBlobstore struct {
	blobstore.Blobs
	// contains filtered or unexported fields
}

CachedStatBlobstore implements a blob store, but also manages an external cache for file metadata.

func (*CachedStatBlobstore) Delete

func (s *CachedStatBlobstore) Delete(ctx context.Context, ref blobstore.BlobRef) error

Delete implements blobstore.Blobs.

func (*CachedStatBlobstore) DeleteWithStorageFormat

func (s *CachedStatBlobstore) DeleteWithStorageFormat(ctx context.Context, ref blobstore.BlobRef, formatVer blobstore.FormatVersion) error

DeleteWithStorageFormat implements blobstore.Blobs.

func (*CachedStatBlobstore) EmptyTrash

func (s *CachedStatBlobstore) EmptyTrash(ctx context.Context, namespace []byte, trashedBefore time.Time) (int64, [][]byte, error)

EmptyTrash implements blobstore.Blobs.

func (*CachedStatBlobstore) Stat

func (s *CachedStatBlobstore) Stat(ctx context.Context, ref blobstore.BlobRef) (blobstore.BlobInfo, error)

Stat implements blobstore.Blobs.

func (*CachedStatBlobstore) StatWithStorageFormat

func (s *CachedStatBlobstore) StatWithStorageFormat(ctx context.Context, ref blobstore.BlobRef, formatVer blobstore.FormatVersion) (blobstore.BlobInfo, error)

StatWithStorageFormat implements blobstore.Blobs.

func (*CachedStatBlobstore) WalkNamespace

func (s *CachedStatBlobstore) WalkNamespace(ctx context.Context, namespace []byte, startFromPrefix string, walkFunc func(blobstore.BlobInfo) error) error

WalkNamespace implements blobstore.Blobs.

type FileInfo

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

FileInfo is a simple implementation of blobstore.FileInfo.

func (FileInfo) ModTime

func (f FileInfo) ModTime() time.Time

ModTime implements blobstore.FileInfo.

func (FileInfo) Size

func (f FileInfo) Size() int64

Size implements blobstore.FileInfo.

type Lie

type Lie struct {
}

Lie is a cache implementation with returns with fake values. Do not use in production. Only for performance testing.

func (Lie) Close

func (l Lie) Close() error

Close implements Cache.

func (Lie) Delete

func (l Lie) Delete(ctx context.Context, namespace []byte, key []byte) error

Delete implements Cache.

func (Lie) Get

func (l Lie) Get(ctx context.Context, namespace []byte, key []byte) (blobstore.FileInfo, bool, error)

Get implements Cache.

func (Lie) Set

func (l Lie) Set(ctx context.Context, namespace []byte, key []byte, value blobstore.FileInfo) error

Set implements Cache.