sharded

Documentation

Index

• type Impl
• type Storage
  • func (s Storage) DeleteBlob(ctx context.Context, blobID blob.ID) error
  • func (s Storage) GetBlob(ctx context.Context, blobID blob.ID, offset, length int64) ([]byte, error)
  • func (s Storage) GetShardedPathAndFilePath(blobID blob.ID) (shardPath, filePath string)
  • func (s Storage) ListBlobs(ctx context.Context, prefix blob.ID, callback func(blob.Metadata) error) error
  • func (s Storage) PutBlob(ctx context.Context, blobID blob.ID, data []byte) error

Types

type Impl

type Impl interface {
	GetBlobFromPath(ctx context.Context, dirPath, filePath string, offset, length int64) ([]byte, error)
	PutBlobInPath(ctx context.Context, dirPath, filePath string, data []byte) error
	DeleteBlobInPath(ctx context.Context, dirPath, filePath string) error
	ReadDir(ctx context.Context, path string) ([]os.FileInfo, error)
}

type Storage

type Storage struct {
	Impl Impl

	RootPath string
	Suffix   string
	Shards   []int
}

func (Storage) DeleteBlob

func (s Storage) DeleteBlob(ctx context.Context, blobID blob.ID) error

func (Storage) GetBlob

func (s Storage) GetBlob(ctx context.Context, blobID blob.ID, offset, length int64) ([]byte, error)

func (Storage) GetShardedPathAndFilePath

func (s Storage) GetShardedPathAndFilePath(blobID blob.ID) (shardPath, filePath string)

func (Storage) ListBlobs

func (s Storage) ListBlobs(ctx context.Context, prefix blob.ID, callback func(blob.Metadata) error) error

func (Storage) PutBlob

func (s Storage) PutBlob(ctx context.Context, blobID blob.ID, data []byte) error