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 ¶
func (CompressionCodec) Name() string
Name implements the kafka.CompressionCodec interface.
func (CompressionCodec) NewReader ¶
func (CompressionCodec) NewReader(r io.Reader) io.ReadCloser
NewReader implements the kafka.CompressionCodec interface.
func (CompressionCodec) NewWriter ¶
func (CompressionCodec) NewWriter(w io.Writer) io.WriteCloser
NewWriter implements the kafka.CompressionCodec interface.
Source Files
Click to show internal directories.
Click to hide internal directories.