Module: Kafkat::Command

Defined in:
lib/kafkat/command.rb,
lib/kafkat/command/drain.rb,
lib/kafkat/command/topics.rb,
lib/kafkat/command/brokers.rb,
lib/kafkat/command/reassign.rb,
lib/kafkat/command/shutdown.rb,
lib/kafkat/command/controller.rb,
lib/kafkat/command/partitions.rb,
lib/kafkat/command/clean-indexes.rb,
lib/kafkat/command/elect-leaders.rb,
lib/kafkat/command/resign-rewrite.rb,
lib/kafkat/command/cluster_restart.rb,
lib/kafkat/command/verify-reassign.rb,
lib/kafkat/command/verify-replicas.rb,
lib/kafkat/command/set-replication-factor.rb

Defined Under Namespace

Classes: Base, Brokers, CleanIndexes, ClusterRestart, Controller, Describe, Drain, ElectLeaders, NotFoundError, Reassign, Resign, ResignForce, SetReplicationFactor, Topics, VerifyReassign, VerifyReplicas

Class Method Summary collapse

Class Method Details

.all ⇒ Object 



5
6
7
 
# File 'lib/kafkat/command.rb', line 5

def self.all
  @all ||= {}
end

.get(name) ⇒ Object

Raises:



9
10
11
12
13
 
# File 'lib/kafkat/command.rb', line 9

def self.get(name)
  klass = all[name.downcase]
  raise NotFoundError if !klass
  klass
end