Class: FlumeMasterAdminServer::Client

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

Instance Method Summary collapse

Instance Method Details

#getCmdStatus(cmdid) ⇒ Object 



104
105
106
107
 
# File 'lib/thrift/flume_master_admin_server.rb', line 104

def getCmdStatus(cmdid)
  send_getCmdStatus(cmdid)
  return recv_getCmdStatus()
end

#getConfigs ⇒ Object 



74
75
76
77
 
# File 'lib/thrift/flume_master_admin_server.rb', line 74

def getConfigs()
  send_getConfigs()
  return recv_getConfigs()
end

#getMappings(physicalNode) ⇒ Object 



119
120
121
122
 
# File 'lib/thrift/flume_master_admin_server.rb', line 119

def getMappings(physicalNode)
  send_getMappings(physicalNode)
  return recv_getMappings()
end

#getNodeStatuses ⇒ Object 



59
60
61
62
 
# File 'lib/thrift/flume_master_admin_server.rb', line 59

def getNodeStatuses()
  send_getNodeStatuses()
  return recv_getNodeStatuses()
end

#hasCmdId(cmdid) ⇒ Object 



89
90
91
92
 
# File 'lib/thrift/flume_master_admin_server.rb', line 89

def hasCmdId(cmdid)
  send_hasCmdId(cmdid)
  return recv_hasCmdId()
end

#isFailure(cmdid) ⇒ Object 



44
45
46
47
 
# File 'lib/thrift/flume_master_admin_server.rb', line 44

def isFailure(cmdid)
  send_isFailure(cmdid)
  return recv_isFailure()
end

#isSuccess(cmdid) ⇒ Object 



29
30
31
32
 
# File 'lib/thrift/flume_master_admin_server.rb', line 29

def isSuccess(cmdid)
  send_isSuccess(cmdid)
  return recv_isSuccess()
end

#recv_getCmdStatus ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


113
114
115
116
117
 
# File 'lib/thrift/flume_master_admin_server.rb', line 113

def recv_getCmdStatus()
  result = receive_message(GetCmdStatus_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getCmdStatus failed: unknown result')
end

#recv_getConfigs ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


83
84
85
86
87
 
# File 'lib/thrift/flume_master_admin_server.rb', line 83

def recv_getConfigs()
  result = receive_message(GetConfigs_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getConfigs failed: unknown result')
end

#recv_getMappings ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


128
129
130
131
132
 
# File 'lib/thrift/flume_master_admin_server.rb', line 128

def recv_getMappings()
  result = receive_message(GetMappings_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getMappings failed: unknown result')
end

#recv_getNodeStatuses ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


68
69
70
71
72
 
# File 'lib/thrift/flume_master_admin_server.rb', line 68

def recv_getNodeStatuses()
  result = receive_message(GetNodeStatuses_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getNodeStatuses failed: unknown result')
end

#recv_hasCmdId ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


98
99
100
101
102
 
# File 'lib/thrift/flume_master_admin_server.rb', line 98

def recv_hasCmdId()
  result = receive_message(HasCmdId_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'hasCmdId failed: unknown result')
end

#recv_isFailure ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


53
54
55
56
57
 
# File 'lib/thrift/flume_master_admin_server.rb', line 53

def recv_isFailure()
  result = receive_message(IsFailure_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'isFailure failed: unknown result')
end

#recv_isSuccess ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


38
39
40
41
42
 
# File 'lib/thrift/flume_master_admin_server.rb', line 38

def recv_isSuccess()
  result = receive_message(IsSuccess_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'isSuccess failed: unknown result')
end

#recv_submit ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


23
24
25
26
27
 
# File 'lib/thrift/flume_master_admin_server.rb', line 23

def recv_submit()
  result = receive_message(Submit_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'submit failed: unknown result')
end

#send_getCmdStatus(cmdid) ⇒ Object 



109
110
111
 
# File 'lib/thrift/flume_master_admin_server.rb', line 109

def send_getCmdStatus(cmdid)
  send_message('getCmdStatus', GetCmdStatus_args, :cmdid => cmdid)
end

#send_getConfigs ⇒ Object 



79
80
81
 
# File 'lib/thrift/flume_master_admin_server.rb', line 79

def send_getConfigs()
  send_message('getConfigs', GetConfigs_args)
end

#send_getMappings(physicalNode) ⇒ Object 



124
125
126
 
# File 'lib/thrift/flume_master_admin_server.rb', line 124

def send_getMappings(physicalNode)
  send_message('getMappings', GetMappings_args, :physicalNode => physicalNode)
end

#send_getNodeStatuses ⇒ Object 



64
65
66
 
# File 'lib/thrift/flume_master_admin_server.rb', line 64

def send_getNodeStatuses()
  send_message('getNodeStatuses', GetNodeStatuses_args)
end

#send_hasCmdId(cmdid) ⇒ Object 



94
95
96
 
# File 'lib/thrift/flume_master_admin_server.rb', line 94

def send_hasCmdId(cmdid)
  send_message('hasCmdId', HasCmdId_args, :cmdid => cmdid)
end

#send_isFailure(cmdid) ⇒ Object 



49
50
51
 
# File 'lib/thrift/flume_master_admin_server.rb', line 49

def send_isFailure(cmdid)
  send_message('isFailure', IsFailure_args, :cmdid => cmdid)
end

#send_isSuccess(cmdid) ⇒ Object 



34
35
36
 
# File 'lib/thrift/flume_master_admin_server.rb', line 34

def send_isSuccess(cmdid)
  send_message('isSuccess', IsSuccess_args, :cmdid => cmdid)
end

#send_submit(command) ⇒ Object 



19
20
21
 
# File 'lib/thrift/flume_master_admin_server.rb', line 19

def send_submit(command)
  send_message('submit', Submit_args, :command => command)
end

#submit(command) ⇒ Object 



14
15
16
17
 
# File 'lib/thrift/flume_master_admin_server.rb', line 14

def submit(command)
  send_submit(command)
  return recv_submit()
end