spike.rb

require 'riak'
require 'instrumentable'
require 'pp'

c = Riak::Client.new pb_port: 17017

class Riak::Client
  include Instrumentable

  instrument_method :get_object, 'get_object'
  instrument_method :store_object, 'store_object'
end

ActiveSupport::Notifications.subscribe('get_object') do |*args|
  pp args
end

ActiveSupport::Notifications.subscribe('store_object') do |*args|
  pp args
end

b = c['instrumentation_spike']

100.times do |t|
  o = Riak::RObject.new b, t.to_s
  o.data = t.to_s
  o.content_type = 'text/plain'
  o.store

  o2 = b.get t.to_s
end