Method: Exekutor::Configuration#worker_options

Defined in:
lib/exekutor/configuration.rb

#worker_options ⇒ Hash

Gets the options for a worker

Returns:

  • (Hash) —

    the worker configuration



323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
 
# File 'lib/exekutor/configuration.rb', line 323

def worker_options
  {
    min_threads: min_execution_threads,
    max_threads: max_execution_threads,
    max_thread_idletime: max_execution_thread_idletime.to_f
  }.tap do |opts|
    opts[:set_db_connection_name] = set_db_connection_name? unless set_db_connection_name.nil?
    %i[enable_listener delete_completed_jobs delete_discarded_jobs delete_failed_jobs].each do |option|
      opts[option] = send(:"#{option}?") ? true : false
    end
    %i[polling_interval polling_jitter status_server_handler status_server_port healthcheck_timeout]
      .each do |option|
      opts[option] = send(option)
    end
  end
end