objstore

Jun 12, 2023

Changes in this version

type Bucket

+ func NewBucket(bkt objstore.Bucket) Bucket

+ func NewPrefixedBucket(bkt Bucket, prefix string) Bucket

type BucketReader

+ ReaderAt func(ctx context.Context, filename string) (ReaderAtCloser, error)

+ type GetRangeReader interface

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

+ type PrefixedBucket struct

+ func (p *PrefixedBucket) Close() error

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

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

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

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

+ func (p *PrefixedBucket) IsObjNotFoundErr(err error) bool

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

+ func (p *PrefixedBucket) Name() string

+ func (p *PrefixedBucket) Prefix() string

+ func (p *PrefixedBucket) ReaderAt(ctx context.Context, name string) (ReaderAtCloser, error)

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

+ func (p PrefixedBucket) Attributes(ctx context.Context, name string) (objstore.ObjectAttributes, error)

type ReaderAt

+ func (b *ReaderAt) Close() error

+ func (b *ReaderAt) ReadAt(p []byte, off int64) (int, error)

+ type ReaderAtBucket struct

+ func (b *ReaderAtBucket) ReaderAt(ctx context.Context, name string) (ReaderAtCloser, error)

+ type ReaderAtCloser interface

Oct 26, 2022

Changes in this version

+ func DeletePrefix(ctx context.Context, bkt objstore.Bucket, prefix string, logger log.Logger) (int, error)

+ func NewDelayedBucketClient(wrapped objstore.Bucket, minDelay, maxDelay time.Duration) objstore.Bucket

+ type Bucket interface

+ ReaderAt func(ctx context.Context, filename string) (ReaderAt, error)

+ func BucketWithPrefix(b Bucket, prefix string) Bucket

+ type BucketReader interface

+ func BucketReaderWithPrefix(r BucketReader, prefix string) BucketReader

+ type DelayedBucketClient struct

+ func (m *DelayedBucketClient) Attributes(ctx context.Context, name string) (objstore.ObjectAttributes, error)

+ func (m *DelayedBucketClient) Close() error

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

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

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

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

+ func (m *DelayedBucketClient) IsObjNotFoundErr(err error) bool

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

+ func (m *DelayedBucketClient) Name() string

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

+ type InstrumentedBucket interface

+ ReaderWithExpectedErrs func(objstore.IsOpFailureExpectedFunc) BucketReader

+ WithExpectedErrs func(objstore.IsOpFailureExpectedFunc) Bucket

+ func NewMetricBucket(bkt Bucket, reg prometheus.Registerer) InstrumentedBucket

+ func NewTracingBucket(bkt Bucket) InstrumentedBucket

+ type MetricBucket struct

+ func (t MetricBucket) ReaderAt(ctx context.Context, name string) (r ReaderAt, err error)

+ func (t MetricBucket) ReaderWithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) BucketReader

+ func (t MetricBucket) WithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) Bucket

+ type ReaderAt interface

+ Size func() int64

+ type ReaderAtCreator interface

+ ReaderAt func(ctx context.Context, filename string) (ReaderAt, error)

+ type SSEBucketClient struct

+ func NewSSEBucketClient(userID string, bucket objstore.Bucket, cfgProvider TenantConfigProvider) *SSEBucketClient

+ func (b *SSEBucketClient) Attributes(ctx context.Context, name string) (objstore.ObjectAttributes, error)

+ func (b *SSEBucketClient) Close() error

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

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

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

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

+ func (b *SSEBucketClient) IsObjNotFoundErr(err error) bool

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

+ func (b *SSEBucketClient) Name() string

+ func (b *SSEBucketClient) ReaderWithExpectedErrs(fn objstore.IsOpFailureExpectedFunc) objstore.BucketReader

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

+ func (b *SSEBucketClient) WithExpectedErrs(fn objstore.IsOpFailureExpectedFunc) objstore.Bucket

+ type TenantConfigProvider interface

+ S3SSEKMSEncryptionContext func(userID string) string

+ S3SSEKMSKeyID func(userID string) string

+ S3SSEType func(userID string) string

+ type TracingBucket struct

+ func (t TracingBucket) ReaderAt(ctx context.Context, name string) (r ReaderAt, err error)

+ func (t TracingBucket) ReaderWithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) BucketReader

+ func (t TracingBucket) WithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) Bucket