class Indexer

Constants

Client: Elasticsearch client
Logger: Logger

Public Instance Methods

perform(operation, klass, record_id, options={}) click to toggle source

To update/delete index in elastic search

# File app/workers/indexer.rb, line 12
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, type: klass.constantize.document_type, id: record_id
    else raise ArgumentError, "Unknown operation '#{operation}'"
  end
end