Sha256: 88b6a310d3f74afd11cad010f034cd8715d6071ecb7a814586050c53b1989d5d
Contents?: true
Size: 868 Bytes
Versions: 13
Compression:
Stored size: 868 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Tracking
module Producers
module Listeners
# Listener needed to start schedulers and other things that we need to collect and report
# data. We do not want to start this when code is loaded because it may not be fork
# compatible that way
class Booting < Base
# Starts (if needed) the Web UI tracking scheduler thread that periodically pings
# reporters to report needed data (when it is time).
#
# @param _event [Karafka::Core::Monitoring::Event]
def on_producer_connected(_event)
::Karafka::Web.config.tracking.scheduler.async_call(
'karafka.web.tracking.scheduler'
)
end
end
end
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems