Sha256: 5ff67d63d0e79c08eed418b2d1dc7ea54beb8dbf6f41dbfeda79f69c48177ad9
Contents?: true
Size: 702 Bytes
Versions: 26
Compression:
Stored size: 702 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 code prior to scheduling this revoked job
def before_schedule
executor.before_schedule_revoked
end
# Runs the revoking job via an executor.
def call
executor.revoked
end
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems