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/matchers/base.rb,
lib/karafka/web/pro/commanding/matchers/topic.rb,
lib/karafka/web/pro/commanding/contracts/config.rb,
lib/karafka/web/pro/commanding/matchers/process_id.rb,
lib/karafka/web/pro/commanding/commands/topics/pause.rb,
lib/karafka/web/pro/commanding/matchers/message_type.rb,
lib/karafka/web/pro/commanding/matchers/partition_id.rb,
lib/karafka/web/pro/commanding/commands/topics/resume.rb,
lib/karafka/web/pro/commanding/commands/consumers/stop.rb,
lib/karafka/web/pro/commanding/handlers/topics/tracker.rb,
lib/karafka/web/pro/commanding/matchers/schema_version.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/handlers/topics/executor.rb,
lib/karafka/web/pro/commanding/handlers/topics/listener.rb,
lib/karafka/web/pro/commanding/commands/partitions/pause.rb,
lib/karafka/web/pro/commanding/commands/partitions/resume.rb,
lib/karafka/web/pro/commanding/matchers/consumer_group_id.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/topics/commands/base.rb,
lib/karafka/web/pro/commanding/handlers/topics/commands/pause.rb,
lib/karafka/web/pro/commanding/handlers/topics/commands/resume.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, Matchers 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



43
44
45
46
47
48
49
50
51
52
 
# File 'lib/karafka/web/pro/commanding.rb', line 43

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