Sha256: 8813b74a471e13c6aa42bd9b11e50e76e2a2ab1996c6e3c913c8e1b83e38c542
Contents?: true
Size: 386 Bytes
Versions: 48
Compression:
Stored size: 386 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Messages
# "Fake" message that we use as an abstraction layer when seeking back.
# This allows us to encapsulate a seek with a simple abstraction
#
# @note `#offset` can be either the offset value or the time of the offset
# (first equal or greater)
Seek = Struct.new(:topic, :partition, :offset)
end
end
Version data entries
48 entries across 48 versions & 1 rubygems