Sha256: 3fe8a8d104b5d64bc0a75e6386fb2dfeae86c00091a505a6e772b2856f0616ee
Contents?: true
Size: 1.38 KB
Versions: 8
Compression:
Stored size: 1.38 KB
Contents
# encoding: utf-8
# This writer puts reindex requests into a stalker queue. If you want
# to use this writer, you must install beanstalkd and the stalker gem.
# This writer can only be used inside a Rails app.
# See https://github.com/adamwiggins/stalker for more info
# @author Gernot Kogler
require 'beanstalk-client'
require 'json'
module XapianDb
module IndexWriters
class BeanstalkWriter
class << self
# Update an object in the index
# @param [Object] obj An instance of a class with a blueprint configuration
def index(obj, commit=true, changed_attrs: [])
beanstalk.put( { :task => "index_task", :class => obj.class.name, :id => obj.id, :changed_attrs => changed_attrs, :commit => commit }.to_json )
end
# Remove an object from the index
# @param [String] xapian_id The document id
def delete_doc_with(xapian_id, commit=true)
beanstalk.put( { :task => "delete_doc_task", :xapian_id => xapian_id }.to_json )
end
# Reindex all objects of a given class
# @param [Class] klass The class to reindex
def reindex_class(klass, options={})
beanstalk.put( { :task => "reindex_class_task", :class => klass.name }.to_json )
end
def beanstalk
@beanstalk ||= Beanstalk::Pool.new([XapianDb::Config.beanstalk_daemon_url])
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems