Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files