Class: Karafka::Web::Management::Migrations::IntroduceWaitingInConsumersState
- Inherits:
-
Base
- Object
- Base
- Karafka::Web::Management::Migrations::IntroduceWaitingInConsumersState
- Defined in:
- lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_state.rb
Overview
Introduce waiting in consumers metrics to complement busy and enqueued for jobs stats
Instance Method Summary collapse
Methods inherited from Base
applicable?, index, migrate, sorted_descendants
Instance Method Details
#migrate(state) ⇒ Object
13 14 15 |
# File 'lib/karafka/web/management/migrations/1700234522_introduce_waiting_in_consumers_state.rb', line 13 def migrate(state) state[:stats][:waiting] = 0 end |