Sha256: 887d187d539e7be2a7bc04eefbbf78d0928c8a28ffd82066e4c9794b6c9996fb
Contents?: true
Size: 1.01 KB
Versions: 14
Compression:
Stored size: 1.01 KB
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 truncate(event)
name = 'CassandraObject truncate (%.1fms)' % event.duration
debug " #{name} #{event.payload[:column_family]}"
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
14 entries across 14 versions & 1 rubygems