Sha256: 5138534b3101f4131b96ac7b0f7313cdee65cb2fbeb01b6ea8ad21efbd7ca4cc
Contents?: true
Size: 1.38 KB
Versions: 7
Compression:
Stored size: 1.38 KB
Contents
module CassandraObject
class LogSubscriber < ActiveSupport::LogSubscriber
def get(event)
name = '%s get (%.1fms)' % [event.payload[:column_family], event.duration]
debug " #{name} #{event.payload[:key]}"
end
def multi_get(event)
name = '%s multi_get (%.1fms)' % [event.payload[:column_family], event.duration]
debug " #{name} (#{event.payload[:keys].size}) #{event.payload[:keys].join(" ")}"
end
def remove(event)
name = '%s remove (%.1fms)' % [event.payload[:column_family], event.duration]
message = " #{name} #{event.payload[:key]}"
message << " #{Array(event.payload[:attributes]).inspect}" if event.payload[:attributes]
debug message
end
def truncate(event)
name = '%s truncate (%.1fms)' % [event.payload[:column_family], event.duration]
debug " #{name} #{event.payload[:column_family]}"
end
def insert(event)
name = '%s insert (%.1fms)' % [event.payload[:column_family], event.duration]
debug " #{name} #{event.payload[:key]} #{event.payload[:attributes].inspect}"
end
def get_range(event)
name = '%s get_range (%.1fms)' % [event.payload[:column_family], 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
7 entries across 7 versions & 1 rubygems