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

package lz4

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

Index

Package Files

lz4.go

Constants

const (
    Code = 3
)

type CompressionCodec Uses

type CompressionCodec struct{}

func NewCompressionCodec Uses

func NewCompressionCodec() *CompressionCodec

func (CompressionCodec) Code Uses

func (CompressionCodec) Code() int8

Code implements the kafka.CompressionCodec interface.

func (CompressionCodec) Name Uses

func (CompressionCodec) Name() string

Name implements the kafka.CompressionCodec interface.

func (CompressionCodec) NewReader Uses

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

NewReader implements the kafka.CompressionCodec interface.

func (CompressionCodec) NewWriter Uses

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

NewWriter implements the kafka.CompressionCodec interface.

Package lz4 imports 4 packages (graph) and is imported by 3 packages. Updated 2019-07-23. Refresh now. Tools for package owners.