s3

Documentation

Index

• func Download(ctx context.Context, storage *S3, src string, dest string) (err error)
• func ListFiles(storage *S3, prefix string, recursive bool) (files []string, err error)
• func ReaperDownload(ctx context.Context, storage *S3, src string, dest string) (err error)
• func Upload(ctx context.Context, storage *S3, src string, dest string) (err error)
• type S3
  • func NewS3StorageFromEncryptedURI(encryptedURI string) (*S3, error)
  • func NewS3StorageFromURL(uri string) (*S3, error)
  • func (s *S3) GetObjectPath(name string) string
  • func (s *S3) GetSchema() string
  • func (s *S3) GetURI() string
  • func (s *S3) Validate() error

Functions

func Download

func Download(ctx context.Context, storage *S3, src string, dest string) (err error)

Download the file to object storage

func ListFiles

func ListFiles(storage *S3, prefix string, recursive bool) (files []string, err error)

ListFiles with specific prefix

func ReaperDownload

func ReaperDownload(ctx context.Context, storage *S3, src string, dest string) (err error)

func Upload

func Upload(ctx context.Context, storage *S3, src string, dest string) (err error)

Upload the file to object storage

Types

type S3

type S3 struct {
	Ak        string `json:"ak"`
	Sk        string `json:"sk"`
	Endpoint  string `json:"endpoint"`
	Bucket    string `json:"bucket"`
	Subfolder string `json:"subfolder"`
	Insecure  bool   `json:"insecure"`
	IsDefault bool   `json:"is_default"`
}

func NewS3StorageFromEncryptedURI

func NewS3StorageFromEncryptedURI(encryptedURI string) (*S3, error)

func NewS3StorageFromURL

func NewS3StorageFromURL(uri string) (*S3, error)

func (*S3) GetObjectPath

func (s *S3) GetObjectPath(name string) string

func (*S3) GetSchema

func (s *S3) GetSchema() string

func (*S3) GetURI

func (s *S3) GetURI() string

func (*S3) Validate

func (s *S3) Validate() error