Module: Kafka::Compression

Defined in:

lib/kafka/compression.rb

Constant Summary

CODEC_NAMES =

{
  1 => :gzip,
  2 => :snappy,
  3 => :lz4,
}.freeze

CODECS =

{
  :gzip => GzipCodec.new,
  :snappy => SnappyCodec.new,
  :lz4 => LZ4Codec.new,
}.freeze

Class Method Summary

• .codecs ⇒ Object
• .find_codec(name) ⇒ Object
• .find_codec_by_id(codec_id) ⇒ Object

Class Method Details

.codecs ⇒ Object

# File 'lib/kafka/compression.rb', line 19

def self.codecs
  CODECS.keys
end

.find_codec(name) ⇒ Object

# File 'lib/kafka/compression.rb', line 23

def self.find_codec(name)
  codec = CODECS.fetch(name) do
    raise "Unknown compression codec #{name}"
  end

  codec.load

  codec
end

.find_codec_by_id(codec_id) ⇒ Object

# File 'lib/kafka/compression.rb', line 33

def self.find_codec_by_id(codec_id)
  codec_name = CODEC_NAMES.fetch(codec_id) do
    raise "Unknown codec id #{codec_id}"
  end

  find_codec(codec_name)
end