awss3

Documentation

Index

• type BatchedFileWriter
  • func NewBatchedFileWriter(s3Client *s3.S3, bucket string, fileName string, logger logrus.FieldLogger) BatchedFileWriter
  • func (w *BatchedFileWriter) Close() error
  • func (w *BatchedFileWriter) GetUploadCount() int
  • func (w *BatchedFileWriter) IsAccessible() bool
  • func (w *BatchedFileWriter) Name() string
  • func (w *BatchedFileWriter) Size() int64
  • func (w *BatchedFileWriter) Write(p []byte) (n int, err error)
• type BatchedFileWriterInterface

Types

type BatchedFileWriter

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

BatchedFileWriter is the file producer core.BatchedWriter implementation for the core.BatchedWriterAssembly

func NewBatchedFileWriter

func NewBatchedFileWriter(s3Client *s3.S3, bucket string, fileName string, logger logrus.FieldLogger) BatchedFileWriter

NewBatchedFileWriter returns a BatchedFileWriter instance

func (*BatchedFileWriter) Close

func (w *BatchedFileWriter) Close() error

Close is part of the Close interface and handle the file close or compression call

func (*BatchedFileWriter) GetUploadCount

func (w *BatchedFileWriter) GetUploadCount() int

GetUploadCount returns the count of completed part uploads

func (*BatchedFileWriter) IsAccessible

func (w *BatchedFileWriter) IsAccessible() bool

IsAccessible is part of the BatchedWriter interface and check if the writer can access his file

func (*BatchedFileWriter) Name

func (w *BatchedFileWriter) Name() string

Name is part of the BatchedWriter interface and wraps the file.Name() implementation

func (*BatchedFileWriter) Size

func (w *BatchedFileWriter) Size() int64

Size is part of the BatchedWriter interface and wraps the file.Stat().Size() implementation

func (*BatchedFileWriter) Write

func (w *BatchedFileWriter) Write(p []byte) (n int, err error)

Write is part of the BatchedWriter interface and wraps the file.Write() implementation

type BatchedFileWriterInterface

type BatchedFileWriterInterface interface {
	components.BatchedWriter
	GetUploadCount() int
}

BatchedFileWriterInterface extends the components.BatchedWriter interface for rotation checks