initialize

in lib/core/sync_job_runner.rb [50:68]

• 18 lines of code
• 1 McCabe index (conditional complexity)

    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