Class: Indexer

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::Worker
Defined in:
lib/rails/templates/indexer.rb

Overview

Indexer class for http://sidekiq.org

Run me with:

$ bundle exec sidekiq --queue elasticsearch --verbose

Constant Summary collapse

Logger = 
Sidekiq.logger.level == Logger::DEBUG ? Sidekiq.logger : nil
Client = 
Elasticsearch::Client.new host: (ENV['ELASTICSEARCH_URL'] || 'http://localhost:9200'), logger: Logger

Instance Method Summary collapse

Instance Method Details

#perform(operation, klass, record_id, options = {}) ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/rails/templates/indexer.rb', line 31

def perform(operation, klass, record_id, options={})
  logger.debug [operation, "#{klass}##{record_id} #{options.inspect}"]

  case operation.to_s
    when /index|update/
      record = klass.constantize.find(record_id)
      record.__elasticsearch__.client = Client
      record.__elasticsearch__.__send__ "#{operation}_document"
    when /delete/
      Client.delete index: klass.constantize.index_name, id: record_id
    else raise ArgumentError, "Unknown operation '#{operation}'"
  end
end