Codec is the implementation of a compress.Codec which supports creating readers and writers for kafka messages compressed with lz4.
| 15 | // Codec is the implementation of a compress.Codec which supports creating |
| 16 | // readers and writers for kafka messages compressed with lz4. |
| 17 | type Codec struct{} |
| 18 | |
| 19 | // Code implements the compress.Codec interface. |
| 20 | func (c *Codec) Code() int8 { return 3 } |
nothing calls this directly
no outgoing calls
no test coverage detected