Class: Caoutsearch::Instrumentation::Index

Inherits:
Base
  • Object
show all
Defined in:
lib/caoutsearch/instrumentation/index.rb

Instance Method Summary collapse

Instance Method Details

#bulk(event) ⇒ Object 



26
27
28
29
30
31
 
# File 'lib/caoutsearch/instrumentation/index.rb', line 26

def bulk(event)
  method = event[:method].to_s.titleize

  log_request("Bulk #{method}", event, format: log_request_format)
  log_response("Bulk #{method}", event, warn_errors: true)
end

#delete(event) ⇒ Object 



21
22
23
24
 
# File 'lib/caoutsearch/instrumentation/index.rb', line 21

def delete(event)
  log_request("Delete", event, format: log_request_format)
  log_response("Delete", event)
end

#get(event) ⇒ Object 



6
7
8
9
 
# File 'lib/caoutsearch/instrumentation/index.rb', line 6

def get(event)
  log_request("Get", event, format: log_request_format)
  log_response("Get", event)
end

#index(event) ⇒ Object 



11
12
13
14
 
# File 'lib/caoutsearch/instrumentation/index.rb', line 11

def index(event)
  log_request("Index", event, format: log_request_format)
  log_response("Index", event)
end

#reindex(event) ⇒ Object 



33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/caoutsearch/instrumentation/index.rb', line 33

def reindex(event)
  log_request("Reindex", event, format: log_request_format)
  log_response("Reindex", event, warn_errors: true) do |message|
    payload = event.payload
    request = payload[:request]
    request_size = inspect_json_size(request)

    response = payload[:response]
    response_size = inspect_json_size(response)

    message += ", request size: #{request_size}"
    message += ", response size: #{response_size}"
    message += ", progress: #{payload[:progress]} / #{payload[:total]}"
    message
  end
end

#update(event) ⇒ Object 



16
17
18
19
 
# File 'lib/caoutsearch/instrumentation/index.rb', line 16

def update(event)
  log_request("Update", event, format: log_request_format)
  log_response("Update", event)
end