Class: Core::SyncJobRunner

Inherits:
Object
  • Object
show all
Defined in:
lib/core/sync_job_runner.rb

Instance Method Summary collapse

Constructor Details

#initialize(connector_settings) ⇒ SyncJobRunner

Returns a new instance of SyncJobRunner.



22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/core/sync_job_runner.rb', line 22

def initialize(connector_settings)
  @connector_settings = connector_settings
  @sink = Core::OutputSink::EsSink.new(connector_settings.index_name, @connector_settings.request_pipeline)
  @connector_class = Connectors::REGISTRY.connector_class(connector_settings.service_type)
  @connector_instance = Connectors::REGISTRY.connector(connector_settings.service_type, connector_settings.configuration)
  @status = {
    :indexed_document_count => 0,
    :deleted_document_count => 0,
    :error => nil
  }
end

Instance Method Details

#execute ⇒ Object 



34
35
36
37
 
# File 'lib/core/sync_job_runner.rb', line 34

def execute
  validate_configuration!
  do_sync!
end