kafka-go: github.com/segmentio/kafka-go/gzip Index | Files

package gzip

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

Index

Package Files

gzip.go

Constants

const (
    Code = 1

    DefaultCompressionLevel = gzip.DefaultCompression
)

type CompressionCodec Uses

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

func NewCompressionCodec Uses

func NewCompressionCodec() *CompressionCodec

func NewCompressionCodecLevel Uses

func NewCompressionCodecLevel(level int) *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.

Package gzip imports 6 packages (graph) and is imported by 3 packages. Updated 2019-07-24. Refresh now. Tools for package owners.