class Kafkat::Command::Base
Attributes
command_name[R]
config[R]
Public Class Methods
new(config)
click to toggle source
# File lib/kafkat/command.rb, line 39 def initialize(config) @config = config end
register_as(name)
click to toggle source
# File lib/kafkat/command.rb, line 26 def self.register_as(name) @command_name = name Command.all[name] = self end
usage(format, description)
click to toggle source
# File lib/kafkat/command.rb, line 35 def self.usage(format, description) usages << [format, description] end
usages()
click to toggle source
# File lib/kafkat/command.rb, line 31 def self.usages @usages ||= [] end
Public Instance Methods
admin()
click to toggle source
# File lib/kafkat/command.rb, line 47 def admin @admin ||= begin Interface::Admin.new(config) end end
kafka_logs()
click to toggle source
# File lib/kafkat/command.rb, line 59 def kafka_logs @kafka_logs ||= begin Interface::KafkaLogs.new(config) end end
run()
click to toggle source
# File lib/kafkat/command.rb, line 43 def run raise NotImplementedError end
zookeeper()
click to toggle source
# File lib/kafkat/command.rb, line 53 def zookeeper @zookeeper ||= begin Interface::Zookeeper.new(config) end end