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/request.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/contracts/config.rb,
lib/karafka/web/pro/commanding/commands/consumers/stop.rb,
lib/karafka/web/pro/commanding/commands/consumers/quiet.rb,
lib/karafka/web/pro/commanding/commands/consumers/trace.rb,
lib/karafka/web/pro/commanding/commands/partitions/seek.rb,
lib/karafka/web/pro/commanding/commands/partitions/pause.rb,
lib/karafka/web/pro/commanding/commands/partitions/resume.rb,
lib/karafka/web/pro/commanding/handlers/partitions/tracker.rb,
lib/karafka/web/pro/commanding/handlers/partitions/executor.rb,
lib/karafka/web/pro/commanding/handlers/partitions/listener.rb,
lib/karafka/web/pro/commanding/handlers/partitions/commands/base.rb,
lib/karafka/web/pro/commanding/handlers/partitions/commands/seek.rb,
lib/karafka/web/pro/commanding/handlers/partitions/commands/pause.rb,
lib/karafka/web/pro/commanding/handlers/partitions/commands/resume.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 traced via the Web UI

Defined Under Namespace

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

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



18
19
20
21
22
23
24
25
26
27
 
# File 'lib/karafka/web/pro/commanding.rb', line 18

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