import "github.com/segmentio/kafka-go/snappy"
const (
Code = 2
)
type CompressionCodec struct {
// contains filtered or unexported fields
}
func NewCompressionCodec() *CompressionCodec
func NewCompressionCodecFraming(framing Framing) *CompressionCodec
func (c *CompressionCodec) Code() int8
Code implements the kafka.CompressionCodec interface.
func (c *CompressionCodec) Name() string
Name implements the kafka.CompressionCodec interface.
func (c *CompressionCodec) NewReader(r io.Reader) io.ReadCloser
NewReader implements the kafka.CompressionCodec interface.
func (c *CompressionCodec) NewWriter(w io.Writer) io.WriteCloser
NewWriter implements the kafka.CompressionCodec interface.
Framing is an enumeration type used to enable or disable xerial framing of snappy messages.
Package snappy imports 6 packages (graph) and is imported by 7 packages. Updated 2019-07-25. Refresh now. Tools for package owners.