module Eye::Controller::Status

Public Instance Methods

debug_data(*args) click to toggle source
# File lib/eye/controller/status.rb, line 3
def debug_data(*args)
  h = args.extract_options!
  actors = Celluloid::Actor.all.map{|actor| actor.__klass__ }.group_by{|a| a}.map{|k,v| [k, v.size]}.sort_by{|a|a[1]}.reverse

  res = {
    :about => Eye::ABOUT,
    :resources => Eye::SystemResources.resources($$),
    :ruby => RUBY_DESCRIPTION,
    :gems => %w|Celluloid Celluloid::IO StateMachine NIO Sigar|.map{|c| gem_version(c) },
    :logger => Eye::Logger.args.present? ? [Eye::Logger.dev, *Eye::Logger.args] : Eye::Logger.dev,
    :pid_path => Eye::Local::pid_path,
    :sock_path => Eye::Local::socket_path,
    :actors => actors
  }

  res[:config_yaml] = YAML.dump(current_config.to_h) if h[:config].present?

  res
end
history_data(*args) click to toggle source
# File lib/eye/controller/status.rb, line 31
def history_data(*args)
  res = {}
  history_objects(*args).each do |process|
    res[process.full_name] = process.schedule_history.reject{|c| c[:state] == :check_crash }
  end
  res
end
info_data(*args) click to toggle source
# File lib/eye/controller/status.rb, line 23
def info_data(*args)
  {:subtree => info_objects(*args).map{|a| a.status_data } }
end
short_data(*args) click to toggle source
# File lib/eye/controller/status.rb, line 27
def short_data(*args)
  {:subtree => info_objects(*args).select{ |o| o.class == Eye::Application }.map{|a| a.status_data_short } }
end

Private Instance Methods

gem_version(klass) click to toggle source
# File lib/eye/controller/status.rb, line 48
def gem_version(klass)
  v = nil
  begin
    v = eval("#{klass}::VERSION::STRING")
  rescue
    v = eval("#{klass}::VERSION") rescue ''
  end
  "#{klass}=#{v}"
end
history_objects(*args) click to toggle source
# File lib/eye/controller/status.rb, line 58
def history_objects(*args)
  args = ['*'] if args.empty?
  res = []
  matched_objects(*args) do |obj|
    if obj.is_a?(Eye::Process)
      res << obj
    elsif obj.is_a?(Eye::ChildProcess)
    else
      res += obj.processes.to_a
    end
  end
  Eye::Utils::AliveArray.new(res)
end
info_objects(*args) click to toggle source
# File lib/eye/controller/status.rb, line 41
def info_objects(*args)
  res = []
  return @applications if args.empty?
  matched_objects(*args){|obj| res << obj }
  res
end