Module: Karafka::Callbacks::Config

Included in:
Setup::Config
Defined in:
lib/karafka/callbacks/config.rb

Overview

Additional configuration required to store procs that we will execute upon callback trigger

Class Method Summary collapse

Class Method Details

.extended(klass) ⇒ Object

Builds up internal callback accumulators

Parameters:

  • klass (Class)

    Class that we extend with callback config



9
10
11
12
13
14
15
16
17
18
19
# File 'lib/karafka/callbacks/config.rb', line 9

def self.extended(klass)
  # option internal [Hash] - optional - internal karafka configuration settings that should
  #   never be changed by users directly
  klass.setting :callbacks do
    Callbacks::TYPES.each do |callback_type|
      # option [Array<Proc>] an array of blocks that will be executed at a given moment
      #   depending on the callback type
      setting callback_type, []
    end
  end
end