util

Documentation

Index

• func GunzipWrite(w io.Writer, data []byte) error
• type MockTransferManager
  • func NewMockTransferManager(ctx context.Context) *MockTransferManager
  • func (m *MockTransferManager) Download(bucket string, key string) ([]byte, error)
  • func (m *MockTransferManager) Upload(bucket string, key string, data []byte) error
• type S3TransferManager
  • func NewS3TransferManager(ioTimeout time.Duration, cfg *aws.Config) (*S3TransferManager, error)
  • func (m *S3TransferManager) Download(bucket string, key string) ([]byte, error)
  • func (m *S3TransferManager) Upload(bucket string, key string, data []byte) error
• type TransferManager

Functions

func GunzipWrite

func GunzipWrite(w io.Writer, data []byte) error

Types

type MockTransferManager

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

func NewMockTransferManager

func NewMockTransferManager(ctx context.Context) *MockTransferManager

func (*MockTransferManager) Download

func (m *MockTransferManager) Download(bucket string, key string) ([]byte, error)

func (*MockTransferManager) Upload

func (m *MockTransferManager) Upload(bucket string, key string, data []byte) error

type S3TransferManager

type S3TransferManager struct {
	Downloader *s3manager.Downloader
	Uploader   *s3manager.Uploader
	// contains filtered or unexported fields
}

func NewS3TransferManager

func NewS3TransferManager(ioTimeout time.Duration, cfg *aws.Config) (*S3TransferManager, error)

func (*S3TransferManager) Download

func (m *S3TransferManager) Download(bucket string, key string) ([]byte, error)

func (*S3TransferManager) Upload

func (m *S3TransferManager) Upload(bucket string, key string, data []byte) error

type TransferManager

type TransferManager interface {
	Download(string, string) ([]byte, error)
	Upload(string, string, []byte) error
}

Using an interface makes things easier to test