Sha256: 1aeb13ee86e9afb829120c812531a72ed44e169146fa5608e14c544b99226de2

Contents?: true

Size: 270 Bytes

Versions: 65

Compression:

Stored size: 270 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
    Seek = Struct.new(:topic, :partition, :offset)
  end
end

Version data entries

65 entries across 65 versions & 1 rubygems

Version Path
karafka-2.1.5 lib/karafka/messages/seek.rb
karafka-2.1.5.beta1 lib/karafka/messages/seek.rb
karafka-2.1.4 lib/karafka/messages/seek.rb
karafka-2.1.3 lib/karafka/messages/seek.rb
karafka-2.1.2 lib/karafka/messages/seek.rb
karafka-2.1.1 lib/karafka/messages/seek.rb
karafka-2.1.0 lib/karafka/messages/seek.rb
karafka-2.0.41 lib/karafka/messages/seek.rb
karafka-2.0.40 lib/karafka/messages/seek.rb
karafka-2.0.39 lib/karafka/messages/seek.rb
karafka-2.0.38 lib/karafka/messages/seek.rb
karafka-2.0.37 lib/karafka/messages/seek.rb
karafka-2.0.36 lib/karafka/messages/seek.rb
karafka-2.0.35 lib/karafka/messages/seek.rb
karafka-2.0.34 lib/karafka/messages/seek.rb
karafka-2.0.33 lib/karafka/messages/seek.rb
karafka-2.0.32 lib/karafka/messages/seek.rb
karafka-2.0.31 lib/karafka/messages/seek.rb
karafka-2.0.30 lib/karafka/messages/seek.rb
karafka-2.0.29 lib/karafka/messages/seek.rb