Sha256: d21a255d4b83232b51ccfd9d17d76fe6d323b7e4ce4acc1cbf97a35cc1235174
Contents?: true
Size: 490 Bytes
Versions: 9
Compression:
Stored size: 490 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Management
module Migrations
# Introduce waiting in consumers metrics to complement busy and enqueued for jobs stats
class IntroduceWaitingInConsumersState < Base
self.versions_until = '1.2.1'
self.type = :consumers_state
# @param state [Hash]
def migrate(state)
state[:stats][:waiting] = 0
end
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems