oss

package

v0.26.0 Latest Latest Go to latest Published: Apr 9, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/heylongdacoder/thanos

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewTestBucket(t testing.TB) (objstore.Bucket, func(), error)
func NewTestBucketFromConfig(t testing.TB, c Config, reuseBucket bool) (objstore.Bucket, func(), error)
type Bucket
- func NewBucket(logger log.Logger, conf []byte, component string) (*Bucket, error)
- func NewBucketWithConfig(logger log.Logger, config Config, component string) (*Bucket, error)
type Config

Constants ¶

View Source

const PartSize = 1024 * 1024 * 128

Part size for multi part upload.

Variables ¶

This section is empty.

Functions ¶

func NewTestBucket ¶

func NewTestBucket(t testing.TB) (objstore.Bucket, func(), error)

func NewTestBucketFromConfig ¶

func NewTestBucketFromConfig(t testing.TB, c Config, reuseBucket bool) (objstore.Bucket, func(), error)

Types ¶

type Bucket ¶

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

Bucket implements the store.Bucket interface.

func NewBucket ¶

func NewBucket(logger log.Logger, conf []byte, component string) (*Bucket, error)

NewBucket returns a new Bucket using the provided oss config values.

func NewBucketWithConfig ¶

func NewBucketWithConfig(logger log.Logger, config Config, component string) (*Bucket, error)

NewBucketWithConfig returns a new Bucket using the provided oss config struct.

func (*Bucket) Attributes ¶

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

Attributes returns information about the specified object.

func (*Bucket) Close ¶

func (b *Bucket) Close() error

func (*Bucket) Delete ¶

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

Delete removes the object with the given name.

func (*Bucket) Exists ¶

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

Exists checks if the given object exists in the bucket.

func (*Bucket) Get ¶

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

Get returns a reader for the given object name.

func (*Bucket) GetRange ¶

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

func (*Bucket) IsObjNotFoundErr ¶

func (b *Bucket) IsObjNotFoundErr(err error) bool

IsObjNotFoundErr returns true if error means that object is not found. Relevant to Get operations.

func (*Bucket) Iter ¶

func (b *Bucket) Iter(ctx context.Context, dir string, f func(string) error, options ...objstore.IterOption) error

Iter calls f for each entry in the given directory (not recursive). The argument to f is the full object name including the prefix of the inspected directory.

func (*Bucket) Name ¶

func (b *Bucket) Name() string

func (*Bucket) Upload ¶

func (b *Bucket) Upload(_ context.Context, name string, r io.Reader) error

Upload the contents of the reader as an object into the bucket.

type Config ¶

type Config struct {
	Endpoint        string `yaml:"endpoint"`
	Bucket          string `yaml:"bucket"`
	AccessKeyID     string `yaml:"access_key_id"`
	AccessKeySecret string `yaml:"access_key_secret"`
}

Config stores the configuration for oss bucket.

Source Files ¶

View all Source files

oss.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL