Class: Core::SyncJobRunner

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

Constant Summary collapse

JOB_REPORTING_INTERVAL = 
10

Instance Method Summary collapse

Constructor Details

#initialize(connector_settings, job, max_ingestion_queue_size, max_ingestion_queue_bytes) ⇒ SyncJobRunner

Returns a new instance of SyncJobRunner.



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
 
# File 'lib/core/sync_job_runner.rb', line 51

def initialize(connector_settings, job, max_ingestion_queue_size, max_ingestion_queue_bytes)
  @connector_settings = connector_settings
  @connector_id = connector_settings.id
  @index_name = job.index_name
  @service_type = job.service_type
  @job = job
  @job_id = job.id
  @sink = Core::Ingestion::EsSink.new(
    @index_name,
    @connector_settings.request_pipeline,
    Utility::BulkQueue.new(
      max_ingestion_queue_size,
      max_ingestion_queue_bytes
    ),
    max_ingestion_queue_bytes
  )
  @connector_class = Connectors::REGISTRY.connector_class(@service_type)
end

Instance Method Details

#execute ⇒ Object 



70
71
72
73
 
# File 'lib/core/sync_job_runner.rb', line 70

def execute
  validate_configuration!
  do_sync!
end