s3store

Documentation

Index

• func New(sess *session.Session, s3Config config.S3Config) store.Store
• type S3Store
  • func (s *S3Store) Delete(fileName string) error
  • func (s *S3Store) DeleteAll(prefix ...string) error
  • func (s *S3Store) Get(key string, writer io.Writer) error
  • func (s *S3Store) GetAll() ([]*pb.StorageObject, error)
  • func (s *S3Store) Init() error
  • func (s *S3Store) Put(key string, body io.Reader) error

Functions

func New

func New(sess *session.Session, s3Config config.S3Config) store.Store

Types

type S3Store

type S3Store struct {
	S3           *s3.S3
	S3Gofer      *s3gof3r.S3 // provides fast, parallelized, streaming access to Amazon S3
	Bucket       *s3gof3r.Bucket
	Config       *s3gof3r.Config
	UploaderPool sync.Pool
	Session      *session.Session
}

func (*S3Store) Delete

func (s *S3Store) Delete(fileName string) error

func (*S3Store) DeleteAll

func (s *S3Store) DeleteAll(prefix ...string) error

func (*S3Store) Get

func (s *S3Store) Get(key string, writer io.Writer) error

func (*S3Store) GetAll

func (s *S3Store) GetAll() ([]*pb.StorageObject, error)

func (*S3Store) Init

func (s *S3Store) Init() error

func (*S3Store) Put

func (s *S3Store) Put(key string, body io.Reader) error