cloudwriter

Documentation

Index

• type CloudWriter
• type CloudWriterFactory
• type S3Writer
  • func (w *S3Writer) Close() error
  • func (w *S3Writer) Write(data []byte) (int, error)
• type S3WriterFactory
  • func NewS3WriterFactory(region string) (*S3WriterFactory, error)
  • func (f *S3WriterFactory) NewWriter(bucket, objectPath string) (CloudWriter, error)

Types

type CloudWriter

type CloudWriter interface {
	Write(data []byte) (int, error)
	Close() error
}

type CloudWriterFactory

type CloudWriterFactory interface {
	NewWriter(bucket, objectPath string) (CloudWriter, error)
}

type S3Writer

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

func (*S3Writer) Close

func (w *S3Writer) Close() error

func (*S3Writer) Write

func (w *S3Writer) Write(data []byte) (int, error)

type S3WriterFactory

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

func NewS3WriterFactory

func NewS3WriterFactory(region string) (*S3WriterFactory, error)

func (*S3WriterFactory) NewWriter

func (f *S3WriterFactory) NewWriter(bucket, objectPath string) (CloudWriter, error)