compressor

package
v0.0.0-...-ee8f338 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 26, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	GZIP_TYPE    = "gzip"
	ZLIB_TYPE    = "zlib"
	DEFLATE_TYPE = "deflate"
	SNAPPY_TYPE  = "snappy"
	ZSTD_TYPE    = "zstd"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CompressorReader

type CompressorReader interface {
	io.Reader
}

func NewNoopCompressorReader

func NewNoopCompressorReader(r io.Reader) CompressorReader

func NewReader

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

type CompressorWriter

type CompressorWriter interface {
	io.WriteCloser
}

func NewNoopCompressorWriter

func NewNoopCompressorWriter(buf io.Writer) CompressorWriter

func NewWriter

func NewWriter(
	conf *config.Compression,
	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) Write

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL