module ActiveReplica::LogSubscriber

Public Class Methods

included(base) click to toggle source
# File lib/active_replica/logging.rb, line 36
def self.included(base)
  base.send(:attr_accessor, :active_replica)
  base.alias_method_chain :sql, :active_replica
  base.alias_method_chain :debug, :active_replica
end

Public Instance Methods

debug_with_active_replica(msg) click to toggle source
# File lib/active_replica/logging.rb, line 47
def debug_with_active_replica(msg)
  conn = active_replica ? color("[Replica: #{active_replica}]", ActiveSupport::LogSubscriber::GREEN, true) : ''
  debug_without_active_replica(conn + msg)
end
sql_with_active_replica(event) click to toggle source
# File lib/active_replica/logging.rb, line 42
def sql_with_active_replica(event)
  self.active_replica = event.payload[:active_replica]
  sql_without_active_replica(event)
end