s3

Documentation

Index

• func NewRepository(cfg *config.Config) (*storage.Repository, error)
• type S3RepoCfg
• type S3Repository
  • func NewS3Repository(cfg *S3RepoCfg) (*S3Repository, error)
  • func (s *S3Repository) BucketExists(ctx context.Context) (bool, error)
  • func (s *S3Repository) GetObject(ctx context.Context, objName string) (io.ReadSeekCloser, error)
  • func (s *S3Repository) PutObject(ctx context.Context, objName, contentType string, contentLength int64, ...) error

Functions

func NewRepository

func NewRepository(cfg *config.Config) (*storage.Repository, error)

Types

type S3RepoCfg

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

type S3Repository

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

func NewS3Repository

func NewS3Repository(cfg *S3RepoCfg) (*S3Repository, error)

func (*S3Repository) BucketExists

func (s *S3Repository) BucketExists(ctx context.Context) (bool, error)

func (*S3Repository) GetObject

func (s *S3Repository) GetObject(ctx context.Context, objName string) (io.ReadSeekCloser, error)

func (*S3Repository) PutObject

func (s *S3Repository) PutObject(ctx context.Context, objName, contentType string, contentLength int64, r io.Reader) error