Sha256: e8cad07a902353590d197a0fe0d608712f7722cbd20b17b07e8faf50e2a3f8fb
Contents?: true
Size: 627 Bytes
Versions: 12
Compression:
Stored size: 627 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Tracking
module Producers
module Listeners
# Special listener that we use to report data about producers states
# We don't have to have a separate thread for reporting, because producers have their
# own internal threads for changes polling and we can utilize this thread
class Reporter < Base
# @param _event [Karafka::Core::Monitoring::Event]
def on_statistics_emitted(_event)
reporter.report
end
end
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems