Module: RubyReactor

Defined in:
lib/ruby_reactor.rb,
lib/ruby_reactor/step.rb,
lib/ruby_reactor/context.rb,
lib/ruby_reactor/reactor.rb,
lib/ruby_reactor/version.rb,
lib/ruby_reactor/executor.rb,
lib/ruby_reactor/error/base.rb,
lib/ruby_reactor/dsl/reactor.rb,
lib/ruby_reactor/map/helpers.rb,
lib/ruby_reactor/async_router.rb,
lib/ruby_reactor/configuration.rb,
lib/ruby_reactor/map/collector.rb,
lib/ruby_reactor/map/execution.rb,
lib/ruby_reactor/retry_context.rb,
lib/ruby_reactor/step/map_step.rb,
lib/ruby_reactor/template/base.rb,
lib/ruby_reactor/template/input.rb,
lib/ruby_reactor/template/value.rb,
lib/ruby_reactor/dsl/map_builder.rb,
lib/ruby_reactor/storage/adapter.rb,
lib/ruby_reactor/template/result.rb,
lib/ruby_reactor/validation/base.rb,
lib/ruby_reactor/dependency_graph.rb,
lib/ruby_reactor/dsl/step_builder.rb,
lib/ruby_reactor/error/undo_error.rb,
lib/ruby_reactor/template/element.rb,
lib/ruby_reactor/step/compose_step.rb,
lib/ruby_reactor/context_serializer.rb,
lib/ruby_reactor/dsl/compose_builder.rb,
lib/ruby_reactor/retry_queued_result.rb,
lib/ruby_reactor/dsl/template_helpers.rb,
lib/ruby_reactor/map/element_executor.rb,
lib/ruby_reactor/storage/configuration.rb,
lib/ruby_reactor/storage/redis_adapter.rb,
lib/ruby_reactor/dsl/validation_helpers.rb,
lib/ruby_reactor/error/dependency_error.rb,
lib/ruby_reactor/error/validation_error.rb,
lib/ruby_reactor/executor/graph_manager.rb,
lib/ruby_reactor/executor/retry_manager.rb,
lib/ruby_reactor/executor/step_executor.rb,
lib/ruby_reactor/sidekiq_workers/worker.rb,
lib/ruby_reactor/executor/result_handler.rb,
lib/ruby_reactor/error/compensation_error.rb,
lib/ruby_reactor/error/step_failure_error.rb,
lib/ruby_reactor/executor/input_validator.rb,
lib/ruby_reactor/validation/schema_builder.rb,
lib/ruby_reactor/error/schema_version_error.rb,
lib/ruby_reactor/validation/input_validator.rb,
lib/ruby_reactor/error/deserialization_error.rb,
lib/ruby_reactor/error/input_validation_error.rb,
lib/ruby_reactor/error/context_too_large_error.rb,
lib/ruby_reactor/executor/compensation_manager.rb,
lib/ruby_reactor/max_retries_exhausted_failure.rb,
lib/ruby_reactor/sidekiq_workers/map_element_worker.rb,
lib/ruby_reactor/sidekiq_workers/map_collector_worker.rb,
lib/ruby_reactor/sidekiq_workers/map_execution_worker.rb

Defined Under Namespace

Modules: Dsl, Error, Map, SidekiqWorkers, Step, Storage, Template, Validation Classes: AsyncResult, AsyncRouter, Configuration, Context, ContextSerializer, DependencyGraph, Executor, Failure, MaxRetriesExhaustedFailure, Reactor, RetryContext, RetryQueuedResult, Success

Constant Summary collapse

VERSION = 
"0.1.0"

Class Method Summary collapse

Class Method Details

.configuration ⇒ Object 



156
157
158
 
# File 'lib/ruby_reactor.rb', line 156

def self.configuration
  Configuration.instance
end

.configure {|Configuration.instance| ... } ⇒ Object

Yields:



152
153
154
 
# File 'lib/ruby_reactor.rb', line 152

def self.configure
  yield(Configuration.instance) if block_given?
end

.Failure(error, **kwargs) ⇒ Object 



148
149
150
 
# File 'lib/ruby_reactor.rb', line 148

def self.Failure(error, **kwargs)
  Failure.new(error, **kwargs)
end

.Success(value = nil) ⇒ Object

Global helper methods



144
145
146
 
# File 'lib/ruby_reactor.rb', line 144

def self.Success(value = nil)
  Success.new(value)
end