snappy

Documentation

Index

• Constants
• type CompressionCodec
  • func NewCompressionCodec() CompressionCodec
  • func (c CompressionCodec) Code() int8
  • func (c CompressionCodec) Decode(src []byte) ([]byte, error)
  • func (c CompressionCodec) Encode(src []byte) ([]byte, error)

Constants

const Code = 2

Types

type CompressionCodec

type CompressionCodec struct{}

func NewCompressionCodec

func NewCompressionCodec() CompressionCodec

func (CompressionCodec) Code

func (c CompressionCodec) Code() int8

Code implements the kafka.CompressionCodec interface.

func (CompressionCodec) Decode

func (c CompressionCodec) Decode(src []byte) ([]byte, error)

Decode implements the kafka.CompressionCodec interface.

func (CompressionCodec) Encode

func (c CompressionCodec) Encode(src []byte) ([]byte, error)

Encode implements the kafka.CompressionCodec interface.