objstore

Dec 10, 2018

Changes in this version

type Bucket

+ Name func() string

Sep 18, 2018

Changes in this version

+ const DirDelim

+ func DeleteDir(ctx context.Context, bkt Bucket, dir string) error

+ func DownloadDir(ctx context.Context, logger log.Logger, bkt BucketReader, src, dst string) error

+ func DownloadFile(ctx context.Context, logger log.Logger, bkt BucketReader, src, dst string) error

+ func EmptyBucket(t testing.TB, ctx context.Context, bkt Bucket)

+ func UploadDir(ctx context.Context, logger log.Logger, bkt Bucket, srcdir, dstdir string) error

+ func UploadFile(ctx context.Context, logger log.Logger, bkt Bucket, src, dst string) error

+ type Bucket interface

+ Delete func(ctx context.Context, name string) error

+ Upload func(ctx context.Context, name string, r io.Reader) error

+ func BucketWithMetrics(name string, b Bucket, r prometheus.Registerer) Bucket

+ type BucketReader interface

+ Exists func(ctx context.Context, name string) (bool, error)

+ Get func(ctx context.Context, name string) (io.ReadCloser, error)

+ GetRange func(ctx context.Context, name string, off, length int64) (io.ReadCloser, error)

+ IsObjNotFoundErr func(err error) bool

+ Iter func(ctx context.Context, dir string, f func(string) error) error