Module: Julewire::Karafka::Installer

Defined in:
lib/julewire/karafka/installer.rb

Class Method Summary collapse

Class Method Details

.install!(app: nil, monitor: nil, configuration: Configuration.new) ⇒ Object

Raises:



7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/julewire/karafka/installer.rb', line 7

def install!(app: nil, monitor: nil, configuration: Configuration.new)
  return false unless configuration.enabled?

  monitor ||= monitor_for(app)
  raise Error, "Karafka monitor is not available" unless monitor

  ForkHooks.subscribe!(monitor, configuration: configuration)
  if configuration.consumer_events?
    MonitorSubscription.install!(monitor, configuration: configuration, profile: :consumer)
  end
  monitor
end