class Concord::Thrift::BoltMetricsService::Processor
Public Instance Methods
process_gauge(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/bolt_metrics_service.rb, line 81 def process_gauge(seqid, iprot, oprot) args = read_args(iprot, Gauge_args) result = Gauge_result.new() begin @handler.gauge(args.name, args.val) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'gauge', seqid) end
process_histogram(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/bolt_metrics_service.rb, line 103 def process_histogram(seqid, iprot, oprot) args = read_args(iprot, Histogram_args) result = Histogram_result.new() begin @handler.histogram(args.name, args.measure) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'histogram', seqid) end
process_sum(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/bolt_metrics_service.rb, line 114 def process_sum(seqid, iprot, oprot) args = read_args(iprot, Sum_args) result = Sum_result.new() begin @handler.sum(args.name, args.counter) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'sum', seqid) end
process_timer(seqid, iprot, oprot)
click to toggle source
# File lib/gen-rb/bolt_metrics_service.rb, line 92 def process_timer(seqid, iprot, oprot) args = read_args(iprot, Timer_args) result = Timer_result.new() begin @handler.timer(args.name, args.duration) rescue ::Concord::Thrift::BoltError => e result.e = e end write_result(result, oprot, 'timer', seqid) end