Module: Karafka::Web::Pro::Commanding

Defined in:
lib/karafka/web/pro/commanding.rb,
lib/karafka/web/pro/commanding/config.rb,
lib/karafka/web/pro/commanding/manager.rb,
lib/karafka/web/pro/commanding/matcher.rb,
lib/karafka/web/pro/commanding/listener.rb,
lib/karafka/web/pro/commanding/dispatcher.rb,
lib/karafka/web/pro/commanding/commands/base.rb,
lib/karafka/web/pro/commanding/commands/stop.rb,
lib/karafka/web/pro/commanding/commands/probe.rb,
lib/karafka/web/pro/commanding/commands/quiet.rb,
lib/karafka/web/pro/commanding/contracts/config.rb

Overview

Namespace for things related to consumers commanding (management)

This feature allows for basic of consumers. They can be stopped, moved to quiet or probed via the Web UI

Defined Under Namespace

Modules: Commands, Contracts Classes: Config, Dispatcher, Listener, Manager, Matcher

Class Method Summary collapse

Class Method Details

.post_setup(config) ⇒ Object

Subscribes with the commanding manager when commanding is enabled

Parameters:

  • config (Karafka::Core::Configurable::Node) —

    web config



26
27
28
29
30
31
32
33
34
35
 
# File 'lib/karafka/web/pro/commanding.rb', line 26

def post_setup(config)
  # We do not use manager if commanding is not suppose to work at all
  return unless config.commanding.active

  Commanding::Contracts::Config.new.validate!(config.to_h)

  ::Karafka.monitor.subscribe(
    Commanding::Manager.instance
  )
end