Contents

module Profit
  class Client

    attr_accessor :ctx, :socket, :pending

    def initialize(ctx = nil)
      @ctx = ctx || ZMQ::Context.new
      @socket = @ctx.connect(:PUSH, "tcp://127.0.0.1:5556")
      @pending = {}
    end

    def start(metric_type)
      now = Time.now
      start_file = caller[0][/(.+):(.+):/,1]
      start_line = caller[0][/(.+):(.+):/,2].to_i + 1

      # TODO: wrap in a Mutex & make the key a combo of metric_type,
      #       pid, and/or thread object_id to make this thread safe and
      #       thread-robust.
      @pending[metric_type] = { start_file: start_file,
                                start_line: start_line,
                                start_time: now }
    end

    def stop(metric_type)
      now = Time.now
      metric = @pending.delete(metric_type)
      recorded_time = Time.now - metric[:start_time]
      stop_file = caller[0][/(.+):(.+):/,1]
      stop_line = caller[0][/(.+):(.+):/,2].to_i - 1

      @socket.send({ metric_type: metric_type,
                     recorded_time: recorded_time,
                     start_file: metric[:start_file],
                     start_line: metric[:start_line],
                     stop_file: stop_file,
                     stop_line: stop_line }.to_json)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
profit-0.1.3	lib/profit/client.rb
profit-0.1.2	lib/profit/client.rb
profit-0.1.1	lib/profit/client.rb
profit-0.1.0	lib/profit/client.rb