bucketstore

Documentation

Index

• type BucketStore
  • func New(cfg s3.Config) (*BucketStore, error)
  • func (b *BucketStore) Close()
  • func (b *BucketStore) Get(ctx context.Context, name string) (io.ReadCloser, error)
  • func (b *BucketStore) IsAccessDeniedErr(err error) bool
  • func (b *BucketStore) IsObjNotFoundErr(err error) bool
  • func (b *BucketStore) Ping(ctx context.Context) error
  • func (b *BucketStore) Upload(ctx context.Context, name string, r io.Reader) error

Types

type BucketStore

type BucketStore struct {
	Bucket *s3.Bucket
}

func New

func New(cfg s3.Config) (*BucketStore, error)

func (*BucketStore) Close

func (b *BucketStore) Close()

func (*BucketStore) Get

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

func (*BucketStore) IsAccessDeniedErr

func (b *BucketStore) IsAccessDeniedErr(err error) bool

func (*BucketStore) IsObjNotFoundErr

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

func (*BucketStore) Ping

func (b *BucketStore) Ping(ctx context.Context) error

func (*BucketStore) Upload

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

Upload writes data to a named object in the store.