class Fog::Compute::Hadoop::Real

Public Class Methods

new(options = {}) click to toggle source
# File lib/fog/hadoop/compute.rb, line 20
def initialize(options = {})

  @compute_api_url = options[:hadoop_compute_api_url] || 'https://localhost:8088/'
  Fog.credentials[:@compute_api_url]        = options[:hadoop_compute_api_url]
  @connection = Fog::Core::Connection.new(@compute_api_url)
end

Public Instance Methods

get_app_stats() click to toggle source
# File lib/fog/hadoop/requests/compute/get_app_stats.rb, line 5
def get_app_stats
  request(
      :expects => [200, 203],
      :method => 'GET',
      :path => "#{Fog::Hadoop.yarn_endpoint}/appstatistics"
  ).body["appStatInfo"]["statItem"]
end
get_app_stats_detail(options = {}) click to toggle source
# File lib/fog/hadoop/requests/compute/get_app_stats_detail.rb, line 5
def get_app_stats_detail(options = {})
  request(
      :expects => [200, 203],
      :method => 'GET',
      :path => "#{Fog::Hadoop.yarn_endpoint}/appstatistics?#{URI.encode_www_form(options)}"
  ).body["appStatInfo"]["statItem"]
end
get_info() click to toggle source
# File lib/fog/hadoop/requests/compute/get_info.rb, line 5
def get_info
  request(
      :expects => [200, 203],
      :method => 'GET',
      :path => "#{Fog::Hadoop.yarn_endpoint}/info"
  ).body["clusterInfo"]
end
get_metrics() click to toggle source
# File lib/fog/hadoop/requests/compute/get_metrics.rb, line 5
def get_metrics
  request(
      :expects => 200,
      :method => 'GET',
      :path => "#{Fog::Hadoop.yarn_endpoint}/metrics"
  ).body["clusterMetrics"]
end
get_node(node_ref) click to toggle source
# File lib/fog/hadoop/requests/compute/get_node.rb, line 5
def get_node(node_ref)
  request(
      :expects => [200, 203],
      :method => 'GET',
      :path => "#{Fog::Hadoop.yarn_endpoint}/nodes/#{node_ref}"
  ).body["node"]
end
list_nodes() click to toggle source
# File lib/fog/hadoop/requests/compute/list_nodes.rb, line 5
def list_nodes
  request(
      :expects => 200,
      :method => 'GET',
      :path => "#{Fog::Hadoop.yarn_endpoint}/nodes"
  ).body["nodes"]["node"]
end