package snappy

import "github.com/segmentio/kafka-go/snappy"

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

Package Files ¶

snappy.go xerial.go

Constants ¶

const (
    Code = 2
)

type CompressionCodec ¶ Uses

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

func NewCompressionCodec ¶ Uses

func NewCompressionCodec() *CompressionCodec

func NewCompressionCodecFraming ¶ Uses

func NewCompressionCodecFraming(framing Framing) *CompressionCodec

func (*CompressionCodec) Code ¶ Uses

func (c *CompressionCodec) Code() int8

Code implements the kafka.CompressionCodec interface.

func (*CompressionCodec) Name ¶ Uses

func (c *CompressionCodec) Name() string

Name implements the kafka.CompressionCodec interface.

func (*CompressionCodec) NewReader ¶ Uses

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

NewReader implements the kafka.CompressionCodec interface.

func (*CompressionCodec) NewWriter ¶ Uses

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

NewWriter implements the kafka.CompressionCodec interface.

type Framing ¶ Uses

type Framing int

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

const (
    Framed Framing = iota
    Unframed
)