Class: Mongo::Monitoring::CommandLogSubscriber

Inherits:
Object
  • Object
show all
Includes:
SemanticLogger::Loggable
Defined in:
lib/rocket_job/extensions/mongo/logging.rb

Instance Method Summary collapse

Instance Method Details

#failed(event) ⇒ Object 



17
18
19
 
# File 'lib/rocket_job/extensions/mongo/logging.rb', line 17

def failed(event)
  logger.debug(message: "#{prefix(event)} Failed: #{event.message}", duration: (event.duration * 1000), payload: @event_command)
end

#prefix(event) ⇒ Object 



21
22
23
 
# File 'lib/rocket_job/extensions/mongo/logging.rb', line 21

def prefix(event)
  "#{event.address.to_s} | #{event.database_name}.#{event.command_name}"
end

#started(event) ⇒ Object 



9
10
11
 
# File 'lib/rocket_job/extensions/mongo/logging.rb', line 9

def started(event)
  @event_command = event.command
end

#succeeded(event) ⇒ Object 



13
14
15
 
# File 'lib/rocket_job/extensions/mongo/logging.rb', line 13

def succeeded(event)
  logger.debug(message: prefix(event), duration: (event.duration * 1000), payload: @event_command)
end