Sha256: 775ebc191282090107deb98d537c7e6f4a08864a108230c5495dc79f72c412d7
Contents?: true
Size: 787 Bytes
Versions: 26
Compression:
Stored size: 787 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Processing
module Jobs
# Type of job that we may use to run some extra handling that happens without the user
# related lifecycle event like consumption, revocation, etc.
class Idle < Base
# @param executor [Karafka::Processing::Executor] executor that is suppose to run a given
# job on an active consumer
# @return [Shutdown]
def initialize(executor)
@executor = executor
super()
end
# Runs code prior to scheduling this idle job
def before_schedule
executor.before_schedule_idle
end
# Run the idle work via the executor
def call
executor.idle
end
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems