stores3

Documentation

Index

• func NewWithEndpoint(ctx context.Context, endpoint string) (*s3.Client, error)
• type S3HealthCheck
  • func (c *S3HealthCheck) Health(ctx context.Context) models.ServiceHealthResp
• type S3Store
  • func (s *S3Store) AsConcatableUpload(upload handler.Upload) handler.ConcatableUpload
  • func (s *S3Store) AsLengthDeclarableUpload(upload handler.Upload) handler.LengthDeclarableUpload
  • func (s *S3Store) AsTerminatableUpload(upload handler.Upload) handler.TerminatableUpload
  • func (s *S3Store) GetUpload(ctx context.Context, id string) (handler.Upload, error)
  • func (s *S3Store) NewUpload(ctx context.Context, info handler.FileInfo) (handler.Upload, error)
  • func (s *S3Store) UseIn(composer *handler.StoreComposer)
• type S3StoreUpload
  • func (su *S3StoreUpload) GetInfo(ctx context.Context) (handler.FileInfo, error)

Functions

func NewWithEndpoint

func NewWithEndpoint(ctx context.Context, endpoint string) (*s3.Client, error)

Types

type S3HealthCheck

type S3HealthCheck struct {
	Client     *s3.Client
	BucketName string
}

func (*S3HealthCheck) Health

func (c *S3HealthCheck) Health(ctx context.Context) models.ServiceHealthResp

type S3Store

type S3Store struct {
	Store s3store.S3Store
}

func (*S3Store) AsConcatableUpload

func (s *S3Store) AsConcatableUpload(upload handler.Upload) handler.ConcatableUpload

func (*S3Store) AsLengthDeclarableUpload

func (s *S3Store) AsLengthDeclarableUpload(upload handler.Upload) handler.LengthDeclarableUpload

func (*S3Store) AsTerminatableUpload

func (s *S3Store) AsTerminatableUpload(upload handler.Upload) handler.TerminatableUpload

func (*S3Store) GetUpload

func (s *S3Store) GetUpload(ctx context.Context, id string) (handler.Upload, error)

func (*S3Store) NewUpload

func (s *S3Store) NewUpload(ctx context.Context, info handler.FileInfo) (handler.Upload, error)

func (*S3Store) UseIn

func (s *S3Store) UseIn(composer *handler.StoreComposer)

type S3StoreUpload

type S3StoreUpload struct {
	handler.Upload
}

func (*S3StoreUpload) GetInfo

func (su *S3StoreUpload) GetInfo(ctx context.Context) (handler.FileInfo, error)