Class: Kafka::Protocol::MessageSet
- Inherits:
-
Object
- Object
- Kafka::Protocol::MessageSet
- Defined in:
- lib/kafka/protocol/message_set.rb
Instance Attribute Summary collapse
-
#messages ⇒ Object
readonly
Returns the value of attribute messages.
Class Method Summary collapse
Instance Method Summary collapse
- #==(other) ⇒ Object
- #encode(encoder) ⇒ Object
-
#initialize(messages: [], compression_codec: nil, compression_threshold: 1) ⇒ MessageSet
constructor
A new instance of MessageSet.
- #size ⇒ Object
Constructor Details
#initialize(messages: [], compression_codec: nil, compression_threshold: 1) ⇒ MessageSet
Returns a new instance of MessageSet.
6 7 8 9 10 |
# File 'lib/kafka/protocol/message_set.rb', line 6 def initialize(messages: [], compression_codec: nil, compression_threshold: 1) @messages = @compression_codec = compression_codec @compression_threshold = compression_threshold end |
Instance Attribute Details
#messages ⇒ Object (readonly)
Returns the value of attribute messages.
4 5 6 |
# File 'lib/kafka/protocol/message_set.rb', line 4 def @messages end |
Class Method Details
Instance Method Details
#==(other) ⇒ Object
16 17 18 |
# File 'lib/kafka/protocol/message_set.rb', line 16 def ==(other) == other. end |
#encode(encoder) ⇒ Object
20 21 22 23 24 25 26 |
# File 'lib/kafka/protocol/message_set.rb', line 20 def encode(encoder) if compress? encode_with_compression(encoder) else encode_without_compression(encoder) end end |
#size ⇒ Object
12 13 14 |
# File 'lib/kafka/protocol/message_set.rb', line 12 def size @messages.size end |