Struct Codec

compress/snappy/snappy.go:37–45

Codec is the implementation of a compress.Codec which supports creating readers and writers for kafka messages compressed with snappy.

// Codec is the implementation of a compress.Codec which supports creating
// readers and writers for kafka messages compressed with snappy.
type Codec struct {
	// An optional framing to apply to snappy compression.
	//
	// Default to Framed.
	Framing Framing

	// Compression level.
	Compression Compression
}

// Code implements the compress.Codec interface.
func (c *Codec) Code() int8 { return 2 }