object

Documentation

Index

• func Module() app.Module
• type Store
  • func NewStore(cfg *StoreConfig) (*Store, error)
  • func (s *Store) OnStart(context.Context) error
  • func (s *Store) OnStop(context.Context) error
  • func (s *Store) PreSignedDownload(ctx context.Context, uri url.URL, expires time.Duration) (*url.URL, error)
  • func (s *Store) Upload(ctx context.Context, bucketName, path string, data io.Reader, objectSize int64) (*UploadedObject, error)
• type StoreConfig
• type UploadedObject

Functions

func Module

func Module() app.Module

Types

type Store

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

func NewStore

func NewStore(cfg *StoreConfig) (*Store, error)

func (*Store) OnStart

func (s *Store) OnStart(context.Context) error

func (*Store) OnStop

func (s *Store) OnStop(context.Context) error

func (*Store) PreSignedDownload

func (s *Store) PreSignedDownload(ctx context.Context, uri url.URL, expires time.Duration) (
	*url.URL,
	error,
)

func (*Store) Upload

func (s *Store) Upload(ctx context.Context, bucketName, path string, data io.Reader, objectSize int64) (
	*UploadedObject,
	error,
)

type StoreConfig

type StoreConfig struct {
	Endpoint  string
	AccessKey string
	SecretKey string
	UseSSL    bool
}

type UploadedObject

type UploadedObject struct {
	Uri            *url.URL
	ChecksumSHA256 string
	UploadedSize   int64
}