Sha256: e932a26028da2134047d7b2cc141d4a1b3eaaa99841eae5b93ec5067f036d1f3
Contents?: true
Size: 648 Bytes
Versions: 9
Compression:
Stored size: 648 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Management
module Migrations
# Similar to filling in consumers metrics, we initialize this with zeros so it is always
# present as expected
class FillMissingReceivedAndSentBytesInConsumersState < Base
# Network metrics were introduced with schema 1.2.0
self.versions_until = '1.2.0'
self.type = :consumers_state
# @param state [Hash]
def migrate(state)
state[:stats][:bytes_sent] = 0
state[:stats][:bytes_received] = 0
end
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems