Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SnappyDecoder ¶
type SnappyDecoder struct {
}
SnappyDecoder decompresses snappy-compressed Message bytes.
func (*SnappyDecoder) Decode ¶
func (re *SnappyDecoder) Decode(pack *PipelinePack) (packs []*PipelinePack, err error)
func (*SnappyDecoder) Init ¶
func (re *SnappyDecoder) Init(config interface{}) (err error)
type SnappyEncoder ¶
type SnappyEncoder struct {
}
SnappyEncoder compresses the Message bytes using snappy compression. Each message is compressed separately.
func (*SnappyEncoder) Encode ¶
func (re *SnappyEncoder) Encode(pack *PipelinePack) (output []byte, err error)
func (*SnappyEncoder) Init ¶
func (re *SnappyEncoder) Init(config interface{}) (err error)
Source Files
Click to show internal directories.
Click to hide internal directories.