Contents

module CassandraObject
  class LogSubscriber < ActiveSupport::LogSubscriber
    def multi_get(event)
      name = 'CassandraObject multi_get (%.1fms)' % event.duration

      debug "  #{name}  (#{event.payload[:keys].size}) #{event.payload[:keys].join(" ")}"
    end

    def remove(event)
      name = 'CassandraObject remove (%.1fms)' % event.duration

      debug "  #{name}  #{event.payload[:key]}"
    end

    def insert(event)
      name = 'CassandraObject insert (%.1fms)' % event.duration

      debug "  #{name}  #{event.payload[:key]} #{event.payload[:attributes].inspect}"
    end

    def get_range(event)
      name = 'CassandraObject get_range (%.1fms)' % event.duration
      
      debug "  #{name}  (#{event.payload[:count]}) #{event.payload[:start]} => #{event.payload[:finish]}"
    end
  end
end
CassandraObject::LogSubscriber.attach_to :cassandra_object

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
gotime-cassandra_object-0.7.2	lib/cassandra_object/log_subscriber.rb
gotime-cassandra_object-0.7.1	lib/cassandra_object/log_subscriber.rb