s3

Feb 8, 2019

Changes in this version

type Config

+ PutUserMetadata map[string]string

type HTTPConfig

+ InsecureSkipVerify bool

Dec 10, 2018

Changes in this version

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

+ func Validate(conf Config) error

+ func ValidateForTests(conf Config) error

type Bucket

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

+ func (b *Bucket) Name() string

type Config

+ HTTPConfig HTTPConfig

+ SecretKey string

+ func ParseConfig(conf []byte) (Config, error)

+ type HTTPConfig struct

+ IdleConnTimeout model.Duration

Sep 18, 2018

Changes in this version

+ const DirDelim

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

+ type Bucket struct

+ func NewBucket(logger log.Logger, conf *Config, reg prometheus.Registerer, component string) (*Bucket, error)

+ func (b *Bucket) Close() error

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

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

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

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

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

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

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

+ type Config struct

+ AccessKey string

+ Bucket string

+ Endpoint string

+ Insecure bool

+ SSEEncryption bool

+ SignatureV2 bool

+ func RegisterS3Params(cmd *kingpin.CmdClause) *Config

+ func (conf *Config) Validate() error

+ func (conf *Config) ValidateForTests() error