Sha256: 44f69b49c4faaa090262ddacf8bd5b445c37c374f4e51e53b4a7b7a7ffddb6e8
Contents?: true
Size: 1.04 KB
Versions: 7
Compression:
Stored size: 1.04 KB
Contents
# frozen_string_literal: true
module Karafka
module Web
module Management
module Migrations
# Renames total lag to hybrid to better represent what it is
class RenameLagTotalToLagHybridInMetrics < Base
self.versions_until = '1.2.1'
self.type = :consumers_metrics
# @param state [Hash]
def migrate(state)
state[:aggregated].each_value do |metrics|
metrics.each do |metric|
metric.last[:lag_hybrid] = metric.last[:lag_total] || 0
metric.last.delete(:lag_total)
end
end
state[:consumer_groups].each_value do |metrics|
metrics.each do |metric_group|
metric_group.last.each_value do |metric|
metric.each_value do |sample|
sample[:lag_hybrid] = sample[:lag_total]
sample.delete(:lag_total)
end
end
end
end
end
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems