awss3

Documentation

Index

• func DownloadFile(ctx context.Context, api GetObjectAPI, bucketName string, objectKey string) ([]byte, error)
• func DownloadFileStream(ctx context.Context, api GetObjectAPI, bucketName string, objectKey string) (io.ReadCloser, error)
• func DownloadLargeFile(ctx context.Context, api GetObjectAPI, bucketName string, objectKey string) ([]byte, error)
• func GeneratePresignedURL(ctx context.Context, api PresignObject, bucketName string, objectKey string, ...) (string, error)
• func NewClient(useTracing bool) *s3.Client
• type GetObjectAPI
• type ListObjectsV2API
• type PresignObject
• type S3File
  • func ListBucketObjects(ctx context.Context, client ListObjectsV2API, bucketName string, prefix string) ([]S3File, error)

Functions

func DownloadFile

func DownloadFile(ctx context.Context, api GetObjectAPI, bucketName string, objectKey string) ([]byte, error)

DownloadFile downloads file from S3 and returns it as a byte slice

func DownloadFileStream

func DownloadFileStream(ctx context.Context, api GetObjectAPI, bucketName string, objectKey string) (io.ReadCloser, error)

DownloadFileStream downloads file from S3 and returns the io.ReadCloser. This must be closed by the callee function!

func DownloadLargeFile

func DownloadLargeFile(ctx context.Context, api GetObjectAPI, bucketName string, objectKey string) ([]byte, error)

DownloadFileLarge downloads file from S3 using download manager and returns it as a byte slice

func GeneratePresignedURL

func GeneratePresignedURL(ctx context.Context, api PresignObject, bucketName string, objectKey string, mimeType string, fileName string, expiry time.Duration) (string, error)

func NewClient

func NewClient(useTracing bool) *s3.Client

Types

type GetObjectAPI

type GetObjectAPI interface {
	GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)
}

type ListObjectsV2API

type ListObjectsV2API interface {
	ListObjectsV2(ctx context.Context,
		params *s3.ListObjectsV2Input,
		optFns ...func(*s3.Options)) (*s3.ListObjectsV2Output, error)
}

type PresignObject

type PresignObject interface {
	PresignGetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.PresignOptions)) (*v4.PresignedHTTPRequest, error)
}

type S3File

type S3File struct {
	CreatedAt time.Time
	Name      string
}

func ListBucketObjects

func ListBucketObjects(ctx context.Context, client ListObjectsV2API, bucketName string, prefix string) ([]S3File, error)