Contents

require "active_support/log_subscriber"

class Kredis::LogSubscriber < ActiveSupport::LogSubscriber
  def proxy(event)
    debug formatted_in(YELLOW, event, type: "Proxy")
  end

  def migration(event)
    debug formatted_in(YELLOW, event, type: "Migration")
  end

  def meta(event)
    info formatted_in(MAGENTA, event)
  end

  private
    def formatted_in(color, event, type: nil)
      color "  Kredis #{type} (#{event.duration.round(1)}ms)  #{event.payload[:message]}", color, bold: true
    end
end

Kredis::LogSubscriber.attach_to :kredis

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
kredis-1.5.0	lib/kredis/log_subscriber.rb
kredis-1.4.0	lib/kredis/log_subscriber.rb