Module: SolidFlow::Instrumentation

Defined in:
lib/solid_flow/instrumentation.rb

Class Method Summary collapse

Class Method Details

.subscribe(logger: SolidFlow.logger) ⇒ Object 



7
8
9
10
11
12
13
14
 
# File 'lib/solid_flow/instrumentation.rb', line 7

def subscribe(logger: SolidFlow.logger)
  ActiveSupport::Notifications.subscribe(/solidflow\./) do |event_name, start, finish, _id, payload|
    next unless logger

    duration = (finish - start) * 1000.0
    logger.info("[#{event_name}] (#{format('%.1fms', duration)}) #{payload.compact}")
  end
end