Module: Dipa

Extended by:
ActiveSupport::Autoload
Defined in:
lib/dipa/version.rb,
lib/dipa.rb,
lib/dipa/engine.rb,
lib/dipa/errors.rb,
app/models/dipa/agent.rb,
lib/dipa/processor/map.rb,
lib/dipa/processor/base.rb,
lib/dipa/processor/each.rb,
app/jobs/dipa/service_job.rb,
app/models/dipa/coordinator.rb,
app/jobs/dipa/application_job.rb,
lib/dipa/processor/concerns/wait.rb,
lib/dipa/processor/concerns/state.rb,
app/models/dipa/application_record.rb,
app/validators/dipa/date_validator.rb,
lib/dipa/processor/concerns/source.rb,
lib/dipa/processor/concerns/options.rb,
app/services/dipa/application_service.rb,
lib/dipa/processor/concerns/coordinator.rb,
app/models/concerns/dipa/models/dumpable.rb,
app/models/concerns/dipa/models/loadable.rb,
app/models/dipa/coordinator_options_record.rb,
app/services/dipa/agent_services/base_service.rb,
app/models/concerns/dipa/models/setting_constants.rb,
app/services/dipa/agent_services/processing_service.rb,
app/services/dipa/coordinator_services/base_service.rb,
app/models/concerns/dipa/models/agent_state_attributes.rb,
app/services/dipa/coordinator_services/destroy_service.rb,
app/models/concerns/dipa/models/state_attribute_handling.rb,
app/services/dipa/agent_services/post_processing_service.rb,
app/services/dipa/agent_services/start_processing_service.rb,
app/services/dipa/agent_services/coordinator_state_service.rb,
app/models/concerns/dipa/models/coordinator_state_attributes.rb,
app/services/concerns/dipa/services/process_failure_handling.rb,
app/services/dipa/coordinator_services/create_agents_service.rb,
app/services/dipa/coordinator_services/maybe_cleanup_service.rb,
app/services/dipa/coordinator_services/start_processing_service.rb

Overview

Schema Information

Table name: dipa_coordinator_options_records

id                             :bigint           not null, primary key
agent_processing_timeout       :integer          not null
agent_timeout                  :integer          not null
coordinator_processing_timeout :integer          not null
coordinator_timeout            :integer          not null
keep_data                      :boolean          default(FALSE), not null
want_result                    :boolean          default(TRUE), not null
created_at                     :datetime         not null
updated_at                     :datetime         not null
dipa_coordinator_id            :bigint           not null

Indexes

index_dipa_coordinator_options_records_on_dipa_coordinator_id  (dipa_coordinator_id)

Foreign Keys

fk_rails_...  (dipa_coordinator_id => dipa_coordinators.id)

Defined Under Namespace

Modules: AgentServices, CoordinatorServices, Models, Processor, Services Classes: Agent, AgentAbortedThroughCoordinatorError, AgentAbortedThroughCoordinatorProcessingTimedOutError, AgentAbortedThroughCoordinatorTimedOutError, AgentError, AgentProcessingTimedOutError, AgentTimedOutError, AlreadyProcessingError, ApplicationJob, ApplicationRecord, ApplicationService, Coordinator, CoordinatorAbortedError, CoordinatorAbortedThroughAgentError, CoordinatorAbortedThroughAgentProcessingFailedError, CoordinatorAbortedThroughAgentProcessingFailureError, CoordinatorAbortedThroughAgentProcessingTimedOutError, CoordinatorAbortedThroughAgentTimedOutError, CoordinatorError, CoordinatorOptionsRecord, CoordinatorProcessingFailedError, CoordinatorProcessingTimedOutError, CoordinatorTimedOutError, DateValidator, Engine, Error, ServiceJob, UnknownProcessingStateError, UnknownProcessorClassError, UnknownProcessorMethodError

Constant Summary collapse

DEFAULT_AGENT_TIMEOUT =

DEFAULT_TIMEOUT = 0

0
DEFAULT_AGENT_PROCESSING_TIMEOUT = 
0
DEFAULT_COORDINATOR_TIMEOUT = 
0
DEFAULT_COORDINATOR_PROCESSING_TIMEOUT = 
0
DATETIME_PRECISION = 
6
VERSION = 
'0.1.0.pre.3'

Class Method Summary collapse

Class Method Details

.each(source, options: {}) ⇒ Object 



34
35
36
 
# File 'lib/dipa.rb', line 34

def self.each(source, options: {})
  Dipa::Processor::Each.new(source, options: options)
end

.map(source, options: {}) ⇒ Object

rubocop:enable ThreadSafety/ClassAndModuleAttributes



30
31
32
 
# File 'lib/dipa.rb', line 30

def self.map(source, options: {})
  Dipa::Processor::Map.new(source, options: options)
end