Sha256: 79a9852afd5bbbdd89ce49ee695d0200a8027380f3733f8c9a17ffd9864b3558

Contents?: true

Size: 626 Bytes

Versions: 9

Compression:

Stored size: 626 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Web
    module Management
      module Migrations
        # Introduce waiting in consumers metrics to complement busy and enqueued for jobs metrics
        class IntroduceWaitingInConsumersMetrics < Base
          self.versions_until = '1.1.1'
          self.type = :consumers_metrics

          # @param state [Hash]
          def migrate(state)
            state[:aggregated].each_value do |metrics|
              metrics.each do |metric|
                metric.last[:waiting] = 0
              end
            end
          end
        end
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
karafka-web-0.9.1 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb
karafka-web-0.9.0 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb
karafka-web-0.9.0.rc3 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb
karafka-web-0.9.0.rc2 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb
karafka-web-0.9.0.rc1 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb
karafka-web-0.8.2 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb
karafka-web-0.8.1 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb
karafka-web-0.8.0 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb
karafka-web-0.8.0.rc1 lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_metrics.rb