Contents

module XRayMachine
  class LogSubscriber < ActiveSupport::LogSubscriber
    def self.runtimes
      Thread.current["x_ray_machine_runtimes"] ||= Hash.new{|k,_| 0}
    end

    def self.reset_runtimes
      Thread.current["x_ray_machine_runtimes"] = nil
    end

    def request(event)
      group  = event.payload[:group]
      config = XRayMachine::Config.for(group)

      self.class.runtimes[group] += event.duration

      name  = config.title
      name += " CACHE" if event.payload[:cache]
      name  = '%s (%.1fms)' % [name, event.duration]
      debug "  #{color(name, config.color, true)}  #{event.payload[:query]}"
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
x-ray-machine-1.0.4	lib/x_ray_machine/log_subscriber.rb
x-ray-machine-1.0.3	lib/x_ray_machine/log_subscriber.rb
x-ray-machine-1.0.2	lib/x_ray_machine/log_subscriber.rb
x-ray-machine-1.0.1	lib/x_ray_machine/log_subscriber.rb
x-ray-machine-1.0.0	lib/x_ray_machine/log_subscriber.rb