Class: Noiseless::LogSubscriber

Inherits:
ActiveSupport::LogSubscriber
  • Object
show all
Defined in:
lib/noiseless/instrumentation.rb

Overview

Log subscriber for Rails integration

Instance Method Summary collapse

Instance Method Details

#bulk(event) ⇒ Object 



52
53
54
55
56
57
58
59
 
# File 'lib/noiseless/instrumentation.rb', line 52

def bulk(event)
  return unless logger.debug?

  actions_count = event.payload[:actions_count] || 0
  duration = event.duration.round(2)

  debug "Noiseless Bulk (#{duration}ms) actions=#{actions_count}"
end

#create_index(event) ⇒ Object 



92
93
94
95
96
97
98
99
 
# File 'lib/noiseless/instrumentation.rb', line 92

def create_index(event)
  return unless logger.debug?

  index = event.payload[:index]
  duration = event.duration.round(2)

  debug "Noiseless Create Index (#{duration}ms) index=#{index}"
end

#delete_document(event) ⇒ Object 



82
83
84
85
86
87
88
89
90
 
# File 'lib/noiseless/instrumentation.rb', line 82

def delete_document(event)
  return unless logger.debug?

  index = event.payload[:index]
  id = event.payload[:id]
  duration = event.duration.round(2)

  debug "Noiseless Delete Document (#{duration}ms) index=#{index} id=#{id}"
end

#delete_index(event) ⇒ Object 



101
102
103
104
105
106
107
108
 
# File 'lib/noiseless/instrumentation.rb', line 101

def delete_index(event)
  return unless logger.debug?

  index = event.payload[:index]
  duration = event.duration.round(2)

  debug "Noiseless Delete Index (#{duration}ms) index=#{index}"
end

#index_document(event) ⇒ Object 



61
62
63
64
65
66
67
68
69
 
# File 'lib/noiseless/instrumentation.rb', line 61

def index_document(event)
  return unless logger.debug?

  index = event.payload[:index]
  id = event.payload[:id]
  duration = event.duration.round(2)

  debug "Noiseless Index Document (#{duration}ms) index=#{index} id=#{id}"
end

#search(event) ⇒ Object 



43
44
45
46
47
48
49
50
 
# File 'lib/noiseless/instrumentation.rb', line 43

def search(event)
  return unless logger.debug?

  indexes = event.payload[:indexes]&.join(", ") || "unknown"
  duration = event.duration.round(2)

  debug "Noiseless Search (#{duration}ms) indexes=[#{indexes}] #{query_summary(event.payload[:query])}"
end

#update_document(event) ⇒ Object 



71
72
73
74
75
76
77
78
79
80
 
# File 'lib/noiseless/instrumentation.rb', line 71

def update_document(event)
  return unless logger.debug?

  index = event.payload[:index]
  id = event.payload[:id]
  changes_count = event.payload[:changes_count] || 0
  duration = event.duration.round(2)

  debug "Noiseless Update Document (#{duration}ms) index=#{index} id=#{id} changes=#{changes_count}"
end