Sha256: 64055e73363778d88e13302087eb624163d564b8736c6002b16fa8606912fe97

Contents?: true

Size: 811 Bytes

Versions: 17

Compression:

Stored size: 811 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Web
    module Tracking
      # Base reporter from which all the reports should inherit
      class Reporter
        include ::Karafka::Core::Helpers::Time

        # Can this reporter report. Since some reporters may report only in part of the processes
        # where Karafka is used (like `karafka server`) each may implement more complex rules.
        #
        # The basic is not to report unless we have a producer and this producer is active
        #
        # @return [Boolean]
        def active?
          return false unless ::Karafka::Web.producer
          return false unless ::Karafka::Web.producer.status.active?
          return false unless ::Karafka::Web.config.tracking.active

          true
        end
      end
    end
  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version Path
karafka-web-0.10.4 lib/karafka/web/tracking/reporter.rb
karafka-web-0.10.3 lib/karafka/web/tracking/reporter.rb
karafka-web-0.10.2 lib/karafka/web/tracking/reporter.rb
karafka-web-0.10.1 lib/karafka/web/tracking/reporter.rb
karafka-web-0.10.0 lib/karafka/web/tracking/reporter.rb
karafka-web-0.10.0.rc2 lib/karafka/web/tracking/reporter.rb
karafka-web-0.10.0.rc1 lib/karafka/web/tracking/reporter.rb
karafka-web-0.10.0.beta1 lib/karafka/web/tracking/reporter.rb
karafka-web-0.9.1 lib/karafka/web/tracking/reporter.rb
karafka-web-0.9.0 lib/karafka/web/tracking/reporter.rb
karafka-web-0.9.0.rc3 lib/karafka/web/tracking/reporter.rb
karafka-web-0.9.0.rc2 lib/karafka/web/tracking/reporter.rb
karafka-web-0.9.0.rc1 lib/karafka/web/tracking/reporter.rb
karafka-web-0.8.2 lib/karafka/web/tracking/reporter.rb
karafka-web-0.8.1 lib/karafka/web/tracking/reporter.rb
karafka-web-0.8.0 lib/karafka/web/tracking/reporter.rb
karafka-web-0.8.0.rc1 lib/karafka/web/tracking/reporter.rb