1 | # |
---|
2 | # Autogenerated by Thrift |
---|
3 | # |
---|
4 | # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING |
---|
5 | # |
---|
6 | |
---|
7 | require 'thrift/protocol' |
---|
8 | require 'thrift' |
---|
9 | require 'hadoopfs_types' |
---|
10 | |
---|
11 | module ThriftHadoopFileSystem |
---|
12 | class Client |
---|
13 | include Thrift::Client |
---|
14 | |
---|
15 | def setInactivityTimeoutPeriod(periodInSeconds) |
---|
16 | send_setInactivityTimeoutPeriod(periodInSeconds) |
---|
17 | recv_setInactivityTimeoutPeriod() |
---|
18 | end |
---|
19 | |
---|
20 | def send_setInactivityTimeoutPeriod(periodInSeconds) |
---|
21 | send_message('setInactivityTimeoutPeriod', SetInactivityTimeoutPeriod_args, :periodInSeconds => periodInSeconds) |
---|
22 | end |
---|
23 | |
---|
24 | def recv_setInactivityTimeoutPeriod() |
---|
25 | result = receive_message(SetInactivityTimeoutPeriod_result) |
---|
26 | return |
---|
27 | end |
---|
28 | |
---|
29 | def shutdown(status) |
---|
30 | send_shutdown(status) |
---|
31 | recv_shutdown() |
---|
32 | end |
---|
33 | |
---|
34 | def send_shutdown(status) |
---|
35 | send_message('shutdown', Shutdown_args, :status => status) |
---|
36 | end |
---|
37 | |
---|
38 | def recv_shutdown() |
---|
39 | result = receive_message(Shutdown_result) |
---|
40 | return |
---|
41 | end |
---|
42 | |
---|
43 | def create(path) |
---|
44 | send_create(path) |
---|
45 | return recv_create() |
---|
46 | end |
---|
47 | |
---|
48 | def send_create(path) |
---|
49 | send_message('create', Create_args, :path => path) |
---|
50 | end |
---|
51 | |
---|
52 | def recv_create() |
---|
53 | result = receive_message(Create_result) |
---|
54 | return result.success unless result.success.nil? |
---|
55 | raise result.ouch unless result.ouch.nil? |
---|
56 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'create failed: unknown result') |
---|
57 | end |
---|
58 | |
---|
59 | def createFile(path, mode, overwrite, bufferSize, block_replication, blocksize) |
---|
60 | send_createFile(path, mode, overwrite, bufferSize, block_replication, blocksize) |
---|
61 | return recv_createFile() |
---|
62 | end |
---|
63 | |
---|
64 | def send_createFile(path, mode, overwrite, bufferSize, block_replication, blocksize) |
---|
65 | send_message('createFile', CreateFile_args, :path => path, :mode => mode, :overwrite => overwrite, :bufferSize => bufferSize, :block_replication => block_replication, :blocksize => blocksize) |
---|
66 | end |
---|
67 | |
---|
68 | def recv_createFile() |
---|
69 | result = receive_message(CreateFile_result) |
---|
70 | return result.success unless result.success.nil? |
---|
71 | raise result.ouch unless result.ouch.nil? |
---|
72 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'createFile failed: unknown result') |
---|
73 | end |
---|
74 | |
---|
75 | def open(path) |
---|
76 | send_open(path) |
---|
77 | return recv_open() |
---|
78 | end |
---|
79 | |
---|
80 | def send_open(path) |
---|
81 | send_message('open', Open_args, :path => path) |
---|
82 | end |
---|
83 | |
---|
84 | def recv_open() |
---|
85 | result = receive_message(Open_result) |
---|
86 | return result.success unless result.success.nil? |
---|
87 | raise result.ouch unless result.ouch.nil? |
---|
88 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'open failed: unknown result') |
---|
89 | end |
---|
90 | |
---|
91 | def append(path) |
---|
92 | send_append(path) |
---|
93 | return recv_append() |
---|
94 | end |
---|
95 | |
---|
96 | def send_append(path) |
---|
97 | send_message('append', Append_args, :path => path) |
---|
98 | end |
---|
99 | |
---|
100 | def recv_append() |
---|
101 | result = receive_message(Append_result) |
---|
102 | return result.success unless result.success.nil? |
---|
103 | raise result.ouch unless result.ouch.nil? |
---|
104 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'append failed: unknown result') |
---|
105 | end |
---|
106 | |
---|
107 | def write(handle, data) |
---|
108 | send_write(handle, data) |
---|
109 | return recv_write() |
---|
110 | end |
---|
111 | |
---|
112 | def send_write(handle, data) |
---|
113 | send_message('write', Write_args, :handle => handle, :data => data) |
---|
114 | end |
---|
115 | |
---|
116 | def recv_write() |
---|
117 | result = receive_message(Write_result) |
---|
118 | return result.success unless result.success.nil? |
---|
119 | raise result.ouch unless result.ouch.nil? |
---|
120 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'write failed: unknown result') |
---|
121 | end |
---|
122 | |
---|
123 | def read(handle, offset, size) |
---|
124 | send_read(handle, offset, size) |
---|
125 | return recv_read() |
---|
126 | end |
---|
127 | |
---|
128 | def send_read(handle, offset, size) |
---|
129 | send_message('read', Read_args, :handle => handle, :offset => offset, :size => size) |
---|
130 | end |
---|
131 | |
---|
132 | def recv_read() |
---|
133 | result = receive_message(Read_result) |
---|
134 | return result.success unless result.success.nil? |
---|
135 | raise result.ouch unless result.ouch.nil? |
---|
136 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'read failed: unknown result') |
---|
137 | end |
---|
138 | |
---|
139 | def close(out) |
---|
140 | send_close(out) |
---|
141 | return recv_close() |
---|
142 | end |
---|
143 | |
---|
144 | def send_close(out) |
---|
145 | send_message('close', Close_args, :out => out) |
---|
146 | end |
---|
147 | |
---|
148 | def recv_close() |
---|
149 | result = receive_message(Close_result) |
---|
150 | return result.success unless result.success.nil? |
---|
151 | raise result.ouch unless result.ouch.nil? |
---|
152 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'close failed: unknown result') |
---|
153 | end |
---|
154 | |
---|
155 | def rm(path, recursive) |
---|
156 | send_rm(path, recursive) |
---|
157 | return recv_rm() |
---|
158 | end |
---|
159 | |
---|
160 | def send_rm(path, recursive) |
---|
161 | send_message('rm', Rm_args, :path => path, :recursive => recursive) |
---|
162 | end |
---|
163 | |
---|
164 | def recv_rm() |
---|
165 | result = receive_message(Rm_result) |
---|
166 | return result.success unless result.success.nil? |
---|
167 | raise result.ouch unless result.ouch.nil? |
---|
168 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'rm failed: unknown result') |
---|
169 | end |
---|
170 | |
---|
171 | def rename(path, dest) |
---|
172 | send_rename(path, dest) |
---|
173 | return recv_rename() |
---|
174 | end |
---|
175 | |
---|
176 | def send_rename(path, dest) |
---|
177 | send_message('rename', Rename_args, :path => path, :dest => dest) |
---|
178 | end |
---|
179 | |
---|
180 | def recv_rename() |
---|
181 | result = receive_message(Rename_result) |
---|
182 | return result.success unless result.success.nil? |
---|
183 | raise result.ouch unless result.ouch.nil? |
---|
184 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'rename failed: unknown result') |
---|
185 | end |
---|
186 | |
---|
187 | def mkdirs(path) |
---|
188 | send_mkdirs(path) |
---|
189 | return recv_mkdirs() |
---|
190 | end |
---|
191 | |
---|
192 | def send_mkdirs(path) |
---|
193 | send_message('mkdirs', Mkdirs_args, :path => path) |
---|
194 | end |
---|
195 | |
---|
196 | def recv_mkdirs() |
---|
197 | result = receive_message(Mkdirs_result) |
---|
198 | return result.success unless result.success.nil? |
---|
199 | raise result.ouch unless result.ouch.nil? |
---|
200 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'mkdirs failed: unknown result') |
---|
201 | end |
---|
202 | |
---|
203 | def exists(path) |
---|
204 | send_exists(path) |
---|
205 | return recv_exists() |
---|
206 | end |
---|
207 | |
---|
208 | def send_exists(path) |
---|
209 | send_message('exists', Exists_args, :path => path) |
---|
210 | end |
---|
211 | |
---|
212 | def recv_exists() |
---|
213 | result = receive_message(Exists_result) |
---|
214 | return result.success unless result.success.nil? |
---|
215 | raise result.ouch unless result.ouch.nil? |
---|
216 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'exists failed: unknown result') |
---|
217 | end |
---|
218 | |
---|
219 | def stat(path) |
---|
220 | send_stat(path) |
---|
221 | return recv_stat() |
---|
222 | end |
---|
223 | |
---|
224 | def send_stat(path) |
---|
225 | send_message('stat', Stat_args, :path => path) |
---|
226 | end |
---|
227 | |
---|
228 | def recv_stat() |
---|
229 | result = receive_message(Stat_result) |
---|
230 | return result.success unless result.success.nil? |
---|
231 | raise result.ouch unless result.ouch.nil? |
---|
232 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'stat failed: unknown result') |
---|
233 | end |
---|
234 | |
---|
235 | def listStatus(path) |
---|
236 | send_listStatus(path) |
---|
237 | return recv_listStatus() |
---|
238 | end |
---|
239 | |
---|
240 | def send_listStatus(path) |
---|
241 | send_message('listStatus', ListStatus_args, :path => path) |
---|
242 | end |
---|
243 | |
---|
244 | def recv_listStatus() |
---|
245 | result = receive_message(ListStatus_result) |
---|
246 | return result.success unless result.success.nil? |
---|
247 | raise result.ouch unless result.ouch.nil? |
---|
248 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'listStatus failed: unknown result') |
---|
249 | end |
---|
250 | |
---|
251 | def chmod(path, mode) |
---|
252 | send_chmod(path, mode) |
---|
253 | recv_chmod() |
---|
254 | end |
---|
255 | |
---|
256 | def send_chmod(path, mode) |
---|
257 | send_message('chmod', Chmod_args, :path => path, :mode => mode) |
---|
258 | end |
---|
259 | |
---|
260 | def recv_chmod() |
---|
261 | result = receive_message(Chmod_result) |
---|
262 | raise result.ouch unless result.ouch.nil? |
---|
263 | return |
---|
264 | end |
---|
265 | |
---|
266 | def chown(path, owner, group) |
---|
267 | send_chown(path, owner, group) |
---|
268 | recv_chown() |
---|
269 | end |
---|
270 | |
---|
271 | def send_chown(path, owner, group) |
---|
272 | send_message('chown', Chown_args, :path => path, :owner => owner, :group => group) |
---|
273 | end |
---|
274 | |
---|
275 | def recv_chown() |
---|
276 | result = receive_message(Chown_result) |
---|
277 | raise result.ouch unless result.ouch.nil? |
---|
278 | return |
---|
279 | end |
---|
280 | |
---|
281 | def setReplication(path, replication) |
---|
282 | send_setReplication(path, replication) |
---|
283 | recv_setReplication() |
---|
284 | end |
---|
285 | |
---|
286 | def send_setReplication(path, replication) |
---|
287 | send_message('setReplication', SetReplication_args, :path => path, :replication => replication) |
---|
288 | end |
---|
289 | |
---|
290 | def recv_setReplication() |
---|
291 | result = receive_message(SetReplication_result) |
---|
292 | raise result.ouch unless result.ouch.nil? |
---|
293 | return |
---|
294 | end |
---|
295 | |
---|
296 | def getFileBlockLocations(path, start, length) |
---|
297 | send_getFileBlockLocations(path, start, length) |
---|
298 | return recv_getFileBlockLocations() |
---|
299 | end |
---|
300 | |
---|
301 | def send_getFileBlockLocations(path, start, length) |
---|
302 | send_message('getFileBlockLocations', GetFileBlockLocations_args, :path => path, :start => start, :length => length) |
---|
303 | end |
---|
304 | |
---|
305 | def recv_getFileBlockLocations() |
---|
306 | result = receive_message(GetFileBlockLocations_result) |
---|
307 | return result.success unless result.success.nil? |
---|
308 | raise result.ouch unless result.ouch.nil? |
---|
309 | raise Thrift::ApplicationException.new(Thrift::ApplicationException::MISSING_RESULT, 'getFileBlockLocations failed: unknown result') |
---|
310 | end |
---|
311 | |
---|
312 | end |
---|
313 | |
---|
314 | class Processor |
---|
315 | include Thrift::Processor |
---|
316 | |
---|
317 | def process_setInactivityTimeoutPeriod(seqid, iprot, oprot) |
---|
318 | args = read_args(iprot, SetInactivityTimeoutPeriod_args) |
---|
319 | result = SetInactivityTimeoutPeriod_result.new() |
---|
320 | @handler.setInactivityTimeoutPeriod(args.periodInSeconds) |
---|
321 | write_result(result, oprot, 'setInactivityTimeoutPeriod', seqid) |
---|
322 | end |
---|
323 | |
---|
324 | def process_shutdown(seqid, iprot, oprot) |
---|
325 | args = read_args(iprot, Shutdown_args) |
---|
326 | result = Shutdown_result.new() |
---|
327 | @handler.shutdown(args.status) |
---|
328 | write_result(result, oprot, 'shutdown', seqid) |
---|
329 | end |
---|
330 | |
---|
331 | def process_create(seqid, iprot, oprot) |
---|
332 | args = read_args(iprot, Create_args) |
---|
333 | result = Create_result.new() |
---|
334 | begin |
---|
335 | result.success = @handler.create(args.path) |
---|
336 | rescue ThriftIOException => ouch |
---|
337 | result.ouch = ouch |
---|
338 | end |
---|
339 | write_result(result, oprot, 'create', seqid) |
---|
340 | end |
---|
341 | |
---|
342 | def process_createFile(seqid, iprot, oprot) |
---|
343 | args = read_args(iprot, CreateFile_args) |
---|
344 | result = CreateFile_result.new() |
---|
345 | begin |
---|
346 | result.success = @handler.createFile(args.path, args.mode, args.overwrite, args.bufferSize, args.block_replication, args.blocksize) |
---|
347 | rescue ThriftIOException => ouch |
---|
348 | result.ouch = ouch |
---|
349 | end |
---|
350 | write_result(result, oprot, 'createFile', seqid) |
---|
351 | end |
---|
352 | |
---|
353 | def process_open(seqid, iprot, oprot) |
---|
354 | args = read_args(iprot, Open_args) |
---|
355 | result = Open_result.new() |
---|
356 | begin |
---|
357 | result.success = @handler.open(args.path) |
---|
358 | rescue ThriftIOException => ouch |
---|
359 | result.ouch = ouch |
---|
360 | end |
---|
361 | write_result(result, oprot, 'open', seqid) |
---|
362 | end |
---|
363 | |
---|
364 | def process_append(seqid, iprot, oprot) |
---|
365 | args = read_args(iprot, Append_args) |
---|
366 | result = Append_result.new() |
---|
367 | begin |
---|
368 | result.success = @handler.append(args.path) |
---|
369 | rescue ThriftIOException => ouch |
---|
370 | result.ouch = ouch |
---|
371 | end |
---|
372 | write_result(result, oprot, 'append', seqid) |
---|
373 | end |
---|
374 | |
---|
375 | def process_write(seqid, iprot, oprot) |
---|
376 | args = read_args(iprot, Write_args) |
---|
377 | result = Write_result.new() |
---|
378 | begin |
---|
379 | result.success = @handler.write(args.handle, args.data) |
---|
380 | rescue ThriftIOException => ouch |
---|
381 | result.ouch = ouch |
---|
382 | end |
---|
383 | write_result(result, oprot, 'write', seqid) |
---|
384 | end |
---|
385 | |
---|
386 | def process_read(seqid, iprot, oprot) |
---|
387 | args = read_args(iprot, Read_args) |
---|
388 | result = Read_result.new() |
---|
389 | begin |
---|
390 | result.success = @handler.read(args.handle, args.offset, args.size) |
---|
391 | rescue ThriftIOException => ouch |
---|
392 | result.ouch = ouch |
---|
393 | end |
---|
394 | write_result(result, oprot, 'read', seqid) |
---|
395 | end |
---|
396 | |
---|
397 | def process_close(seqid, iprot, oprot) |
---|
398 | args = read_args(iprot, Close_args) |
---|
399 | result = Close_result.new() |
---|
400 | begin |
---|
401 | result.success = @handler.close(args.out) |
---|
402 | rescue ThriftIOException => ouch |
---|
403 | result.ouch = ouch |
---|
404 | end |
---|
405 | write_result(result, oprot, 'close', seqid) |
---|
406 | end |
---|
407 | |
---|
408 | def process_rm(seqid, iprot, oprot) |
---|
409 | args = read_args(iprot, Rm_args) |
---|
410 | result = Rm_result.new() |
---|
411 | begin |
---|
412 | result.success = @handler.rm(args.path, args.recursive) |
---|
413 | rescue ThriftIOException => ouch |
---|
414 | result.ouch = ouch |
---|
415 | end |
---|
416 | write_result(result, oprot, 'rm', seqid) |
---|
417 | end |
---|
418 | |
---|
419 | def process_rename(seqid, iprot, oprot) |
---|
420 | args = read_args(iprot, Rename_args) |
---|
421 | result = Rename_result.new() |
---|
422 | begin |
---|
423 | result.success = @handler.rename(args.path, args.dest) |
---|
424 | rescue ThriftIOException => ouch |
---|
425 | result.ouch = ouch |
---|
426 | end |
---|
427 | write_result(result, oprot, 'rename', seqid) |
---|
428 | end |
---|
429 | |
---|
430 | def process_mkdirs(seqid, iprot, oprot) |
---|
431 | args = read_args(iprot, Mkdirs_args) |
---|
432 | result = Mkdirs_result.new() |
---|
433 | begin |
---|
434 | result.success = @handler.mkdirs(args.path) |
---|
435 | rescue ThriftIOException => ouch |
---|
436 | result.ouch = ouch |
---|
437 | end |
---|
438 | write_result(result, oprot, 'mkdirs', seqid) |
---|
439 | end |
---|
440 | |
---|
441 | def process_exists(seqid, iprot, oprot) |
---|
442 | args = read_args(iprot, Exists_args) |
---|
443 | result = Exists_result.new() |
---|
444 | begin |
---|
445 | result.success = @handler.exists(args.path) |
---|
446 | rescue ThriftIOException => ouch |
---|
447 | result.ouch = ouch |
---|
448 | end |
---|
449 | write_result(result, oprot, 'exists', seqid) |
---|
450 | end |
---|
451 | |
---|
452 | def process_stat(seqid, iprot, oprot) |
---|
453 | args = read_args(iprot, Stat_args) |
---|
454 | result = Stat_result.new() |
---|
455 | begin |
---|
456 | result.success = @handler.stat(args.path) |
---|
457 | rescue ThriftIOException => ouch |
---|
458 | result.ouch = ouch |
---|
459 | end |
---|
460 | write_result(result, oprot, 'stat', seqid) |
---|
461 | end |
---|
462 | |
---|
463 | def process_listStatus(seqid, iprot, oprot) |
---|
464 | args = read_args(iprot, ListStatus_args) |
---|
465 | result = ListStatus_result.new() |
---|
466 | begin |
---|
467 | result.success = @handler.listStatus(args.path) |
---|
468 | rescue ThriftIOException => ouch |
---|
469 | result.ouch = ouch |
---|
470 | end |
---|
471 | write_result(result, oprot, 'listStatus', seqid) |
---|
472 | end |
---|
473 | |
---|
474 | def process_chmod(seqid, iprot, oprot) |
---|
475 | args = read_args(iprot, Chmod_args) |
---|
476 | result = Chmod_result.new() |
---|
477 | begin |
---|
478 | @handler.chmod(args.path, args.mode) |
---|
479 | rescue ThriftIOException => ouch |
---|
480 | result.ouch = ouch |
---|
481 | end |
---|
482 | write_result(result, oprot, 'chmod', seqid) |
---|
483 | end |
---|
484 | |
---|
485 | def process_chown(seqid, iprot, oprot) |
---|
486 | args = read_args(iprot, Chown_args) |
---|
487 | result = Chown_result.new() |
---|
488 | begin |
---|
489 | @handler.chown(args.path, args.owner, args.group) |
---|
490 | rescue ThriftIOException => ouch |
---|
491 | result.ouch = ouch |
---|
492 | end |
---|
493 | write_result(result, oprot, 'chown', seqid) |
---|
494 | end |
---|
495 | |
---|
496 | def process_setReplication(seqid, iprot, oprot) |
---|
497 | args = read_args(iprot, SetReplication_args) |
---|
498 | result = SetReplication_result.new() |
---|
499 | begin |
---|
500 | @handler.setReplication(args.path, args.replication) |
---|
501 | rescue ThriftIOException => ouch |
---|
502 | result.ouch = ouch |
---|
503 | end |
---|
504 | write_result(result, oprot, 'setReplication', seqid) |
---|
505 | end |
---|
506 | |
---|
507 | def process_getFileBlockLocations(seqid, iprot, oprot) |
---|
508 | args = read_args(iprot, GetFileBlockLocations_args) |
---|
509 | result = GetFileBlockLocations_result.new() |
---|
510 | begin |
---|
511 | result.success = @handler.getFileBlockLocations(args.path, args.start, args.length) |
---|
512 | rescue ThriftIOException => ouch |
---|
513 | result.ouch = ouch |
---|
514 | end |
---|
515 | write_result(result, oprot, 'getFileBlockLocations', seqid) |
---|
516 | end |
---|
517 | |
---|
518 | end |
---|
519 | |
---|
520 | # HELPER FUNCTIONS AND STRUCTURES |
---|
521 | |
---|
522 | class SetInactivityTimeoutPeriod_args |
---|
523 | include Thrift::Struct |
---|
524 | Thrift::Struct.field_accessor self, :periodInSeconds |
---|
525 | FIELDS = { |
---|
526 | 1 => {:type => Thrift::Types::I64, :name => 'periodInSeconds'} |
---|
527 | } |
---|
528 | end |
---|
529 | |
---|
530 | class SetInactivityTimeoutPeriod_result |
---|
531 | include Thrift::Struct |
---|
532 | FIELDS = { |
---|
533 | |
---|
534 | } |
---|
535 | end |
---|
536 | |
---|
537 | class Shutdown_args |
---|
538 | include Thrift::Struct |
---|
539 | Thrift::Struct.field_accessor self, :status |
---|
540 | FIELDS = { |
---|
541 | 1 => {:type => Thrift::Types::I32, :name => 'status'} |
---|
542 | } |
---|
543 | end |
---|
544 | |
---|
545 | class Shutdown_result |
---|
546 | include Thrift::Struct |
---|
547 | FIELDS = { |
---|
548 | |
---|
549 | } |
---|
550 | end |
---|
551 | |
---|
552 | class Create_args |
---|
553 | include Thrift::Struct |
---|
554 | Thrift::Struct.field_accessor self, :path |
---|
555 | FIELDS = { |
---|
556 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname} |
---|
557 | } |
---|
558 | end |
---|
559 | |
---|
560 | class Create_result |
---|
561 | include Thrift::Struct |
---|
562 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
563 | FIELDS = { |
---|
564 | 0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle}, |
---|
565 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
566 | } |
---|
567 | end |
---|
568 | |
---|
569 | class CreateFile_args |
---|
570 | include Thrift::Struct |
---|
571 | Thrift::Struct.field_accessor self, :path, :mode, :overwrite, :bufferSize, :block_replication, :blocksize |
---|
572 | FIELDS = { |
---|
573 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}, |
---|
574 | 2 => {:type => Thrift::Types::I16, :name => 'mode'}, |
---|
575 | 3 => {:type => Thrift::Types::BOOL, :name => 'overwrite'}, |
---|
576 | 4 => {:type => Thrift::Types::I32, :name => 'bufferSize'}, |
---|
577 | 5 => {:type => Thrift::Types::I16, :name => 'block_replication'}, |
---|
578 | 6 => {:type => Thrift::Types::I64, :name => 'blocksize'} |
---|
579 | } |
---|
580 | end |
---|
581 | |
---|
582 | class CreateFile_result |
---|
583 | include Thrift::Struct |
---|
584 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
585 | FIELDS = { |
---|
586 | 0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle}, |
---|
587 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
588 | } |
---|
589 | end |
---|
590 | |
---|
591 | class Open_args |
---|
592 | include Thrift::Struct |
---|
593 | Thrift::Struct.field_accessor self, :path |
---|
594 | FIELDS = { |
---|
595 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname} |
---|
596 | } |
---|
597 | end |
---|
598 | |
---|
599 | class Open_result |
---|
600 | include Thrift::Struct |
---|
601 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
602 | FIELDS = { |
---|
603 | 0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle}, |
---|
604 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
605 | } |
---|
606 | end |
---|
607 | |
---|
608 | class Append_args |
---|
609 | include Thrift::Struct |
---|
610 | Thrift::Struct.field_accessor self, :path |
---|
611 | FIELDS = { |
---|
612 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname} |
---|
613 | } |
---|
614 | end |
---|
615 | |
---|
616 | class Append_result |
---|
617 | include Thrift::Struct |
---|
618 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
619 | FIELDS = { |
---|
620 | 0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => ThriftHandle}, |
---|
621 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
622 | } |
---|
623 | end |
---|
624 | |
---|
625 | class Write_args |
---|
626 | include Thrift::Struct |
---|
627 | Thrift::Struct.field_accessor self, :handle, :data |
---|
628 | FIELDS = { |
---|
629 | 1 => {:type => Thrift::Types::STRUCT, :name => 'handle', :class => ThriftHandle}, |
---|
630 | -1 => {:type => Thrift::Types::STRING, :name => 'data'} |
---|
631 | } |
---|
632 | end |
---|
633 | |
---|
634 | class Write_result |
---|
635 | include Thrift::Struct |
---|
636 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
637 | FIELDS = { |
---|
638 | 0 => {:type => Thrift::Types::BOOL, :name => 'success'}, |
---|
639 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
640 | } |
---|
641 | end |
---|
642 | |
---|
643 | class Read_args |
---|
644 | include Thrift::Struct |
---|
645 | Thrift::Struct.field_accessor self, :handle, :offset, :size |
---|
646 | FIELDS = { |
---|
647 | 1 => {:type => Thrift::Types::STRUCT, :name => 'handle', :class => ThriftHandle}, |
---|
648 | -1 => {:type => Thrift::Types::I64, :name => 'offset'}, |
---|
649 | -2 => {:type => Thrift::Types::I32, :name => 'size'} |
---|
650 | } |
---|
651 | end |
---|
652 | |
---|
653 | class Read_result |
---|
654 | include Thrift::Struct |
---|
655 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
656 | FIELDS = { |
---|
657 | 0 => {:type => Thrift::Types::STRING, :name => 'success'}, |
---|
658 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
659 | } |
---|
660 | end |
---|
661 | |
---|
662 | class Close_args |
---|
663 | include Thrift::Struct |
---|
664 | Thrift::Struct.field_accessor self, :out |
---|
665 | FIELDS = { |
---|
666 | 1 => {:type => Thrift::Types::STRUCT, :name => 'out', :class => ThriftHandle} |
---|
667 | } |
---|
668 | end |
---|
669 | |
---|
670 | class Close_result |
---|
671 | include Thrift::Struct |
---|
672 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
673 | FIELDS = { |
---|
674 | 0 => {:type => Thrift::Types::BOOL, :name => 'success'}, |
---|
675 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
676 | } |
---|
677 | end |
---|
678 | |
---|
679 | class Rm_args |
---|
680 | include Thrift::Struct |
---|
681 | Thrift::Struct.field_accessor self, :path, :recursive |
---|
682 | FIELDS = { |
---|
683 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}, |
---|
684 | 2 => {:type => Thrift::Types::BOOL, :name => 'recursive'} |
---|
685 | } |
---|
686 | end |
---|
687 | |
---|
688 | class Rm_result |
---|
689 | include Thrift::Struct |
---|
690 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
691 | FIELDS = { |
---|
692 | 0 => {:type => Thrift::Types::BOOL, :name => 'success'}, |
---|
693 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
694 | } |
---|
695 | end |
---|
696 | |
---|
697 | class Rename_args |
---|
698 | include Thrift::Struct |
---|
699 | Thrift::Struct.field_accessor self, :path, :dest |
---|
700 | FIELDS = { |
---|
701 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}, |
---|
702 | 2 => {:type => Thrift::Types::STRUCT, :name => 'dest', :class => Pathname} |
---|
703 | } |
---|
704 | end |
---|
705 | |
---|
706 | class Rename_result |
---|
707 | include Thrift::Struct |
---|
708 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
709 | FIELDS = { |
---|
710 | 0 => {:type => Thrift::Types::BOOL, :name => 'success'}, |
---|
711 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
712 | } |
---|
713 | end |
---|
714 | |
---|
715 | class Mkdirs_args |
---|
716 | include Thrift::Struct |
---|
717 | Thrift::Struct.field_accessor self, :path |
---|
718 | FIELDS = { |
---|
719 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname} |
---|
720 | } |
---|
721 | end |
---|
722 | |
---|
723 | class Mkdirs_result |
---|
724 | include Thrift::Struct |
---|
725 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
726 | FIELDS = { |
---|
727 | 0 => {:type => Thrift::Types::BOOL, :name => 'success'}, |
---|
728 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
729 | } |
---|
730 | end |
---|
731 | |
---|
732 | class Exists_args |
---|
733 | include Thrift::Struct |
---|
734 | Thrift::Struct.field_accessor self, :path |
---|
735 | FIELDS = { |
---|
736 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname} |
---|
737 | } |
---|
738 | end |
---|
739 | |
---|
740 | class Exists_result |
---|
741 | include Thrift::Struct |
---|
742 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
743 | FIELDS = { |
---|
744 | 0 => {:type => Thrift::Types::BOOL, :name => 'success'}, |
---|
745 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
746 | } |
---|
747 | end |
---|
748 | |
---|
749 | class Stat_args |
---|
750 | include Thrift::Struct |
---|
751 | Thrift::Struct.field_accessor self, :path |
---|
752 | FIELDS = { |
---|
753 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname} |
---|
754 | } |
---|
755 | end |
---|
756 | |
---|
757 | class Stat_result |
---|
758 | include Thrift::Struct |
---|
759 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
760 | FIELDS = { |
---|
761 | 0 => {:type => Thrift::Types::STRUCT, :name => 'success', :class => FileStatus}, |
---|
762 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
763 | } |
---|
764 | end |
---|
765 | |
---|
766 | class ListStatus_args |
---|
767 | include Thrift::Struct |
---|
768 | Thrift::Struct.field_accessor self, :path |
---|
769 | FIELDS = { |
---|
770 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname} |
---|
771 | } |
---|
772 | end |
---|
773 | |
---|
774 | class ListStatus_result |
---|
775 | include Thrift::Struct |
---|
776 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
777 | FIELDS = { |
---|
778 | 0 => {:type => Thrift::Types::LIST, :name => 'success', :element => {:type => Thrift::Types::STRUCT, :class => FileStatus}}, |
---|
779 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
780 | } |
---|
781 | end |
---|
782 | |
---|
783 | class Chmod_args |
---|
784 | include Thrift::Struct |
---|
785 | Thrift::Struct.field_accessor self, :path, :mode |
---|
786 | FIELDS = { |
---|
787 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}, |
---|
788 | 2 => {:type => Thrift::Types::I16, :name => 'mode'} |
---|
789 | } |
---|
790 | end |
---|
791 | |
---|
792 | class Chmod_result |
---|
793 | include Thrift::Struct |
---|
794 | Thrift::Struct.field_accessor self, :ouch |
---|
795 | FIELDS = { |
---|
796 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
797 | } |
---|
798 | end |
---|
799 | |
---|
800 | class Chown_args |
---|
801 | include Thrift::Struct |
---|
802 | Thrift::Struct.field_accessor self, :path, :owner, :group |
---|
803 | FIELDS = { |
---|
804 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}, |
---|
805 | 2 => {:type => Thrift::Types::STRING, :name => 'owner'}, |
---|
806 | 3 => {:type => Thrift::Types::STRING, :name => 'group'} |
---|
807 | } |
---|
808 | end |
---|
809 | |
---|
810 | class Chown_result |
---|
811 | include Thrift::Struct |
---|
812 | Thrift::Struct.field_accessor self, :ouch |
---|
813 | FIELDS = { |
---|
814 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
815 | } |
---|
816 | end |
---|
817 | |
---|
818 | class SetReplication_args |
---|
819 | include Thrift::Struct |
---|
820 | Thrift::Struct.field_accessor self, :path, :replication |
---|
821 | FIELDS = { |
---|
822 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}, |
---|
823 | 2 => {:type => Thrift::Types::I16, :name => 'replication'} |
---|
824 | } |
---|
825 | end |
---|
826 | |
---|
827 | class SetReplication_result |
---|
828 | include Thrift::Struct |
---|
829 | Thrift::Struct.field_accessor self, :ouch |
---|
830 | FIELDS = { |
---|
831 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
832 | } |
---|
833 | end |
---|
834 | |
---|
835 | class GetFileBlockLocations_args |
---|
836 | include Thrift::Struct |
---|
837 | Thrift::Struct.field_accessor self, :path, :start, :length |
---|
838 | FIELDS = { |
---|
839 | 1 => {:type => Thrift::Types::STRUCT, :name => 'path', :class => Pathname}, |
---|
840 | 2 => {:type => Thrift::Types::I64, :name => 'start'}, |
---|
841 | 3 => {:type => Thrift::Types::I64, :name => 'length'} |
---|
842 | } |
---|
843 | end |
---|
844 | |
---|
845 | class GetFileBlockLocations_result |
---|
846 | include Thrift::Struct |
---|
847 | Thrift::Struct.field_accessor self, :success, :ouch |
---|
848 | FIELDS = { |
---|
849 | 0 => {:type => Thrift::Types::LIST, :name => 'success', :element => {:type => Thrift::Types::STRUCT, :class => BlockLocation}}, |
---|
850 | 1 => {:type => Thrift::Types::STRUCT, :name => 'ouch', :class => ThriftIOException} |
---|
851 | } |
---|
852 | end |
---|
853 | |
---|
854 | end |
---|
855 | |
---|