Class: Karafka::Web::Management::Migrations::RemoveProcessingFromConsumersMetrics
- Inherits:
-
Base
- Object
- Base
- Karafka::Web::Management::Migrations::RemoveProcessingFromConsumersMetrics
- Defined in:
- lib/karafka/web/management/migrations/1700234522_remove_processing_from_consumers_metrics.rb
Overview
Moves unused “processing” that was used instead of “busy” in older versions
Instance Method Summary collapse
Methods inherited from Base
applicable?, index, migrate, sorted_descendants
Instance Method Details
#migrate(state) ⇒ Object
13 14 15 16 17 18 19 |
# File 'lib/karafka/web/management/migrations/1700234522_remove_processing_from_consumers_metrics.rb', line 13 def migrate(state) state[:aggregated].each_value do |metrics| metrics.each do |metric| metric.last.delete(:processing) end end end |