Class: Storm::Nimbus::Client

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

Instance Method Summary collapse

Instance Method Details

#activate(name) ⇒ Object 



62
63
64
65
 
# File 'lib/storm/thrift/nimbus.rb', line 62

def activate(name)
  send_activate(name)
  recv_activate()
end

#beginFileDownload(file) ⇒ Object 



151
152
153
154
 
# File 'lib/storm/thrift/nimbus.rb', line 151

def beginFileDownload(file)
  send_beginFileDownload(file)
  return recv_beginFileDownload()
end

#beginFileUpload ⇒ Object 



108
109
110
111
 
# File 'lib/storm/thrift/nimbus.rb', line 108

def beginFileUpload()
  send_beginFileUpload()
  return recv_beginFileUpload()
end

#deactivate(name) ⇒ Object 



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

def deactivate(name)
  send_deactivate(name)
  recv_deactivate()
end

#downloadChunk(id) ⇒ Object 



166
167
168
169
 
# File 'lib/storm/thrift/nimbus.rb', line 166

def downloadChunk(id)
  send_downloadChunk(id)
  return recv_downloadChunk()
end

#finishFileUpload(location) ⇒ Object 



137
138
139
140
 
# File 'lib/storm/thrift/nimbus.rb', line 137

def finishFileUpload(location)
  send_finishFileUpload(location)
  recv_finishFileUpload()
end

#getClusterInfo ⇒ Object 



181
182
183
184
 
# File 'lib/storm/thrift/nimbus.rb', line 181

def getClusterInfo()
  send_getClusterInfo()
  return recv_getClusterInfo()
end

#getTopology(id) ⇒ Object 



228
229
230
231
 
# File 'lib/storm/thrift/nimbus.rb', line 228

def getTopology(id)
  send_getTopology(id)
  return recv_getTopology()
end

#getTopologyConf(id) ⇒ Object 



212
213
214
215
 
# File 'lib/storm/thrift/nimbus.rb', line 212

def getTopologyConf(id)
  send_getTopologyConf(id)
  return recv_getTopologyConf()
end

#getTopologyInfo(id) ⇒ Object 



196
197
198
199
 
# File 'lib/storm/thrift/nimbus.rb', line 196

def getTopologyInfo(id)
  send_getTopologyInfo(id)
  return recv_getTopologyInfo()
end

#getUserTopology(id) ⇒ Object 



244
245
246
247
 
# File 'lib/storm/thrift/nimbus.rb', line 244

def getUserTopology(id)
  send_getUserTopology(id)
  return recv_getUserTopology()
end

#killTopology(name) ⇒ Object 



32
33
34
35
 
# File 'lib/storm/thrift/nimbus.rb', line 32

def killTopology(name)
  send_killTopology(name)
  recv_killTopology()
end

#killTopologyWithOpts(name, options) ⇒ Object 



47
48
49
50
 
# File 'lib/storm/thrift/nimbus.rb', line 47

def killTopologyWithOpts(name, options)
  send_killTopologyWithOpts(name, options)
  recv_killTopologyWithOpts()
end

#rebalance(name, options) ⇒ Object 



92
93
94
95
 
# File 'lib/storm/thrift/nimbus.rb', line 92

def rebalance(name, options)
  send_rebalance(name, options)
  recv_rebalance()
end

#recv_activate ⇒ Object 



71
72
73
74
75
 
# File 'lib/storm/thrift/nimbus.rb', line 71

def recv_activate()
  result = receive_message(Activate_result)
  raise result.e unless result.e.nil?
  return
end

#recv_beginFileDownload ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


160
161
162
163
164
 
# File 'lib/storm/thrift/nimbus.rb', line 160

def recv_beginFileDownload()
  result = receive_message(BeginFileDownload_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'beginFileDownload failed: unknown result')
end

#recv_beginFileUpload ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


117
118
119
120
121
 
# File 'lib/storm/thrift/nimbus.rb', line 117

def recv_beginFileUpload()
  result = receive_message(BeginFileUpload_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'beginFileUpload failed: unknown result')
end

#recv_deactivate ⇒ Object 



