Sha256: 46d5a4cdce14989e6295fa05253d55e4d1229c4067f00d21e4db2f8e77557f84
Contents?: true
Size: 541 Bytes
Versions: 7
Compression:
Stored size: 541 Bytes
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 RenameLagTotalToLagHybridInStates < Base
self.versions_until = '1.3.1'
self.type = :consumers_state
# @param state [Hash]
def migrate(state)
state[:stats][:lag_hybrid] = state[:stats][:lag_total] || 0
state[:stats].delete(:lag_total)
end
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems