s3store

package
v0.0.0-...-76f7c0c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 10, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

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