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