Class: Caoutsearch::Instrumentation::Search
- Inherits:
-
Base
- Object
- ActiveSupport::LogSubscriber
- Base
- Caoutsearch::Instrumentation::Search
- Defined in:
- lib/caoutsearch/instrumentation/search.rb
Instance Method Summary collapse
- #delete(event) ⇒ Object
- #scroll(event) ⇒ Object
- #scroll_search(event) ⇒ Object
- #search(event) ⇒ Object
- #search_after(event) ⇒ Object
Instance Method Details
#delete(event) ⇒ Object
38 39 40 41 |
# File 'lib/caoutsearch/instrumentation/search.rb', line 38 def delete(event) log_request("Delete", event, format: log_request_format) log_response("Delete", event) end |
#scroll(event) ⇒ Object
29 30 31 32 33 34 35 36 |
# File 'lib/caoutsearch/instrumentation/search.rb', line 29 def scroll(event) log_request("Scroll", event, format: "truncated") log_response("Scroll", event) do || payload = event.payload += ", progress: #{payload[:progress]} / #{payload[:total]}" end end |
#scroll_search(event) ⇒ Object
20 21 22 23 24 25 26 27 |
# File 'lib/caoutsearch/instrumentation/search.rb', line 20 def scroll_search(event) log_request("Search", event, format: log_request_format) log_response("Search", event) do || payload = event.payload += ", progress: #{payload[:progress]} / #{payload[:total]}" end end |
#search(event) ⇒ Object
6 7 8 9 |
# File 'lib/caoutsearch/instrumentation/search.rb', line 6 def search(event) log_request("Search", event, format: log_request_format) log_response("Search", event) end |
#search_after(event) ⇒ Object
11 12 13 14 15 16 17 18 |
# File 'lib/caoutsearch/instrumentation/search.rb', line 11 def search_after(event) log_request("SearchAfter", event, format: "truncated") log_response("SearchAfter", event) do || payload = event.payload += ", progress: #{payload[:progress]} / #{payload[:total]}" end end |