class Phobos::BatchMessage
Attributes
headers[RW]
key[RW]
offset[RW]
partition[RW]
payload[RW]
Public Class Methods
new(key:, partition:, offset:, payload:, headers:)
click to toggle source
# File lib/phobos/batch_message.rb, line 7 def initialize(key:, partition:, offset:, payload:, headers:) @key = key @partition = partition @offset = offset @payload = payload @headers = headers end
Public Instance Methods
==(other)
click to toggle source
# File lib/phobos/batch_message.rb, line 15 def ==(other) [:key, :partition, :offset, :payload, :headers].all? do |s| public_send(s) == other.public_send(s) end end