s3manager

Documentation

Index

• func NewS3() *s3.S3
• func NewS3Downloader() *s3manager.Downloader
• func NewS3Uploader() *s3manager.Uploader
• type DownloaderAPI
  • func (a *DownloaderAPI) Download(ctx aws.Context, bucket, key string) ([]byte, int64, error)
  • func (a *DownloaderAPI) DownloadAsScanner(ctx aws.Context, bucket, key string) (*bufio.Scanner, error)
  • func (a *DownloaderAPI) IsEnabled() bool
  • func (a *DownloaderAPI) Setup()
• type UploaderAPI
  • func (a *UploaderAPI) IsEnabled() bool
  • func (a *UploaderAPI) Setup()
  • func (a *UploaderAPI) Upload(ctx aws.Context, buffer []byte, bucket, key string) (*s3manager.UploadOutput, error)

Functions

func NewS3

func NewS3() *s3.S3

NewS3 creates a new session connection to S3

func NewS3Downloader

func NewS3Downloader() *s3manager.Downloader

NewS3Downloader returns an XRay-enabled S3 Downloader client

func NewS3Uploader

func NewS3Uploader() *s3manager.Uploader

NewS3Uploader creates a new S3 uploader client connection

Types

type DownloaderAPI

type DownloaderAPI struct {
	Client s3manageriface.DownloaderAPI
}

DownloaderAPI wraps a S3 client interface

func (*DownloaderAPI) Download

func (a *DownloaderAPI) Download(ctx aws.Context, bucket, key string) ([]byte, int64, error)

Download wraps AWS S3Downloader DownloadWithContext API with optional XRay support

func (*DownloaderAPI) DownloadAsScanner

func (a *DownloaderAPI) DownloadAsScanner(ctx aws.Context, bucket, key string) (*bufio.Scanner, error)

DownloadAsScanner wraps DownloaderClient.DownloadWithContext and returns object as a decoded scanner

func (*DownloaderAPI) IsEnabled

func (a *DownloaderAPI) IsEnabled() bool

IsEnabled checks if the client has been set

func (*DownloaderAPI) Setup

func (a *DownloaderAPI) Setup()

Setup initialiazes Client with an XRay-enabled S3Uploader client

type UploaderAPI

type UploaderAPI struct {
	Client s3manageriface.UploaderAPI
}

UploaderAPI wraps a S3 client interface

func (*UploaderAPI) IsEnabled

func (a *UploaderAPI) IsEnabled() bool

IsEnabled checks if the client has been set

func (*UploaderAPI) Setup

func (a *UploaderAPI) Setup()

Setup initialiazes Client with an XRay-enabled S3Uploader client

func (*UploaderAPI) Upload

func (a *UploaderAPI) Upload(ctx aws.Context, buffer []byte, bucket, key string) (*s3manager.UploadOutput, error)

Upload wraps AWS S3manager's UploadInput API