class Kafkat::Config

Constants

CONFIG_PATHS

Attributes

kafka_path[R]
log_path[R]
zk_path[R]

Public Class Methods

load!() click to toggle source
# File lib/kafkat/config.rb, line 15
def self.load!
  string = nil
  e = nil

  CONFIG_PATHS.each do |rel_path|
    begin
      path = File.expand_path(rel_path)
      string = File.read(path)
      break
    rescue => e
    end
  end

  raise e if e && string.nil?

  json = JSON.parse(string)
  self.new(json)

rescue Errno::ENOENT
  raise NotFoundError
rescue JSON::JSONError
  raise ParseError
end
new(json) click to toggle source
# File lib/kafkat/config.rb, line 39
def initialize(json)
  @kafka_path = json['kafka_path']
  @log_path = json['log_path']
  @zk_path = json['zk_path']
end