Sha256: d98dc9b76b4151b7a11d0b55ad96272c50d105d59449d39e1ef7861bebd73ca8
Contents?: true
Size: 567 Bytes
Versions: 7
Compression:
Stored size: 567 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Management
module Migrations
# Moves to using lag total as a normalization for both lags
class IntroduceLagTotalInStates < Base
self.versions_until = '1.3.0'
self.type = :consumers_state
# @param state [Hash]
def migrate(state)
state[:stats][:lag_total] = state[:stats][:lag_stored]
state[:stats].delete(:lag)
state[:stats].delete(:lag_stored)
end
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems