Sha256: 8d5f1d57887e5189beadc0989b3109d6df1fa34979f3aa7a16e8943fe820cc6a
Contents?: true
Size: 484 Bytes
Versions: 17
Compression:
Stored size: 484 Bytes
Contents
# frozen_string_literal: true
module Phobos
class BatchMessage
attr_accessor :key, :partition, :offset, :payload, :headers
def initialize(key:, partition:, offset:, payload:, headers:)
@key = key
@partition = partition
@offset = offset
@payload = payload
@headers = headers
end
def ==(other)
[:key, :partition, :offset, :payload, :headers].all? do |s|
public_send(s) == other.public_send(s)
end
end
end
end
Version data entries
17 entries across 17 versions & 2 rubygems