Module: Dipa::Processor::Concerns::Options

Extended by:

ActiveSupport::Concern

Includes:

ActiveSupport::Configurable

Included in:

Base, Coordinator, Wait

Defined in:

lib/dipa/processor/concerns/options.rb

Constant Summary

DEFAULT_ASYNC =

false

DEFAULT_KEEP_DATA =

false

DEFAULT_WANT_RESULT =

true

OPTIONS_MAPPING =

{
  # queue names
  agent_queue: { accessor: :_agent_queue, default: Dipa.agent_queue },
  coordinator_queue: { accessor: :_coordinator_queue, default: Dipa.coordinator_queue },
  # timeouts
  agent_timeout: { accessor: :_agent_timeout, default: Dipa.agent_timeout },
  agent_processing_timeout: { accessor: :_agent_processing_timeout, default: Dipa.agent_processing_timeout },
  coordinator_timeout: { accessor: :_coordinator_timeout, default: Dipa.coordinator_timeout },
  coordinator_processing_timeout: { accessor: :_coordinator_processing_timeout,
                                    default: Dipa.coordinator_processing_timeout },
  # misc
  keep_data: { accessor: :_keep_data, default: DEFAULT_KEEP_DATA },
  want_result: { accessor: :_want_result, default: DEFAULT_WANT_RESULT }
}.freeze