Class: Wakame::Cli::Subcommand::Status

Inherits:

Object

• Object
• Wakame::Cli::Subcommand::Status

Includes:

Wakame::Cli::Subcommand

Defined in:

lib/wakame/runner/administrator_command.rb

Constant Summary

STATUS_TMPL =

<<__E__
<%- if cluster -%>
Cluster : <%= cluster["name"].to_s %> (<%= cluster_status_msg(cluster["status"]) %>)
<%- cluster["resources"].keys.each { |res_id|
  resource = body["resources"][res_id]
-%>
  <%= resource["class_type"] %> : <current=<%= resource["instance_count"] %> min=<%= resource["min_instances"] %>, max=<%= resource["max_instances"] %><%= resource["require_agent"] ? "" : ", AgentLess" %>>
  <%- resource["services_ref"].each { |svc| -%>
     <%= svc["id"] %> (<%= svc_status_msg(svc["status"]) %>:<%= monitor_status_msg(svc["monitor_status"]) %>)
  <%- } -%>
<%- } -%>
<%- if cluster["services"].size > 0  -%>

Instances (<%= cluster["services"].size %>):
  <%- cluster["services"].keys.each { |svc_id| 
    svc = body["services"][svc_id]
  -%>
  <%= svc_id %> : <%= svc["resource_ref"]["class_type"] %> (<%= svc_status_msg(svc["status"]) %>:<%= monitor_status_msg(svc["monitor_status"]) %>)
    <%- if svc["agent_ref"] -%>
    On VM: <%= svc["agent_ref"]["id"] %>
    <%- end -%>
  <%- } -%>
<%- end -%>
<%- if cluster["cloud_hosts"].size > 0 -%>

Cloud Host (<%= cluster["cloud_hosts"].size %>):
  <%- cluster["cloud_hosts"].keys.each { |host_id| 
    cloud_host = body["cloud_hosts"][host_id]
  -%>
  <%= host_id %> : <% if cloud_host["agent_id"] %>bind to <%= cloud_host["agent_id"] %><% end %>
    <%- assigned_svcs = body['services'].values.find_all{|data| data['cloud_host_id'] == host_id } -%>
    <%- if assigned_svcs.size > 0 -%>
    Assigned: <%= body['services'].values.find_all{|data| data['cloud_host_id'] == host_id }.map{|data| data['resource_ref']['class_type'] }.join(', ')  %>
    <%- end -%>
  <%- } -%>
<%- end -%>
<%- else # if cluster -%>
Cluster: 
  No cluster data is loaded in master. (Run import_cluster_config first)
<%- end # if cluster -%>

<%- if agent_pool && agent_pool["group_active"].size > 0 -%>

Agents (<%= agent_pool["group_active"].size %>):
  <%- agent_pool["group_active"].each { |agent_id|
  a = body["agents"][agent_id]
  -%>
  <%= a["id"] %> : <%= (Time.now - Time.parse(a["last_ping_at"])).to_i %> sec(s) (<%= agent_status_msg(a["status"]) %>)
   <%- if a["reported_services"].size > 0 && !cluster["services"].empty? -%>
    Services (<%= a["reported_services"].size %>): <%= a["reported_services"].keys.collect{ |svc_id|
                body['services'][svc_id].nil? ? 'Unknown:' + svc_id[0,5] + '...' :  body["services"][svc_id]["resource_ref"]["class_type"]
              }.join(', ') %>
   <%- end -%>
  <%- } -%>
<%- else -%>

Agents (0):
.....
  None of agents are observed.
<%- end -%>
__E__

SVC_STATUS_MSG =

{
  Wakame::Service::STATUS_TERMINATE=>'Terminated',
  Wakame::Service::STATUS_INIT=>'Initialized',
  Wakame::Service::STATUS_OFFLINE=>'Offline',
  Wakame::Service::STATUS_ONLINE=>'Online',
  Wakame::Service::STATUS_UNKNOWN=>'Unknown',
  Wakame::Service::STATUS_FAIL=>'Fail',
  Wakame::Service::STATUS_STARTING=>'Starting...',
  Wakame::Service::STATUS_STOPPING=>'Stopping...',
  Wakame::Service::STATUS_RELOADING=>'Reloading...',
  Wakame::Service::STATUS_MIGRATING=>'Migrating...',
  Wakame::Service::STATUS_ENTERING=>'Entering...',
  Wakame::Service::STATUS_QUITTING=>'Quitting...',
  Wakame::Service::STATUS_RUNNING=>'Running'
}

SVC_MONITOR_STATUS_MSG =

{
  Wakame::Service::STATUS_OFFLINE=>'Offline',
  Wakame::Service::STATUS_ONLINE=>'Online',
  Wakame::Service::STATUS_UNKNOWN=>'Unknown',
  Wakame::Service::STATUS_FAIL=>'Fail'
}

AGENT_STATUS_MSG =

{
  Wakame::Service::Agent::STATUS_END     => 'Terminated',
  Wakame::Service::Agent::STATUS_INIT    => 'Initialized',
  Wakame::Service::Agent::STATUS_OFFLINE => 'Offline',
  Wakame::Service::Agent::STATUS_ONLINE  => 'Online',
  Wakame::Service::Agent::STATUS_UNKNOWN => 'Unknown',
  Wakame::Service::Agent::STATUS_TIMEOUT => 'Timedout',
  Wakame::Service::Agent::STATUS_RUNNING => 'Running',
  Wakame::Service::Agent::STATUS_REGISTERRING => 'Registerring...',
  Wakame::Service::Agent::STATUS_TERMINATING  => 'Terminating...'
}

CLUSTER_STATUS_MSG =

{
  Wakame::Service::ServiceCluster::STATUS_OFFLINE=>'Offline',
  Wakame::Service::ServiceCluster::STATUS_ONLINE=>'Online',
  Wakame::Service::ServiceCluster::STATUS_PARTIAL_ONLINE=>'Partial Online'
}

Instance Method Summary

• #parse(args) ⇒ Object
• #print_result ⇒ Object
• #run(requester) ⇒ Object

Methods included from Wakame::Cli::Subcommand

#create_parser, included

Instance Method Details

#parse(args) ⇒ Object

# File 'lib/wakame/runner/administrator_command.rb', line 448

def parse(args)
  @params = {}
  create_parser(args){|opts|
    opts.banner = "Usage: status"
    #opts.separator ""
    #opts.separator "options:"
  }
end

#print_result ⇒ Object

# File 'lib/wakame/runner/administrator_command.rb', line 461

def print_result()
  require 'time'
  body = @res[1]["data"]
  map_ref_data(body)

  cluster = body["cluster"]
  agent_pool = body["agent_pool"]
  puts ERB.new(STATUS_TMPL, nil, '-').result(binding)
end

#run(requester) ⇒ Object

# File 'lib/wakame/runner/administrator_command.rb', line 457

def run(requester)
  @res = requester.request(@params)
end