Sha256: 0b7aefd0f406953651f32db47d6b0666632bb0b5d9565055d540ab4ce0c92b36

Contents?: true

Size: 555 Bytes

Versions: 1

Compression:

Stored size: 555 Bytes

Contents

require "active_record/log_subscriber"

module ActiveRecord::Turntable
  module ActiveRecordExt
    module LogSubscriber
      # @note prepend to add shard name logging
      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
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
activerecord-turntable-3.0.0 lib/active_record/turntable/active_record_ext/log_subscriber.rb