Class: Searchkick::LogSubscriber
- Inherits:
-
ActiveSupport::LogSubscriber
- Object
- ActiveSupport::LogSubscriber
- Searchkick::LogSubscriber
- Defined in:
- lib/searchkick/logging.rb
Overview
Class Method Summary collapse
Instance Method Summary collapse
Class Method Details
.reset_runtime ⇒ Object
64 65 66 67 |
# File 'lib/searchkick/logging.rb', line 64 def self.reset_runtime rt, self.runtime = runtime, 0 rt end |
.runtime ⇒ Object
60 61 62 |
# File 'lib/searchkick/logging.rb', line 60 def self.runtime Thread.current[:searchkick_runtime] ||= 0 end |
.runtime=(value) ⇒ Object
56 57 58 |
# File 'lib/searchkick/logging.rb', line 56 def self.runtime=(value) Thread.current[:searchkick_runtime] = value end |
Instance Method Details
#request(event) ⇒ Object
83 84 85 86 87 88 89 90 91 |
# File 'lib/searchkick/logging.rb', line 83 def request(event) self.class.runtime += event.duration return unless logger.debug? payload = event.payload name = "#{payload[:name]} (#{event.duration.round(1)}ms)" debug " #{color(name, YELLOW, true)} #{payload.except(:name).to_json}" end |
#search(event) ⇒ Object
69 70 71 72 73 74 75 76 77 78 79 80 81 |
# File 'lib/searchkick/logging.rb', line 69 def search(event) self.class.runtime += event.duration return unless logger.debug? payload = event.payload name = "#{payload[:name]} (#{event.duration.round(1)}ms)" type = payload[:query][:type] index = payload[:query][:index].is_a?(Array) ? payload[:query][:index].join(",") : payload[:query][:index] # no easy way to tell which host the client will use host = Searchkick.client.transport.hosts.first debug " #{color(name, YELLOW, true)} curl #{host[:protocol]}://#{host[:host]}:#{host[:port]}/#{CGI.escape(index)}#{type ? "/#{type.map { |t| CGI.escape(t) }.join(',')}" : ''}/_search?pretty -d '#{payload[:query][:body].to_json}'" end |