Class: Karafka::Web::Management::Migrations::FillMissingReceivedAndSentBytesInConsumersState

Inherits:
Base
  • Object
show all
Defined in:
lib/karafka/web/management/migrations/1699543515_fill_missing_received_and_sent_bytes_in_consumers_state.rb

Overview

Similar to filling in consumers metrics, we initialize this with zeros so it is always present as expected

Instance Method Summary collapse

Methods inherited from Base

applicable?, index, migrate, sorted_descendants

Instance Method Details

#migrate(state) ⇒ Object

Parameters:

  • state (Hash) 


15
16
17
18
 
# File 'lib/karafka/web/management/migrations/1699543515_fill_missing_received_and_sent_bytes_in_consumers_state.rb', line 15

def migrate(state)
  state[:stats][:bytes_sent] = 0
  state[:stats][:bytes_received] = 0
end