Class: Krikri::Indexer

Inherits:
Object
  • Object
show all
Includes:
EntityConsumer, SoftwareAgent
Defined in:
lib/krikri/indexer.rb

Overview

TODO:

use generalized ‘EntityConsumer` interface that is independent from `Activity`. `#index` needs to be largely rewritten due to `#update_from_activity`, which is tighly bound to `Activity` rather than `Enumerator<#entities>`.

A SoftwareAgent to run indexing processes.

The options hash contains options for the ‘Indexer` as well as the `SearchIndex`.

Examples:

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'
})

See Also:

  • SoftwareAgent#enqueue

Instance Attribute Summary collapse

Attributes included from SoftwareAgent

#entity_behavior

Class Method Summary collapse

Instance Method Summary collapse

Methods included from EntityConsumer

#assign_generator_activity!, #entities, #entity_source, #set_entity_source!

Methods included from SoftwareAgent

#agent_name

Constructor Details

#initialize(opts = {}) ⇒ Indexer

Returns a new instance of Indexer.



30
31
32
33
34
 
# File 'lib/krikri/indexer.rb', line 30

def initialize(opts = {})
  assign_generator_activity!(opts)
  @index_class = opts.delete(:index_class)
  @index_opts = opts
end

Instance Attribute Details

#index ⇒ Object (readonly)

Returns the value of attribute index.



24
25
26
 
# File 'lib/krikri/indexer.rb', line 24

def index
  @index
end

#index_class ⇒ Object (readonly)

Returns the value of attribute index_class.



24
25
26
 
# File 'lib/krikri/indexer.rb', line 24

def index_class
  @index_class
end

#index_opts ⇒ Object (readonly)

Returns the value of attribute index_opts.



24
25
26
 
# File 'lib/krikri/indexer.rb', line 24

def index_opts
  @index_opts
end

Class Method Details

.queue_name ⇒ Object 



26
27
28
 
# File 'lib/krikri/indexer.rb', line 26

def self.queue_name
  :indexing
end

Instance Method Details

#run ⇒ Object 



40
41
42
 
# File 'lib/krikri/indexer.rb', line 40

def run
  index.update_from_activity(generator_activity)
end