Module: Kafka::Compression
- Defined in:
- lib/kafka/compression.rb
Constant Summary collapse
- CODECS_BY_NAME =
{ :gzip => GzipCodec .new , :snappy => SnappyCodec .new , :lz4 => LZ4Codec .new , :zstd => ZstdCodec .new , }.freeze
- CODECS_BY_ID =
CODECS_BY_NAME .each_with_object({}) do |(_, codec), hash| hash[codec.codec_id] = codec end.freeze
Class Method Summary collapse
Class Method Details
.codecs ⇒ Object
21 22 23
# File 'lib/kafka/compression.rb', line 21 def self.codecs CODECS_BY_NAME .keys end
.find_codec(name) ⇒ Object
25 26 27 28 29 30 31 32 33
# File 'lib/kafka/compression.rb', line 25 def self.find_codec(name) codec = CODECS_BY_NAME .fetch(name) do raise "Unknown compression codec #{name}" end codec.load codec end
.find_codec_by_id(codec_id) ⇒ Object
35 36 37 38 39 40 41 42 43
# File 'lib/kafka/compression.rb', line 35 def self.find_codec_by_id(codec_id) codec = CODECS_BY_ID .fetch(codec_id) do raise "Unknown codec id #{codec_id}" end codec.load codec end