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
-
.post_setup(config) ⇒ Object
Subscribes with the commanding manager when commanding is enabled.
Class Method Details
.post_setup(config) ⇒ Object
Subscribes with the commanding manager when commanding is enabled
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 |