Versions in this module Expand all Collapse all v3 v3.0.1 Mar 21, 2022 v3.0.0 Mar 21, 2022 Changes in this version + const Azure + const Filesystem + const GCS + const S3 + const Swift + var ErrUnsupportedStorageBackend = errors.New("unsupported storage backend") + var SupportedBackends = []string + func NewClient(ctx context.Context, cfg Config, name string, logger log.Logger, ...) (client objstore.Bucket, err error) + func NewUserBucketClient(userID string, bucket objstore.Bucket, cfgProvider TenantConfigProvider) objstore.InstrumentedBucket + type Config struct + Azure azure.Config + Backend string + ExtraBackends []string + Filesystem filesystem.Config + GCS gcs.Config + Middlewares []func(objstore.Bucket) (objstore.Bucket, error) + S3 s3.Config + Swift swift.Config + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + func (cfg *Config) Validate() error + type PrefixedBucketClient struct + func NewPrefixedBucketClient(bucket objstore.Bucket, prefix string) *PrefixedBucketClient + func (b *PrefixedBucketClient) Attributes(ctx context.Context, name string) (objstore.ObjectAttributes, error) + func (b *PrefixedBucketClient) Close() error + func (b *PrefixedBucketClient) Delete(ctx context.Context, name string) error + func (b *PrefixedBucketClient) Exists(ctx context.Context, name string) (bool, error) + func (b *PrefixedBucketClient) Get(ctx context.Context, name string) (io.ReadCloser, error) + func (b *PrefixedBucketClient) GetRange(ctx context.Context, name string, off, length int64) (io.ReadCloser, error) + func (b *PrefixedBucketClient) IsObjNotFoundErr(err error) bool + func (b *PrefixedBucketClient) Iter(ctx context.Context, dir string, f func(string) error, ...) error + func (b *PrefixedBucketClient) Name() string + func (b *PrefixedBucketClient) ReaderWithExpectedErrs(fn objstore.IsOpFailureExpectedFunc) objstore.BucketReader + func (b *PrefixedBucketClient) Upload(ctx context.Context, name string, r io.Reader) (err error) + func (b *PrefixedBucketClient) WithExpectedErrs(fn objstore.IsOpFailureExpectedFunc) objstore.Bucket + 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 Other modules containing this package github.com/pao214/loki/v2
Go to main page