Sha256: bc1f9a8896d0a53c05957d157026e4d01b735541ca9d3ead086de6b17773bc49
Contents?: true
Size: 622 Bytes
Versions: 9
Compression:
Stored size: 622 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Management
module Migrations
# Moves unused "processing" that was used instead of "busy" in older versions
class RemoveProcessingFromConsumersMetrics < 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.delete(:processing)
end
end
end
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems