Documentation ¶
Overview ¶
Package compress implements compression related utilities.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CompressionBuffer ¶
type CompressionBuffer struct {
// contains filtered or unexported fields
}
CompressionBuffer stores the data that is ready to be compressed.
func NewCompressionBuffer ¶
func NewCompressionBuffer(inctx context.Context, callback func([]byte), batchSize int, l *logger.Logger) *CompressionBuffer
NewCompressionBuffer returns a new compression buffer.
func (*CompressionBuffer) Close ¶
func (c *CompressionBuffer) Close()
Close compresses the buffer and flushes it to the output channel.
func (*CompressionBuffer) WriteLineToBuffer ¶
func (c *CompressionBuffer) WriteLineToBuffer(line string)
WriteLineToBuffer writes the given line to the buffer.
Click to show internal directories.
Click to hide internal directories.