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