Class: Blur::Blur::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/active_blur/thrift/blur.rb

Instance Method Summary collapse

Instance Method Details

#process_cancelQuery(seqid, iprot, oprot) ⇒ Object 



410
411
412
413
414
415
416
417
418
419
 
# File 'lib/active_blur/thrift/blur.rb', line 410

def process_cancelQuery(seqid, iprot, oprot)
  args = read_args(iprot, CancelQuery_args)
  result = CancelQuery_result.new()
  begin
    @handler.cancelQuery(args.table, args.uuid)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'cancelQuery', seqid)
end

#process_controllerServerList(seqid, iprot, oprot) ⇒ Object 



355
356
357
358
359
360
361
362
363
364
 
# File 'lib/active_blur/thrift/blur.rb', line 355

def process_controllerServerList(seqid, iprot, oprot)
  args = read_args(iprot, ControllerServerList_args)
  result = ControllerServerList_result.new()
  begin
    result.success = @handler.controllerServerList()
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'controllerServerList', seqid)
end

#process_createTable(seqid, iprot, oprot) ⇒ Object 



509
510
511
512
513
514
515
516
517
518
 
# File 'lib/active_blur/thrift/blur.rb', line 509

def process_createTable(seqid, iprot, oprot)
  args = read_args(iprot, CreateTable_args)
  result = CreateTable_result.new()
  begin
    @handler.createTable(args.tableDescriptor)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'createTable', seqid)
end

#process_currentQueries(seqid, iprot, oprot) ⇒ Object 



421
422
423
424
425
426
427
428
429
430
 
# File 'lib/active_blur/thrift/blur.rb', line 421

def process_currentQueries(seqid, iprot, oprot)
  args = read_args(iprot, CurrentQueries_args)
  result = CurrentQueries_result.new()
  begin
    result.success = @handler.currentQueries(args.table)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'currentQueries', seqid)
end

#process_describe(seqid, iprot, oprot) ⇒ Object 



388
389
390
391
392
393
394
395
396
397
 
# File 'lib/active_blur/thrift/blur.rb', line 388

def process_describe(seqid, iprot, oprot)
  args = read_args(iprot, Describe_args)
  result = Describe_result.new()
  begin
    result.success = @handler.describe(args.table)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'describe', seqid)
end

#process_disableTable(seqid, iprot, oprot) ⇒ Object 



531
532
533
534
535
536
537
538
539
540
 
# File 'lib/active_blur/thrift/blur.rb', line 531

def process_disableTable(seqid, iprot, oprot)
  args = read_args(iprot, DisableTable_args)
  result = DisableTable_result.new()
  begin
    @handler.disableTable(args.table)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'disableTable', seqid)
end

#process_enableTable(seqid, iprot, oprot) ⇒ Object 



520
521
522
523
524
525
526
527
528
529
 
# File 'lib/active_blur/thrift/blur.rb', line 520

def process_enableTable(seqid, iprot, oprot)
  args = read_args(iprot, EnableTable_args)
  result = EnableTable_result.new()
  begin
    @handler.enableTable(args.table)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'enableTable', seqid)
end

#process_fetchRow(seqid, iprot, oprot) ⇒ Object 



476
477
478
479
480
481
482
483
484
485
 
# File 'lib/active_blur/thrift/blur.rb', line 476

def process_fetchRow(seqid, iprot, oprot)
  args = read_args(iprot, FetchRow_args)
  result = FetchRow_result.new()
  begin
    result.success = @handler.fetchRow(args.table, args.selector)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'fetchRow', seqid)
end

#process_getTableStats(seqid, iprot, oprot) ⇒ Object 



443
444
445
446
447
448
449
450
451
452
 
# File 'lib/active_blur/thrift/blur.rb', line 443

def process_getTableStats(seqid, iprot, oprot)
  args = read_args(iprot, GetTableStats_args)
  result = GetTableStats_result.new()
  begin
    result.success = @handler.getTableStats(args.table)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'getTableStats', seqid)
end

#process_mutate(seqid, iprot, oprot) ⇒ Object 



487
488
489
490
491
492
493
494
495
496
 
# File 'lib/active_blur/thrift/blur.rb', line 487

def process_mutate(seqid, iprot, oprot)
  args = read_args(iprot, Mutate_args)
  result = Mutate_result.new()
  begin
    @handler.mutate(args.mutation)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'mutate', seqid)
end

#process_mutateBatch(seqid, iprot, oprot) ⇒ Object 



498
499
500
501
502
503
504
505
506
507
 
# File 'lib/active_blur/thrift/blur.rb', line 498

def process_mutateBatch(seqid, iprot, oprot)
  args = read_args(iprot, MutateBatch_args)
  result = MutateBatch_result.new()
  begin
    @handler.mutateBatch(args.mutations)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'mutateBatch', seqid)
end

#process_query(seqid, iprot, oprot) ⇒ Object 



399
400
401
402
403
404
405
406
407
408
 
# File 'lib/active_blur/thrift/blur.rb', line 399

def process_query(seqid, iprot, oprot)
  args = read_args(iprot, Query_args)
  result = Query_result.new()
  begin
    result.success = @handler.query(args.table, args.blurQuery)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'query', seqid)
end

#process_recordFrequency(seqid, iprot, oprot) ⇒ Object 



465
466
467
468
469
470
471
472
473
474
 
# File 'lib/active_blur/thrift/blur.rb', line 465

def process_recordFrequency(seqid, iprot, oprot)
  args = read_args(iprot, RecordFrequency_args)
  result = RecordFrequency_result.new()
  begin
    result.success = @handler.recordFrequency(args.table, args.columnFamily, args.columnName, args.value)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'recordFrequency', seqid)
end

#process_removeTable(seqid, iprot, oprot) ⇒ Object 



542
543
544
545
546
547
548
549
550
551
 
# File 'lib/active_blur/thrift/blur.rb', line 542

def process_removeTable(seqid, iprot, oprot)
  args = read_args(iprot, RemoveTable_args)
  result = RemoveTable_result.new()
  begin
    @handler.removeTable(args.table, args.deleteIndexFiles)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'removeTable', seqid)
end

#process_schema(seqid, iprot, oprot) ⇒ Object 



432
433
434
435
436
437
438
439
440
441
 
# File 'lib/active_blur/thrift/blur.rb', line 432

def process_schema(seqid, iprot, oprot)
  args = read_args(iprot, Schema_args)
  result = Schema_result.new()
  begin
    result.success = @handler.schema(args.table)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'schema', seqid)
end

#process_shardClusterList(seqid, iprot, oprot) ⇒ Object 



333
334
335
336
337
338
339
340
341
342
 
# File 'lib/active_blur/thrift/blur.rb', line 333

def process_shardClusterList(seqid, iprot, oprot)
  args = read_args(iprot, ShardClusterList_args)
  result = ShardClusterList_result.new()
  begin
    result.success = @handler.shardClusterList()
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'shardClusterList', seqid)
end

#process_shardServerLayout(seqid, iprot, oprot) ⇒ Object 



366
367
368
369
370
371
372
373
374
375
 
# File 'lib/active_blur/thrift/blur.rb', line 366

def process_shardServerLayout(seqid, iprot, oprot)
  args = read_args(iprot, ShardServerLayout_args)
  result = ShardServerLayout_result.new()
  begin
    result.success = @handler.shardServerLayout(args.table)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'shardServerLayout', seqid)
end

#process_shardServerList(seqid, iprot, oprot) ⇒ Object 



344
345
346
347
348
349
350
351
352
353
 
# File 'lib/active_blur/thrift/blur.rb', line 344

def process_shardServerList(seqid, iprot, oprot)
  args = read_args(iprot, ShardServerList_args)
  result = ShardServerList_result.new()
  begin
    result.success = @handler.shardServerList(args.cluster)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'shardServerList', seqid)
end

#process_tableList(seqid, iprot, oprot) ⇒ Object 



377
378
379
380
381
382
383
384
385
386
 
# File 'lib/active_blur/thrift/blur.rb', line 377

def process_tableList(seqid, iprot, oprot)
  args = read_args(iprot, TableList_args)
  result = TableList_result.new()
  begin
    result.success = @handler.tableList()
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'tableList', seqid)
end

#process_terms(seqid, iprot, oprot) ⇒ Object 



454
455
456
457
458
459
460
461
462
463
 
# File 'lib/active_blur/thrift/blur.rb', line 454

def process_terms(seqid, iprot, oprot)
  args = read_args(iprot, Terms_args)
  result = Terms_result.new()
  begin
    result.success = @handler.terms(args.table, args.columnFamily, args.columnName, args.startWith, args.size)
  rescue ::Blur::BlurException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'terms', seqid)
end