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

Version Path
karafka-web-0.7.7 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.7.6 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.7.5 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.7.4 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.7.3 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.7.2 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.7.1 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.7.0 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.6.3 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.6.2 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.6.1 lib/karafka/web/tracking/producers/listeners/reporter.rb
karafka-web-0.6.0 lib/karafka/web/tracking/producers/listeners/reporter.rb