compression

package
v1.13.5-rc.3 Latest Latest
Warning

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

Go to latest
Published: Aug 25, 2025 License: BSD-3-Clause Imports: 7 Imported by: 26

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidMaxSizeCompressor = errors.New("invalid compressor max size")
	ErrDecompressedMsgTooLarge  = errors.New("decompressed msg too large")
	ErrMsgTooLarge              = errors.New("msg too large to be compressed")
)

Functions

This section is empty.

Types

type Compressor

type Compressor interface {
	Compress([]byte) ([]byte, error)
	Decompress([]byte) ([]byte, error)
}

Compressor compress and decompresses messages. Decompress is the inverse of Compress. Decompress(Compress(msg)) == msg.

func NewNoCompressor

func NewNoCompressor() Compressor

func NewZstdCompressor added in v1.10.0

func NewZstdCompressor(maxSize int64) (Compressor, error)

func NewZstdCompressorWithLevel

func NewZstdCompressorWithLevel(maxSize int64, level int) (Compressor, error)

type Type added in v1.10.0

type Type byte
const (
	TypeNone Type = iota + 1
	TypeZstd
)

func TypeFromString added in v1.10.0

func TypeFromString(s string) (Type, error)

func (Type) MarshalJSON added in v1.10.0

func (t Type) MarshalJSON() ([]byte, error)

func (Type) String added in v1.10.0

func (t Type) String() string

Jump to

Keyboard shortcuts

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