writers

Documentation

Index

• type S3Uploader
• type S3Writer
  • func NewS3Writer(region, bucket string, concurrency int) (*S3Writer, error)
  • func (w *S3Writer) Write(key key.Key, val []byte) error
• type Writer
  • func NewNoop() Writer

Types

type S3Uploader

type S3Uploader interface {
	//Upload
	Upload(input *s3manager.UploadInput, options ...func(*s3manager.Uploader)) (*s3manager.UploadOutput, error)
}

S3Uploader uploads to underlying backend

type S3Writer

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

S3Writer uploads objects to S3

func NewS3Writer

func NewS3Writer(region, bucket string, concurrency int) (*S3Writer, error)

NewS3Writer initializes an S3Writer

func (*S3Writer) Write

func (w *S3Writer) Write(key key.Key, val []byte) error

Write writes creates object of S3 bucket prefix key in S3Writer bucket with value val

type Writer

type Writer interface {
	Write(key key.Key, value []byte) error
}

func NewNoop

func NewNoop() Writer

NewNoop ...