Contents

# -*- coding: utf-8 -*-
# This writer uses sidekiq to enqueue index jobs
# @author Michael Stämpfli and John Bradley

require 'sidekiq'

module XapianDb
  module IndexWriters
    class SidekiqWriter

      SidekiqWorker.class_eval do
        include Sidekiq::Worker
      end

      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)
          Sidekiq::Client.enqueue worker_class, :index, :class => obj.class.name, :id => obj.id
        end

        # Remove an object from the index
        # @param [String] xapian_id The document id
        def delete_doc_with(xapian_id, commit=true)
          Sidekiq::Client.enqueue worker_class, :delete_doc, :xapian_id => xapian_id
        end

        # Reindex all objects of a given class
        # @param [Class] klass The class to reindex
        def reindex_class(klass, options = {})
          Sidekiq::Client.enqueue worker_class, :reindex_class, :class => klass.name
        end

        def worker_class
          SidekiqWorker
        end
        private :worker_class
      end

    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
xapian_db-1.3.5.4	lib/xapian_db/index_writers/sidekiq_writer.rb
xapian_db-1.3.5.3	lib/xapian_db/index_writers/sidekiq_writer.rb
xapian_db-1.3.5.2	lib/xapian_db/index_writers/sidekiq_writer.rb
xapian_db-1.3.5.1	lib/xapian_db/index_writers/sidekiq_writer.rb
xapian_db-1.3.5	lib/xapian_db/index_writers/sidekiq_writer.rb
xapian_db-1.3.4	lib/xapian_db/index_writers/sidekiq_writer.rb