Documentation
¶
Index ¶
- func GetCompressTypeName(compressType CompressType) string
- func InitZSTDPool(dictPath string)
- func RecycleCompressor(compressType CompressType, c CompressorInterface)
- func RecycleDecompressor(compressType CompressType, decompressor DecompressorInterface)
- type CompressType
- type CompressorInterface
- type DecompressorInterface
- type ZlibPerMessageCompressor
- type ZlibPerMessageDecompressor
- type ZlibStreamCompressor
- type ZlibStreamDecompressor
- type ZstdPerMessageCompressor
- type ZstdPerMessageDecompressor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCompressTypeName ¶
func GetCompressTypeName(compressType CompressType) string
func InitZSTDPool ¶
func InitZSTDPool(dictPath string)
func RecycleCompressor ¶
func RecycleCompressor(compressType CompressType, c CompressorInterface)
func RecycleDecompressor ¶
func RecycleDecompressor(compressType CompressType, decompressor DecompressorInterface)
Types ¶
type CompressType ¶
type CompressType int
const ( CompressTypeNone CompressType = 0 CompressTypeZlibPerMessage CompressType = 1 CompressTypeZstdPerMessage CompressType = 2 )
func ParseCompressType ¶
func ParseCompressType(compress bool, compressTypeStr string) CompressType
type CompressorInterface ¶
type CompressorInterface interface {
Compress(data []byte) ([]byte, error)
//Flush() ([]byte, error)
Reset() error
Recycle() error
}
func GetCompressor ¶
func GetCompressor(compressType CompressType) CompressorInterface
type DecompressorInterface ¶
type DecompressorInterface interface {
Decompress(data []byte) ([]byte, error)
Reset() error
Recycle() error
}
func GetDecompressor ¶
func GetDecompressor(compressType CompressType) DecompressorInterface
func NewZlibStreamDecompressor ¶
func NewZlibStreamDecompressor() DecompressorInterface
func NewZstdPerMessageDecompressor ¶
func NewZstdPerMessageDecompressor() DecompressorInterface
type ZlibPerMessageCompressor ¶
type ZlibPerMessageCompressor struct {
// contains filtered or unexported fields
}
func NewZlibPerMessageCompressor ¶
func NewZlibPerMessageCompressor() *ZlibPerMessageCompressor
func (*ZlibPerMessageCompressor) Compress ¶
func (z *ZlibPerMessageCompressor) Compress(data []byte) ([]byte, error)
func (*ZlibPerMessageCompressor) Recycle ¶
func (z *ZlibPerMessageCompressor) Recycle() error
func (*ZlibPerMessageCompressor) Reset ¶
func (z *ZlibPerMessageCompressor) Reset() error
type ZlibPerMessageDecompressor ¶
type ZlibPerMessageDecompressor struct {
}
func NewZlibPerMessageDecompressor ¶
func NewZlibPerMessageDecompressor() *ZlibPerMessageDecompressor
func (*ZlibPerMessageDecompressor) Decompress ¶
func (z *ZlibPerMessageDecompressor) Decompress(data []byte) ([]byte, error)
func (*ZlibPerMessageDecompressor) Recycle ¶
func (z *ZlibPerMessageDecompressor) Recycle() error
func (*ZlibPerMessageDecompressor) Reset ¶
func (z *ZlibPerMessageDecompressor) Reset() error
type ZlibStreamCompressor ¶
type ZlibStreamCompressor struct {
// contains filtered or unexported fields
}
func (*ZlibStreamCompressor) Compress ¶
func (z *ZlibStreamCompressor) Compress(data []byte) ([]byte, error)
func (*ZlibStreamCompressor) Recycle ¶
func (z *ZlibStreamCompressor) Recycle() error
func (*ZlibStreamCompressor) Reset ¶
func (z *ZlibStreamCompressor) Reset() error
type ZlibStreamDecompressor ¶
type ZlibStreamDecompressor struct {
// contains filtered or unexported fields
}
func (*ZlibStreamDecompressor) Decompress ¶
func (z *ZlibStreamDecompressor) Decompress(data []byte) ([]byte, error)
func (*ZlibStreamDecompressor) Recycle ¶
func (z *ZlibStreamDecompressor) Recycle() error
func (*ZlibStreamDecompressor) Reset ¶
func (z *ZlibStreamDecompressor) Reset() error
type ZstdPerMessageCompressor ¶
type ZstdPerMessageCompressor struct {
}
func NewZstdPerMessageCompressor ¶
func NewZstdPerMessageCompressor() *ZstdPerMessageCompressor
func (*ZstdPerMessageCompressor) Recycle ¶
func (z *ZstdPerMessageCompressor) Recycle() error
func (*ZstdPerMessageCompressor) Reset ¶
func (z *ZstdPerMessageCompressor) Reset() error
type ZstdPerMessageDecompressor ¶
type ZstdPerMessageDecompressor struct {
}
func (*ZstdPerMessageDecompressor) Decompress ¶
func (z *ZstdPerMessageDecompressor) Decompress(data []byte) ([]byte, error)
func (*ZstdPerMessageDecompressor) Recycle ¶
func (z *ZstdPerMessageDecompressor) Recycle() error
func (*ZstdPerMessageDecompressor) Reset ¶
func (z *ZstdPerMessageDecompressor) Reset() error
Source Files
Click to show internal directories.
Click to hide internal directories.