Class: Kafka::SnappyCodec
- Inherits:
-
Object
- Object
- Kafka::SnappyCodec
- Defined in:
- lib/kafka/snappy_codec.rb
Instance Method Summary collapse
- #codec_id ⇒ Object
- #compress(data) ⇒ Object
- #decompress(data) ⇒ Object
- #load ⇒ Object
- #produce_api_min_version ⇒ Object
Instance Method Details
permalink #codec_id ⇒ Object
[View source]
5 6 7 |
# File 'lib/kafka/snappy_codec.rb', line 5 def codec_id 2 end |
permalink #compress(data) ⇒ Object
[View source]
20 21 22 |
# File 'lib/kafka/snappy_codec.rb', line 20 def compress(data) Snappy.deflate(data) end |
permalink #decompress(data) ⇒ Object
[View source]
24 25 26 27 |
# File 'lib/kafka/snappy_codec.rb', line 24 def decompress(data) buffer = StringIO.new(data) Snappy::Reader.new(buffer).read end |
permalink #load ⇒ Object
[View source]
13 14 15 16 17 18 |
# File 'lib/kafka/snappy_codec.rb', line 13 def load require "snappy" rescue LoadError raise LoadError, "Using snappy compression requires adding a dependency on the `snappy` gem to your Gemfile." end |
permalink #produce_api_min_version ⇒ Object
[View source]
9 10 11 |
# File 'lib/kafka/snappy_codec.rb', line 9 def produce_api_min_version 0 end |