Sha256: 7e2ddcbb18c88f9761943988cd70a4bf82e528b448adfa3391a3f3477a2ff829

Contents?: true

Size: 561 Bytes

Versions: 88

Compression:

Stored size: 561 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Processing
    module Jobs
      # Job that runs the revoked operation when we loose a partition on a consumer that lost it.
      class Revoked < Base
        # @param executor [Karafka::Processing::Executor] executor that is suppose to run the job
        # @return [Revoked]
        def initialize(executor)
          @executor = executor
          super()
        end

        # Runs the revoking job via an executor.
        def call
          executor.revoked
        end
      end
    end
  end
end

Version data entries

88 entries across 88 versions & 1 rubygems

Version Path
karafka-2.2.13 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.12 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.11 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.10 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.9 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.8 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.8.beta1 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.7 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.6 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.5 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.4 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.3 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.2 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.1 lib/karafka/processing/jobs/revoked.rb
karafka-2.2.0 lib/karafka/processing/jobs/revoked.rb
karafka-2.1.13 lib/karafka/processing/jobs/revoked.rb
karafka-2.1.12 lib/karafka/processing/jobs/revoked.rb
karafka-2.1.11 lib/karafka/processing/jobs/revoked.rb
karafka-2.1.10 lib/karafka/processing/jobs/revoked.rb
karafka-2.1.9 lib/karafka/processing/jobs/revoked.rb