test

Documentation

Index

• func RandomBucket() string
• type API
  • func NewAPI() *API
  • func (a *API) AssertOutputsEmpty()
  • func (a *API) S3() s3iface.S3API
  • func (a *API) S3ManagerDownloader() s3manageriface.DownloaderAPI
  • func (a *API) S3ManagerUploader() s3manageriface.UploaderAPI
• type DeleteObjectWithContextInput
• type DeleteObjectWithContextOutput
• type DownloadWithContextInput
• type DownloadWithContextOutput
• type HeadObjectWithContextInput
• type HeadObjectWithContextOutput
• type S3
  • func NewS3() *S3
  • func (s *S3) AssertOutputsEmpty()
  • func (s *S3) DeleteObjectWithContext(ctx aws.Context, input *s3.DeleteObjectInput, options ...request.Option) (*s3.DeleteObjectOutput, error)
  • func (s *S3) HeadObjectWithContext(ctx aws.Context, input *s3.HeadObjectInput, options ...request.Option) (*s3.HeadObjectOutput, error)
• type S3Manager
  • func NewS3Manager() *S3Manager
  • func (s *S3Manager) AssertOutputsEmpty()
  • func (s *S3Manager) DownloadWithContext(ctx aws.Context, writerAt io.WriterAt, input *s3.GetObjectInput, ...) (int64, error)
  • func (s *S3Manager) UploadWithContext(ctx aws.Context, input *s3manager.UploadInput, ...) (*s3manager.UploadOutput, error)
• type UploadWithContextInput
• type UploadWithContextOutput

Functions

func RandomBucket

func RandomBucket() string

Types

type API

type API struct {
	S3Invocations                  int
	S3Stub                         func() s3iface.S3API
	S3Outputs                      []s3iface.S3API
	S3Output                       s3iface.S3API
	S3ManagerDownloaderInvocations int
	S3ManagerDownloaderStub        func() s3manageriface.DownloaderAPI
	S3ManagerDownloaderOutputs     []s3manageriface.DownloaderAPI
	S3ManagerDownloaderOutput      s3manageriface.DownloaderAPI
	S3ManagerUploaderInvocations   int
	S3ManagerUploaderStub          func() s3manageriface.UploaderAPI
	S3ManagerUploaderOutputs       []s3manageriface.UploaderAPI
	S3ManagerUploaderOutput        s3manageriface.UploaderAPI
}

func NewAPI

func NewAPI() *API

func (*API) AssertOutputsEmpty

func (a *API) AssertOutputsEmpty()

func (*API) S3

func (a *API) S3() s3iface.S3API

func (*API) S3ManagerDownloader

func (a *API) S3ManagerDownloader() s3manageriface.DownloaderAPI

func (*API) S3ManagerUploader

func (a *API) S3ManagerUploader() s3manageriface.UploaderAPI

type DeleteObjectWithContextInput

type DeleteObjectWithContextInput struct {
	Context aws.Context
	Input   *s3.DeleteObjectInput
	Options []request.Option
}

type DeleteObjectWithContextOutput

type DeleteObjectWithContextOutput struct {
	Output *s3.DeleteObjectOutput
	Error  error
}

type DownloadWithContextInput

type DownloadWithContextInput struct {
	Context  aws.Context
	WriterAt io.WriterAt
	Input    *s3.GetObjectInput
	Options  []func(*s3manager.Downloader)
}

type DownloadWithContextOutput

type DownloadWithContextOutput struct {
	BytesWritten int64
	Error        error
}

type HeadObjectWithContextInput

type HeadObjectWithContextInput struct {
	Context aws.Context
	Input   *s3.HeadObjectInput
	Options []request.Option
}

type HeadObjectWithContextOutput

type HeadObjectWithContextOutput struct {
	Output *s3.HeadObjectOutput
	Error  error
}

type S3

type S3 struct {
	s3iface.S3API

	HeadObjectWithContextInvocations   int
	HeadObjectWithContextInputs        []HeadObjectWithContextInput
	HeadObjectWithContextStub          func(ctx aws.Context, input *s3.HeadObjectInput, options ...request.Option) (*s3.HeadObjectOutput, error)
	HeadObjectWithContextOutputs       []HeadObjectWithContextOutput
	HeadObjectWithContextOutput        *HeadObjectWithContextOutput
	DeleteObjectWithContextInvocations int
	DeleteObjectWithContextInputs      []DeleteObjectWithContextInput
	DeleteObjectWithContextStub        func(ctx aws.Context, input *s3.DeleteObjectInput, options ...request.Option) (*s3.DeleteObjectOutput, error)
	DeleteObjectWithContextOutputs     []DeleteObjectWithContextOutput
	DeleteObjectWithContextOutput      *DeleteObjectWithContextOutput
}

func NewS3

func NewS3() *S3

func (*S3) AssertOutputsEmpty

func (s *S3) AssertOutputsEmpty()

func (*S3) DeleteObjectWithContext

func (s *S3) DeleteObjectWithContext(ctx aws.Context, input *s3.DeleteObjectInput, options ...request.Option) (*s3.DeleteObjectOutput, error)

func (*S3) HeadObjectWithContext

func (s *S3) HeadObjectWithContext(ctx aws.Context, input *s3.HeadObjectInput, options ...request.Option) (*s3.HeadObjectOutput, error)

type S3Manager

type S3Manager struct {
	s3manageriface.DownloaderAPI
	s3manageriface.UploaderAPI

	DownloadWithContextInvocations int
	DownloadWithContextInputs      []DownloadWithContextInput
	DownloadWithContextStub        func(ctx aws.Context, writerAt io.WriterAt, input *s3.GetObjectInput, options ...func(*s3manager.Downloader)) (int64, error)
	DownloadWithContextOutputs     []DownloadWithContextOutput
	DownloadWithContextOutput      *DownloadWithContextOutput
	UploadWithContextInvocations   int
	UploadWithContextInputs        []UploadWithContextInput
	UploadWithContextStub          func(ctx aws.Context, input *s3manager.UploadInput, options ...func(*s3manager.Uploader)) (*s3manager.UploadOutput, error)
	UploadWithContextOutputs       []UploadWithContextOutput
	UploadWithContextOutput        *UploadWithContextOutput
}

func NewS3Manager

func NewS3Manager() *S3Manager

func (*S3Manager) AssertOutputsEmpty

func (s *S3Manager) AssertOutputsEmpty()

func (*S3Manager) DownloadWithContext

func (s *S3Manager) DownloadWithContext(ctx aws.Context, writerAt io.WriterAt, input *s3.GetObjectInput, options ...func(*s3manager.Downloader)) (int64, error)

func (*S3Manager) UploadWithContext

func (s *S3Manager) UploadWithContext(ctx aws.Context, input *s3manager.UploadInput, options ...func(*s3manager.Uploader)) (*s3manager.UploadOutput, error)

type UploadWithContextInput

type UploadWithContextInput struct {
	Context aws.Context
	Input   *s3manager.UploadInput
	Options []func(*s3manager.Uploader)
}

type UploadWithContextOutput

type UploadWithContextOutput struct {
	Output *s3manager.UploadOutput
	Error  error
}