riak_callback.rb

class RiakCallback
  def before_destroy(record)
    raise 'Invalid Riak Client' unless record.walk_server_client.is_a? Riak::Client
    @client = record.walk_server_client
    record.riak_keys.each do |key|
      delete(key[0], key[1])
    end
  end

  def exists?(key, bucket_name)
    bucket(bucket_name).exists?(key)
  end

  def delete(key, bucket_name)
    bucket(bucket_name).delete(key) if exists?(key, bucket_name)
  end

  def bucket(bucket_name)
    @client.bucket(bucket_name)
  end
end