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