Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Compressor ¶
Compressor compress and decompresses messages. Decompress is the inverse of Compress. Decompress(Compress(msg)) == msg.
func NewGzipCompressor ¶
func NewGzipCompressor(maxSize int64) (Compressor, error)
NewGzipCompressor returns a new gzip Compressor that compresses
func NewNoCompressor ¶
func NewNoCompressor() Compressor
type ZstdCompressor ¶
type ZstdCompressor struct {
// contains filtered or unexported fields
}
ZstdCompressor implements Compressor using zstd compression
func NewZstdCompressor ¶
func NewZstdCompressor(maxSize int64) (*ZstdCompressor, error)
func NewZstdCompressorWithLevel ¶
func NewZstdCompressorWithLevel(maxSize int64, level zstd.EncoderLevel) (*ZstdCompressor, error)
func (*ZstdCompressor) Decompress ¶
func (z *ZstdCompressor) Decompress(msg []byte) ([]byte, error)
Click to show internal directories.
Click to hide internal directories.