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