86
87
88
89
90
 
# File 'lib/storm/thrift/nimbus.rb', line 86

def recv_deactivate()
  result = receive_message(Deactivate_result)
  raise result.e unless result.e.nil?
  return
end

#recv_downloadChunk ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


175
176
177
178
179
 
# File 'lib/storm/thrift/nimbus.rb', line 175

def recv_downloadChunk()
  result = receive_message(DownloadChunk_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'downloadChunk failed: unknown result')
end

#recv_finishFileUpload ⇒ Object 



146
147
148
149
 
# File 'lib/storm/thrift/nimbus.rb', line 146

def recv_finishFileUpload()
  result = receive_message(FinishFileUpload_result)
  return
end

#recv_getClusterInfo ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


190
191
192
193
194
 
# File 'lib/storm/thrift/nimbus.rb', line 190

def recv_getClusterInfo()
  result = receive_message(GetClusterInfo_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getClusterInfo failed: unknown result')
end

#recv_getTopology ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


237
238
239
240
241
242
 
# File 'lib/storm/thrift/nimbus.rb', line 237

def recv_getTopology()
  result = receive_message(GetTopology_result)
  return result.success unless result.success.nil?
  raise result.e unless result.e.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTopology failed: unknown result')
end

#recv_getTopologyConf ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


221
222
223
224
225
226
 
# File 'lib/storm/thrift/nimbus.rb', line 221

def recv_getTopologyConf()
  result = receive_message(GetTopologyConf_result)
  return result.success unless result.success.nil?
  raise result.e unless result.e.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTopologyConf failed: unknown result')
end

#recv_getTopologyInfo ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


205
206
207
208
209
210
 
# File 'lib/storm/thrift/nimbus.rb', line 205

def recv_getTopologyInfo()
  result = receive_message(GetTopologyInfo_result)
  return result.success unless result.success.nil?
  raise result.e unless result.e.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTopologyInfo failed: unknown result')
end

#recv_getUserTopology ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


253
254
255
256
257
258
 
# File 'lib/storm/thrift/nimbus.rb', line 253

def recv_getUserTopology()
  result = receive_message(GetUserTopology_result)
  return result.success unless result.success.nil?
  raise result.e unless result.e.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getUserTopology failed: unknown result')
end

#recv_killTopology ⇒ Object 



41
42
43
44
45
 
# File 'lib/storm/thrift/nimbus.rb', line 41

def recv_killTopology()
  result = receive_message(KillTopology_result)
  raise result.e unless result.e.nil?
  return
end

#recv_killTopologyWithOpts ⇒ Object 



56
57
58
59
60
 
# File 'lib/storm/thrift/nimbus.rb', line 56

def recv_killTopologyWithOpts()
  result = receive_message(KillTopologyWithOpts_result)
  raise result.e unless result.e.nil?
  return
end

#recv_rebalance ⇒ Object 



101
102
103
104
105
106
 
# File 'lib/storm/thrift/nimbus.rb', line 101

def recv_rebalance()
  result = receive_message(Rebalance_result)
  raise result.e unless result.e.nil?
  raise result.ite unless result.ite.nil?
  return
end

#recv_submitTopology ⇒ Object 



25
26
27
28
29
30
 
# File 'lib/storm/thrift/nimbus.rb', line 25

def recv_submitTopology()
  result = receive_message(SubmitTopology_result)
  raise result.e unless result.e.nil?
  raise result.ite unless result.ite.nil?
  return
end

#recv_uploadChunk ⇒ Object 



132
133
134
135
 
# File 'lib/storm/thrift/nimbus.rb', line 132

def recv_uploadChunk()
  result = receive_message(UploadChunk_result)
  return
end

#send_activate(name) ⇒ Object 



67
68
69
 
# File 'lib/storm/thrift/nimbus.rb', line 67

def send_activate(name)
  send_message('activate', Activate_args, :name => name)
end

#send_beginFileDownload(file) ⇒ Object 



156
157
158
 
# File 'lib/storm/thrift/nimbus.rb', line 156

def send_beginFileDownload(file)
  send_message('beginFileDownload', BeginFileDownload_args, :file => file)
end

#send_beginFileUpload ⇒ Object 



113
114
115
 
# File 'lib/storm/thrift/nimbus.rb', line 113

def send_beginFileUpload()
  send_message('beginFileUpload', BeginFileUpload_args)
end

#send_deactivate(name) ⇒ Object 



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

def send_deactivate(name)
  send_message('deactivate', Deactivate_args, :name => name)
end

#send_downloadChunk(id) ⇒ Object 



171
172
173
 
# File 'lib/storm/thrift/nimbus.rb', line 171

def send_downloadChunk(id)
  send_message('downloadChunk', DownloadChunk_args, :id => id)
end

#send_finishFileUpload(location) ⇒ Object 



142
143
144
 
# File 'lib/storm/thrift/nimbus.rb', line 142

def send_finishFileUpload(location)
  send_message('finishFileUpload', FinishFileUpload_args, :location => location)
end

#send_getClusterInfo ⇒ Object 



186
187
188
 
# File 'lib/storm/thrift/nimbus.rb', line 186

def send_getClusterInfo()
  send_message('getClusterInfo', GetClusterInfo_args)
end

#send_getTopology(id) ⇒ Object 



233
234
235
 
# File 'lib/storm/thrift/nimbus.rb', line 233

def send_getTopology(id)
  send_message('getTopology', GetTopology_args, :id => id)
end

#send_getTopologyConf(id) ⇒ Object 



217
218
219
 
# File 'lib/storm/thrift/nimbus.rb', line 217

def send_getTopologyConf(id)
  send_message('getTopologyConf', GetTopologyConf_args, :id => id)
end

#send_getTopologyInfo(id) ⇒ Object 



201
202
203
 
# File 'lib/storm/thrift/nimbus.rb', line 201

def send_getTopologyInfo(id)
  send_message('getTopologyInfo', GetTopologyInfo_args, :id => id)
end

#send_getUserTopology(id) ⇒ Object 



249
250
251
 
# File 'lib/storm/thrift/nimbus.rb', line 249

def send_getUserTopology(id)
  send_message('getUserTopology', GetUserTopology_args, :id => id)
end

#send_killTopology(name) ⇒ Object 



37
38
39
 
# File 'lib/storm/thrift/nimbus.rb', line 37

def send_killTopology(name)
  send_message('killTopology', KillTopology_args, :name => name)
end

#send_killTopologyWithOpts(name, options) ⇒ Object 



52
53
54
 
# File 'lib/storm/thrift/nimbus.rb', line 52

def send_killTopologyWithOpts(name, options)
  send_message('killTopologyWithOpts', KillTopologyWithOpts_args, :name => name, :options => options)
end

#send_rebalance(name, options) ⇒ Object 



97
98
99
 
# File 'lib/storm/thrift/nimbus.rb', line 97

def send_rebalance(name, options)
  send_message('rebalance', Rebalance_args, :name => name, :options => options)
end

#send_submitTopology(name, uploadedJarLocation, jsonConf, topology) ⇒ Object 



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

def send_submitTopology(name, uploadedJarLocation, jsonConf, topology)
  send_message('submitTopology', SubmitTopology_args, :name => name, :uploadedJarLocation => uploadedJarLocation, :jsonConf => jsonConf, :topology => topology)
end

#send_uploadChunk(location, chunk) ⇒ Object 



128
129
130
 
# File 'lib/storm/thrift/nimbus.rb', line 128

def send_uploadChunk(location, chunk)
  send_message('uploadChunk', UploadChunk_args, :location => location, :chunk => chunk)
end

#submitTopology(name, uploadedJarLocation, jsonConf, topology) ⇒ Object 



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

def submitTopology(name, uploadedJarLocation, jsonConf, topology)
  send_submitTopology(name, uploadedJarLocation, jsonConf, topology)
  recv_submitTopology()
end

#uploadChunk(location, chunk) ⇒ Object 



123
124
125
126
 
# File 'lib/storm/thrift/nimbus.rb', line 123

def uploadChunk(location, chunk)
  send_uploadChunk(location, chunk)
  recv_uploadChunk()
end