lib/phobos/batch_message.rb in phobos-2.1.4 vs lib/phobos/batch_message.rb in phobos-2.1.5
- old
+ new
@@ -1,18 +1,35 @@
# frozen_string_literal: true
module Phobos
class BatchMessage
- attr_accessor :key, :partition, :offset, :payload, :headers
+ # @return
+ attr_accessor :key
+ # @return [Integer]
+ attr_accessor :partition
+ # @return [Integer]
+ attr_accessor :offset
+ # @return
+ attr_accessor :payload
+ # @return
+ attr_accessor :headers
+ # @param key
+ # @param partition [Integer]
+ # @param offset [Integer]
+ # @param payload
+ # @param headers
+ # @return [void]
def initialize(key:, partition:, offset:, payload:, headers:)
@key = key
@partition = partition
@offset = offset
@payload = payload
@headers = headers
end
+ # @param other [Phobos::BatchMessage]
+ # @return [Boolean]
def ==(other)
[:key, :partition, :offset, :payload, :headers].all? do |s|
public_send(s) == other.public_send(s)
end
end