Sha256: 88ab90862871f8d43e00b271f1c10b567b8c8e8a9f0f7baa741d61882d201b72
Contents?: true
Size: 1.1 KB
Versions: 19
Compression:
Stored size: 1.1 KB
Contents
module Krikri
##
# A SoftwareAgent to run indexing processes.
#
# @example
#
# To index records enriched by the enrichment activity with ID 3:
#
# Krikri::Indexer.enqueue({
# index_class: 'Krikri::QASearchIndex',
# generator_uri: 'http://ldp.local.dp.la/ldp/activity/3'
# some_option_for_index_class: 'abc'
# })
#
# The options hash contains options for the Indexer as well as the
# SearchIndex.
#
# @see Krikri::SoftwareAgent#enqueue
#
class Indexer
include SoftwareAgent
include EntityConsumer
attr_reader :index_class, :index_opts
def self.queue_name
:indexing
end
def initialize(opts = {})
assign_generator_activity!(opts)
@index_class = opts.delete(:index_class)
@index_opts = opts
end
def run
log :info, 'indexer is running'
search_index = index_class.constantize.new(index_opts)
search_index.update_from_activity(generator_activity)
rescue => e
Rails.logger.error("Indexing error: #{e.message}\n#{e.backtrace}")
ensure
log :info, 'indexer is done'
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems