Class: Stat::Count::Thrift::RemoteSimpleCountCollecter::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/stat-count-client/thrift/remote_simple_count_collecter.rb

Instance Method Summary collapse

Instance Method Details

#process_decr(seqid, iprot, oprot) ⇒ Object 



535
536
537
538
539
540
541
542
543
544
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 535

def process_decr(seqid, iprot, oprot)
  args = read_args(iprot, Decr_args)
  result = Decr_result.new()
  begin
    result.success = @handler.decr(args.name, args.id)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'decr', seqid)
end

#process_decrBy(seqid, iprot, oprot) ⇒ Object 



513
514
515
516
517
518
519
520
521
522
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 513

def process_decrBy(seqid, iprot, oprot)
  args = read_args(iprot, DecrBy_args)
  result = DecrBy_result.new()
  begin
    result.success = @handler.decrBy(args.name, args.id, args.count)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'decrBy', seqid)
end

#process_decrByCount(seqid, iprot, oprot) ⇒ Object 



557
558
559
560
561
562
563
564
565
566
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 557

def process_decrByCount(seqid, iprot, oprot)
  args = read_args(iprot, DecrByCount_args)
  result = DecrByCount_result.new()
  begin
    result.success = @handler.decrByCount(args.count)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'decrByCount', seqid)
end

#process_decrByCountWithDate(seqid, iprot, oprot) ⇒ Object 



546
547
548
549
550
551
552
553
554
555
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 546

def process_decrByCountWithDate(seqid, iprot, oprot)
  args = read_args(iprot, DecrByCountWithDate_args)
  result = DecrByCountWithDate_result.new()
  begin
    @handler.decrByCountWithDate(args.dateCount)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'decrByCountWithDate', seqid)
end

#process_decrByWithDate(seqid, iprot, oprot) ⇒ Object 



524
525
526
527
528
529
530
531
532
533
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 524

def process_decrByWithDate(seqid, iprot, oprot)
  args = read_args(iprot, DecrByWithDate_args)
  result = DecrByWithDate_result.new()
  begin
    result.success = @handler.decrByWithDate(args.name, args.id, args.count, args.date)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'decrByWithDate', seqid)
end

#process_delByDateQuery(seqid, iprot, oprot) ⇒ Object 



733
734
735
736
737
738
739
740
741
742
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 733

def process_delByDateQuery(seqid, iprot, oprot)
  args = read_args(iprot, DelByDateQuery_args)
  result = DelByDateQuery_result.new()
  begin
    @handler.delByDateQuery(args.query)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'delByDateQuery', seqid)
end

#process_delByKey(seqid, iprot, oprot) ⇒ Object 



755
756
757
758
759
760
761
762
763
764
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 755

def process_delByKey(seqid, iprot, oprot)
  args = read_args(iprot, DelByKey_args)
  result = DelByKey_result.new()
  begin
    @handler.delByKey(args.name, args.id)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'delByKey', seqid)
end

#process_delByQuery(seqid, iprot, oprot) ⇒ Object 



722
723
724
725
726
727
728
729
730
731
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 722

def process_delByQuery(seqid, iprot, oprot)
  args = read_args(iprot, DelByQuery_args)
  result = DelByQuery_result.new()
  begin
    @handler.delByQuery(args.query)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'delByQuery', seqid)
end

#process_get(seqid, iprot, oprot) ⇒ Object 



634
635
636
637
638
639
640
641
642
643
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 634

def process_get(seqid, iprot, oprot)
  args = read_args(iprot, Get_args)
  result = Get_result.new()
  begin
    result.success = @handler.get(args.name, args.id)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'get', seqid)
end

#process_getByDateQuery(seqid, iprot, oprot) ⇒ Object 



711
712
713
714
715
716
717
718
719
720
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 711

def process_getByDateQuery(seqid, iprot, oprot)
  args = read_args(iprot, GetByDateQuery_args)
  result = GetByDateQuery_result.new()
  begin
    result.success = @handler.getByDateQuery(args.query)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'getByDateQuery', seqid)
end

#process_getByIds(seqid, iprot, oprot) ⇒ Object 



678
679
680
681
682
683
684
685
686
687
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 678

def process_getByIds(seqid, iprot, oprot)
  args = read_args(iprot, GetByIds_args)
  result = GetByIds_result.new()
  begin
    result.success = @handler.getByIds(args.name, args.ids)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'getByIds', seqid)
end

#process_getByIdsAndLimit(seqid, iprot, oprot) ⇒ Object 



689
690
691
692
693
694
695
696
697
698
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 689

def process_getByIdsAndLimit(seqid, iprot, oprot)
  args = read_args(iprot, GetByIdsAndLimit_args)
  result = GetByIdsAndLimit_result.new()
  begin
    result.success = @handler.getByIdsAndLimit(args.name, args.ids, args.limit)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'getByIdsAndLimit', seqid)
end

#process_getByLimit(seqid, iprot, oprot) ⇒ Object 



645
646
647
648
649
650
651
652
653
654
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 645

def process_getByLimit(seqid, iprot, oprot)
  args = read_args(iprot, GetByLimit_args)
  result = GetByLimit_result.new()
  begin
    result.success = @handler.getByLimit(args.name, args.id, args.limit)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'getByLimit', seqid)
end

#process_getByNames(seqid, iprot, oprot) ⇒ Object 



667
668
669
670
671
672
673
674
675
676
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 667

def process_getByNames(seqid, iprot, oprot)
  args = read_args(iprot, GetByNames_args)
  result = GetByNames_result.new()
  begin
    result.success = @handler.getByNames(args.names, args.id)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'getByNames', seqid)
end

