Versions in this module Expand all Collapse all v0 v0.0.9 Dec 1, 2025 Changes in this version + func GetCompressTypeName(compressType CompressType) string + func InitZSTDPool(dictPath string) + func RecycleCompressor(compressType CompressType, c CompressorInterface) + func RecycleDecompressor(compressType CompressType, decompressor DecompressorInterface) + type CompressType int + const CompressTypeNone + const CompressTypeZlibPerMessage + const CompressTypeZstdPerMessage + func ParseCompressType(compress bool, compressTypeStr string) CompressType + type CompressorInterface interface + Compress func(data []byte) ([]byte, error) + Recycle func() error + Reset func() error + func GetCompressor(compressType CompressType) CompressorInterface + type DecompressorInterface interface + Decompress func(data []byte) ([]byte, error) + Recycle func() error + Reset func() error + func GetDecompressor(compressType CompressType) DecompressorInterface + func NewZlibStreamDecompressor() DecompressorInterface + func NewZstdPerMessageDecompressor() DecompressorInterface + type ZlibPerMessageCompressor struct + func NewZlibPerMessageCompressor() *ZlibPerMessageCompressor + func (z *ZlibPerMessageCompressor) Compress(data []byte) ([]byte, error) + func (z *ZlibPerMessageCompressor) Recycle() error + func (z *ZlibPerMessageCompressor) Reset() error + type ZlibPerMessageDecompressor struct + func NewZlibPerMessageDecompressor() *ZlibPerMessageDecompressor + func (z *ZlibPerMessageDecompressor) Decompress(data []byte) ([]byte, error) + func (z *ZlibPerMessageDecompressor) Recycle() error + func (z *ZlibPerMessageDecompressor) Reset() error + type ZlibStreamCompressor struct + func (z *ZlibStreamCompressor) Compress(data []byte) ([]byte, error) + func (z *ZlibStreamCompressor) Recycle() error + func (z *ZlibStreamCompressor) Reset() error + type ZlibStreamDecompressor struct + func (z *ZlibStreamDecompressor) Decompress(data []byte) ([]byte, error) + func (z *ZlibStreamDecompressor) Recycle() error + func (z *ZlibStreamDecompressor) Reset() error + type ZstdPerMessageCompressor struct + func NewZstdPerMessageCompressor() *ZstdPerMessageCompressor + func (z *ZstdPerMessageCompressor) Recycle() error + func (z *ZstdPerMessageCompressor) Reset() error + type ZstdPerMessageDecompressor struct + func (z *ZstdPerMessageDecompressor) Decompress(data []byte) ([]byte, error) + func (z *ZstdPerMessageDecompressor) Recycle() error + func (z *ZstdPerMessageDecompressor) Reset() error
Go to main page