mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-08-12 21:58:33 +00:00
31 lines
648 B
Go
31 lines
648 B
Go
package kafka
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"github.com/segmentio/kafka-go/compress"
|
|
)
|
|
|
|
type Compression = compress.Compression
|
|
|
|
type CompressionCodec = compress.Codec
|
|
|
|
// TODO: this file should probably go away once the internals of the package
|
|
// have moved to use the protocol package.
|
|
const (
|
|
compressionCodecMask = 0x07
|
|
)
|
|
|
|
var (
|
|
errUnknownCodec = errors.New("the compression code is invalid or its codec has not been imported")
|
|
)
|
|
|
|
// resolveCodec looks up a codec by Code()
|
|
func resolveCodec(code int8) (CompressionCodec, error) {
|
|
codec := compress.Compression(code).Codec()
|
|
if codec == nil {
|
|
return nil, errUnknownCodec
|
|
}
|
|
return codec, nil
|
|
}
|