#process_getByNamesAndLimit(seqid, iprot, oprot) ⇒ Object 



656
657
658
659
660
661
662
663
664
665
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 656

def process_getByNamesAndLimit(seqid, iprot, oprot)
  args = read_args(iprot, GetByNamesAndLimit_args)
  result = GetByNamesAndLimit_result.new()
  begin
    result.success = @handler.getByNamesAndLimit(args.names, args.id, args.limit)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'getByNamesAndLimit', seqid)
end

#process_getByQuery(seqid, iprot, oprot) ⇒ Object 



700
701
702
703
704
705
706
707
708
709
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 700

def process_getByQuery(seqid, iprot, oprot)
  args = read_args(iprot, GetByQuery_args)
  result = GetByQuery_result.new()
  begin
    result.success = @handler.getByQuery(args.query)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'getByQuery', seqid)
end

#process_incr(seqid, iprot, oprot) ⇒ Object 



491
492
493
494
495
496
497
498
499
500
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 491

def process_incr(seqid, iprot, oprot)
  args = read_args(iprot, Incr_args)
  result = Incr_result.new()
  begin
    result.success = @handler.incr(args.name, args.id)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'incr', seqid)
end

#process_incrBy(seqid, iprot, oprot) ⇒ Object 



458
459
460
461
462
463
464
465
466
467
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 458

def process_incrBy(seqid, iprot, oprot)
  args = read_args(iprot, IncrBy_args)
  result = IncrBy_result.new()
  begin
    result.success = @handler.incrBy(args.name, args.id, args.count)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'incrBy', seqid)
end

#process_incrByCount(seqid, iprot, oprot) ⇒ Object 



480
481
482
483
484
485
486
487
488
489
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 480

def process_incrByCount(seqid, iprot, oprot)
  args = read_args(iprot, IncrByCount_args)
  result = IncrByCount_result.new()
  begin
    result.success = @handler.incrByCount(args.count)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'incrByCount', seqid)
end

#process_incrByCountWithDate(seqid, iprot, oprot) ⇒ Object 



469
470
471
472
473
474
475
476
477
478
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 469

def process_incrByCountWithDate(seqid, iprot, oprot)
  args = read_args(iprot, IncrByCountWithDate_args)
  result = IncrByCountWithDate_result.new()
  begin
    @handler.incrByCountWithDate(args.dateCount)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'incrByCountWithDate', seqid)
end

#process_incrByWithDate(seqid, iprot, oprot) ⇒ Object 



502
503
504
505
506
507
508
509
510
511
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 502

def process_incrByWithDate(seqid, iprot, oprot)
  args = read_args(iprot, IncrByWithDate_args)
  result = IncrByWithDate_result.new()
  begin
    result.success = @handler.incrByWithDate(args.name, args.id, args.count, args.timeMills)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'incrByWithDate', seqid)
end

#process_reset(seqid, iprot, oprot) ⇒ Object 



612
613
614
615
616
617
618
619
620
621
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 612

def process_reset(seqid, iprot, oprot)
  args = read_args(iprot, Reset_args)
  result = Reset_result.new()
  begin
    @handler.reset(args.name, args.id)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'reset', seqid)
end

#process_resetByLimit(seqid, iprot, oprot) ⇒ Object 



623
624
625
626
627
628
629
630
631
632
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 623

def process_resetByLimit(seqid, iprot, oprot)
  args = read_args(iprot, ResetByLimit_args)
  result = ResetByLimit_result.new()
  begin
    @handler.resetByLimit(args.name, args.id, args.limit)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'resetByLimit', seqid)
end

#process_setByCount(seqid, iprot, oprot) ⇒ Object 



579
580
581
582
583
584
585
586
587
588
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 579

def process_setByCount(seqid, iprot, oprot)
  args = read_args(iprot, SetByCount_args)
  result = SetByCount_result.new()
  begin
    @handler.setByCount(args.count)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'setByCount', seqid)
end

#process_setByCountWithDate(seqid, iprot, oprot) ⇒ Object 



568
569
570
571
572
573
574
575
576
577
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 568

def process_setByCountWithDate(seqid, iprot, oprot)
  args = read_args(iprot, SetByCountWithDate_args)
  result = SetByCountWithDate_result.new()
  begin
    @handler.setByCountWithDate(args.count)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'setByCountWithDate', seqid)
end

#process_setRecord(seqid, iprot, oprot) ⇒ Object 



744
745
746
747
748
749
750
751
752
753
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 744

def process_setRecord(seqid, iprot, oprot)
  args = read_args(iprot, SetRecord_args)
  result = SetRecord_result.new()
  begin
    @handler.setRecord(args.name, args.id, args.record)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'setRecord', seqid)
end

#process_setValue(seqid, iprot, oprot) ⇒ Object 



590
591
592
593
594
595
596
597
598
599
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 590

def process_setValue(seqid, iprot, oprot)
  args = read_args(iprot, SetValue_args)
  result = SetValue_result.new()
  begin
    @handler.setValue(args.name, args.id, args.value)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'setValue', seqid)
end

#process_setWithDate(seqid, iprot, oprot) ⇒ Object 



601
602
603
604
605
606
607
608
609
610
 
# File 'lib/stat-count-client/thrift/remote_simple_count_collecter.rb', line 601

def process_setWithDate(seqid, iprot, oprot)
  args = read_args(iprot, SetWithDate_args)
  result = SetWithDate_result.new()
  begin
    @handler.setWithDate(args.name, args.id, args.value, args.timeMills)
  rescue ::Stat::Count::Thrift::DataCollectionException => dcex
    result.dcex = dcex
  end
  write_result(result, oprot, 'setWithDate', seqid)
end