compression

Documentation

Index

• Constants
• type CompressorReader
  • func NewNoopCompressorReader(r io.Reader) CompressorReader
  • func NewReader(conf *config.CompressionConfig, reader io.Reader) (CompressorReader, error)
• type CompressorWriter
  • func NewNoopCompressorWriter(buf io.Writer) CompressorWriter
  • func NewWriter(conf *config.CompressionConfig, writer io.Writer) (CompressorWriter, error)
• type NoopCompressorReader
  • func (c *NoopCompressorReader) Close() error
  • func (c *NoopCompressorReader) Read(p []byte) (int, error)
• type NoopCompressorWriter
  • func (c *NoopCompressorWriter) Close() error
  • func (c *NoopCompressorWriter) Flush() error
  • func (c *NoopCompressorWriter) Write(p []byte) (int, error)

Constants

const (
	GzipType    = "gzip"
	ZlibType    = "zlib"
	DeflateType = "deflate"
	SnappyType  = "snappy"
	ZstdType    = "zstd"
)

Types

type CompressorReader

type CompressorReader interface {
	io.Reader
	io.Closer
}

func NewNoopCompressorReader

func NewNoopCompressorReader(r io.Reader) CompressorReader

func NewReader

func NewReader(
	conf *config.CompressionConfig,
	reader io.Reader,
) (CompressorReader, error)

type CompressorWriter

type CompressorWriter interface {
	io.WriteCloser
	Flush() error
}

func NewNoopCompressorWriter

func NewNoopCompressorWriter(buf io.Writer) CompressorWriter

func NewWriter

func NewWriter(
	conf *config.CompressionConfig,
	writer io.Writer,
) (CompressorWriter, error)

type NoopCompressorReader

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

func (*NoopCompressorReader) Close

func (c *NoopCompressorReader) Close() error

func (*NoopCompressorReader) Read

func (c *NoopCompressorReader) Read(p []byte) (int, error)

type NoopCompressorWriter

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

func (*NoopCompressorWriter) Close

func (c *NoopCompressorWriter) Close() error

func (*NoopCompressorWriter) Flush

func (c *NoopCompressorWriter) Flush() error

func (*NoopCompressorWriter) Write

func (c *NoopCompressorWriter) Write(p []byte) (int, error)