snappy

Documentation

Index

• Constants
• type CompressionCodec
  • func NewCompressionCodec() *CompressionCodec
  • func NewCompressionCodecFraming(framing Framing) *CompressionCodec
  • func (c *CompressionCodec) Code() int8
  • func (c *CompressionCodec) Name() string
  • func (c *CompressionCodec) NewReader(r io.Reader) io.ReadCloser
  • func (c *CompressionCodec) NewWriter(w io.Writer) io.WriteCloser
• type Framing

Constants

const (
	Code = 2
)

Types

type CompressionCodec

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

func NewCompressionCodec

func NewCompressionCodec() *CompressionCodec

func NewCompressionCodecFraming

func NewCompressionCodecFraming(framing Framing) *CompressionCodec

func (*CompressionCodec) Code

func (c *CompressionCodec) Code() int8

Code implements the kafka.CompressionCodec interface.

func (*CompressionCodec) Name

func (c *CompressionCodec) Name() string

Name implements the kafka.CompressionCodec interface.

func (*CompressionCodec) NewReader

func (c *CompressionCodec) NewReader(r io.Reader) io.ReadCloser

NewReader implements the kafka.CompressionCodec interface.

func (*CompressionCodec) NewWriter

func (c *CompressionCodec) NewWriter(w io.Writer) io.WriteCloser

NewWriter implements the kafka.CompressionCodec interface.

type Framing

type Framing int

Framing is an enumeration type used to enable or disable xerial framing of snappy messages.

const (
	Framed Framing = iota
	Unframed
)