Class: Hadoop::API::HadoopServiceBase::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/thrift/hadoop_service_base.rb

Direct Known Subclasses

Jobtracker::Jobtracker::Client

Instance Method Summary collapse

Instance Method Details

#getAllMetrics(ctx) ⇒ Object 



61
62
63
64
 
# File 'lib/thrift/hadoop_service_base.rb', line 61

def getAllMetrics(ctx)
  send_getAllMetrics(ctx)
  return recv_getAllMetrics()
end

#getMetricsContext(ctx, contextName) ⇒ Object 



77
78
79
80
 
# File 'lib/thrift/hadoop_service_base.rb', line 77

def getMetricsContext(ctx, contextName)
  send_getMetricsContext(ctx, contextName)
  return recv_getMetricsContext()
end

#getRuntimeInfo(ctx) ⇒ Object 



31
32
33
34
 
# File 'lib/thrift/hadoop_service_base.rb', line 31

def getRuntimeInfo(ctx)
  send_getRuntimeInfo(ctx)
  return recv_getRuntimeInfo()
end

#getThreadDump(ctx) ⇒ Object 



46
47
48
49
 
# File 'lib/thrift/hadoop_service_base.rb', line 46

def getThreadDump(ctx)
  send_getThreadDump(ctx)
  return recv_getThreadDump()
end

#getVersionInfo(ctx) ⇒ Object 



16
17
18
19
 
# File 'lib/thrift/hadoop_service_base.rb', line 16

def getVersionInfo(ctx)
  send_getVersionInfo(ctx)
  return recv_getVersionInfo()
end

#recv_getAllMetrics ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


70
71
72
73
74
75
 
# File 'lib/thrift/hadoop_service_base.rb', line 70

def recv_getAllMetrics()
  result = receive_message(GetAllMetrics_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getAllMetrics failed: unknown result')
end

#recv_getMetricsContext ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


86
87
88
89
90
91
 
# File 'lib/thrift/hadoop_service_base.rb', line 86

def recv_getMetricsContext()
  result = receive_message(GetMetricsContext_result)
  return result.success unless result.success.nil?
  raise result.err unless result.err.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getMetricsContext failed: unknown result')
end

#recv_getRuntimeInfo ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


40
41
42
43
44
 
# File 'lib/thrift/hadoop_service_base.rb', line 40

def recv_getRuntimeInfo()
  result = receive_message(GetRuntimeInfo_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRuntimeInfo failed: unknown result')
end

#recv_getThreadDump ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


55
56
57
58
59
 
# File 'lib/thrift/hadoop_service_base.rb', line 55

def recv_getThreadDump()
  result = receive_message(GetThreadDump_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getThreadDump failed: unknown result')
end

#recv_getVersionInfo ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


25
26
27
28
29
 
# File 'lib/thrift/hadoop_service_base.rb', line 25

def recv_getVersionInfo()
  result = receive_message(GetVersionInfo_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getVersionInfo failed: unknown result')
end

#send_getAllMetrics(ctx) ⇒ Object 



66
67
68
 
# File 'lib/thrift/hadoop_service_base.rb', line 66

def send_getAllMetrics(ctx)
  send_message('getAllMetrics', GetAllMetrics_args, :ctx => ctx)
end

#send_getMetricsContext(ctx, contextName) ⇒ Object 



82
83
84
 
# File 'lib/thrift/hadoop_service_base.rb', line 82

def send_getMetricsContext(ctx, contextName)
  send_message('getMetricsContext', GetMetricsContext_args, :ctx => ctx, :contextName => contextName)
end

#send_getRuntimeInfo(ctx) ⇒ Object 



36
37
38
 
# File 'lib/thrift/hadoop_service_base.rb', line 36

def send_getRuntimeInfo(ctx)
  send_message('getRuntimeInfo', GetRuntimeInfo_args, :ctx => ctx)
end

#send_getThreadDump(ctx) ⇒ Object 



51
52
53
 
# File 'lib/thrift/hadoop_service_base.rb', line 51

def send_getThreadDump(ctx)
  send_message('getThreadDump', GetThreadDump_args, :ctx => ctx)
end

#send_getVersionInfo(ctx) ⇒ Object 



21
22
23
 
# File 'lib/thrift/hadoop_service_base.rb', line 21

def send_getVersionInfo(ctx)
  send_message('getVersionInfo', GetVersionInfo_args, :ctx => ctx)
end