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