Module: ActiveRecord::Turntable::ActiveRecordExt::LogSubscriber

Defined in:
lib/active_record/turntable/active_record_ext/log_subscriber.rb

Instance Method Summary collapse

Instance Method Details

#sql(event) ⇒ Object

Note:

prepend to add shard name logging



7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/active_record/turntable/active_record_ext/log_subscriber.rb', line 7

def sql(event)
  payload = event.payload

  if self.class::IGNORE_PAYLOAD_NAMES.include?(payload[:name])
    self.class.runtime += event.duration
    return
  end

  if payload[:turntable_shard_name]
    payload[:name] = "#{payload[:name]} [Shard: #{payload[:turntable_shard_name]}]"
  end
  super
end