Documentation ¶
Index ¶
Constants ¶
View Source
const (
Code = 3
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompressionCodec ¶
type CompressionCodec struct{}
func NewCompressionCodec ¶
func NewCompressionCodec() *CompressionCodec
func (CompressionCodec) Code ¶
func (CompressionCodec) Code() int8
Code implements the kafka.CompressionCodec interface.
func (CompressionCodec) Name ¶ added in v0.3.4
func (CompressionCodec) Name() string
Name implements the kafka.CompressionCodec interface.
func (CompressionCodec) NewReader ¶ added in v0.3.4
func (CompressionCodec) NewReader(r io.Reader) io.ReadCloser
NewReader implements the kafka.CompressionCodec interface.
func (CompressionCodec) NewWriter ¶ added in v0.3.4
func (CompressionCodec) NewWriter(w io.Writer) io.WriteCloser
NewWriter implements the kafka.CompressionCodec interface.
Click to show internal directories.
Click to hide internal directories.