compress

Documentation

Overview

Package compress implements compression related utilities.

Index

• func Compress(inBytes []byte) ([]byte, error)
• type CompressionBuffer
  • func NewCompressionBuffer(inctx context.Context, callback func([]byte), batchSize int, l *logger.Logger) *CompressionBuffer
  • func (c *CompressionBuffer) Close()
  • func (c *CompressionBuffer) WriteLineToBuffer(line string)

Functions

func Compress

func Compress(inBytes []byte) ([]byte, error)

Compress compresses the given bytes and encodes them into a string.

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.