Sha256: afd4e3e6a6599dd0bf0c5e9c128f79f670383f11223bc86776ac7d5602ac5fa6
Contents?: true
Size: 965 Bytes
Versions: 9
Compression:
Stored size: 965 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Management
module Migrations
# Initial migration that sets the consumers metrics initial first state.
# This is the basic of metrics as they were when they were introduced.
class SetInitialConsumersMetrics < Base
# Always migrate from empty up
self.versions_until = '0.0.1'
self.type = :consumers_metrics
# @param state [Hash] initial empty state
def migrate(state)
state.merge!(
aggregated: {
days: [],
hours: [],
minutes: [],
seconds: []
},
consumer_groups: {
days: [],
hours: [],
minutes: [],
seconds: []
},
dispatched_at: float_now
)
end
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems