snappy

Documentation

Index

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

Constants

const Code = 2

Types

type CompressionCodec

type CompressionCodec struct {
	// contains filtered or unexported fields
}

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(dst, src []byte) (int, error)

Decode implements the kafka.CompressionCodec interface.

func (CompressionCodec) Encode

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

Encode implements the kafka.CompressionCodec interface.