Module: RubyReactor

Defined in:
lib/ruby_reactor.rb,
lib/ruby_reactor/lock.rb,
lib/ruby_reactor/step.rb,
lib/ruby_reactor/rspec.rb,
lib/ruby_reactor/period.rb,
lib/ruby_reactor/context.rb,
lib/ruby_reactor/reactor.rb,
lib/ruby_reactor/sweeper.rb,
lib/ruby_reactor/version.rb,
lib/ruby_reactor/web/api.rb,
lib/ruby_reactor/executor.rb,
lib/ruby_reactor/registry.rb,
lib/ruby_reactor/semaphore.rb,
lib/ruby_reactor/error/base.rb,
lib/ruby_reactor/middleware.rb,
lib/ruby_reactor/rate_limit.rb,
lib/ruby_reactor/dsl/reactor.rb,
lib/ruby_reactor/map/helpers.rb,
lib/ruby_reactor/map/sweeper.rb,
lib/ruby_reactor/dsl/lockable.rb,
lib/ruby_reactor/ordered_lock.rb,
lib/ruby_reactor/configuration.rb,
lib/ruby_reactor/map/collector.rb,
lib/ruby_reactor/retry_context.rb,
lib/ruby_reactor/rspec/helpers.rb,
lib/ruby_reactor/step/map_step.rb,
lib/ruby_reactor/template/base.rb,
lib/ruby_reactor/map/dispatcher.rb,
lib/ruby_reactor/open_telemetry.rb,
lib/ruby_reactor/rspec/matchers.rb,
lib/ruby_reactor/template/input.rb,
lib/ruby_reactor/template/value.rb,
lib/ruby_reactor/dsl/map_builder.rb,
lib/ruby_reactor/sidekiq_adapter.rb,
lib/ruby_reactor/storage/adapter.rb,
lib/ruby_reactor/template/result.rb,
lib/ruby_reactor/validation/base.rb,
lib/ruby_reactor/web/application.rb,
lib/ruby_reactor/dependency_graph.rb,
lib/ruby_reactor/dsl/step_builder.rb,
lib/ruby_reactor/error/undo_error.rb,
lib/ruby_reactor/interrupt_result.rb,
lib/ruby_reactor/template/element.rb,
lib/ruby_reactor/middleware_runner.rb,
lib/ruby_reactor/step/compose_step.rb,
lib/ruby_reactor/context_serializer.rb,
lib/ruby_reactor/rspec/test_subject.rb,
lib/ruby_reactor/dsl/compose_builder.rb,
lib/ruby_reactor/rate_limit_registry.rb,
lib/ruby_reactor/retry_queued_result.rb,
lib/ruby_reactor/rspec/storage_reset.rb,
lib/ruby_reactor/dsl/template_helpers.rb,
lib/ruby_reactor/map/element_executor.rb,
lib/ruby_reactor/utils/code_extractor.rb,
lib/ruby_reactor/dsl/interrupt_builder.rb,
lib/ruby_reactor/map/result_enumerator.rb,
lib/ruby_reactor/rspec/sidekiq_helpers.rb,
lib/ruby_reactor/storage/configuration.rb,
lib/ruby_reactor/storage/redis_adapter.rb,
lib/ruby_reactor/storage/redis_locking.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/template/dynamic_source.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/utils/backtrace_location.rb,
lib/ruby_reactor/dsl/interrupt_step_config.rb,
lib/ruby_reactor/rspec/step_executor_patch.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/web/coordination_serializer.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/executor/ordered_lock_support.rb,
lib/ruby_reactor/max_retries_exhausted_failure.rb,
lib/ruby_reactor/storage/redis_ordered_locking.rb,
lib/ruby_reactor/sidekiq_workers/sweeper_worker.rb,
lib/ruby_reactor/sidekiq_workers/map_element_worker.rb,
lib/ruby_reactor/sidekiq_workers/map_collector_worker.rb

Defined Under Namespace

Modules: Dsl, Error, Map, Period, RSpec, SidekiqWorkers, Step, Storage, Template, Utils, Validation, Web Classes: AsyncResult, Configuration, Context, ContextSerializer, DependencyGraph, Executor, Failure, InterruptResult, Lock, MaxRetriesExhaustedFailure, Middleware, MiddlewareRunner, OpenTelemetry, OrderedLock, RateLimit, RateLimitRegistry, Reactor, Registry, RetryContext, RetryQueuedResult, Semaphore, SidekiqAdapter, Skipped, Success, Sweeper

Constant Summary collapse

VERSION = 
"0.5.3"

Class Method Summary collapse

Class Method Details

.configuration ⇒ Object 



330
331
332
 
# File 'lib/ruby_reactor.rb', line 330

def self.configuration
  Configuration.instance
end

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

Yields:



326
327
328
 
# File 'lib/ruby_reactor.rb', line 326

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

.Failure(error, **kwargs) ⇒ Object 



316
317
318
 
# File 'lib/ruby_reactor.rb', line 316

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

.internal_lib_path ⇒ Object 



379
380
381
 
# File 'lib/ruby_reactor.rb', line 379

def self.internal_lib_path
  File.join(root.to_s, "lib")
end

.reactor_storage_name(reactor_class) ⇒ Object

The name under which a reactor class’s durable state is keyed in storage (‘reactor:<name>:context:<id>`, map metadata, etc.). MUST be stable across processes: the enqueuing process writes the blob under this name and a different worker process reads it back by the same name. So an anonymous class falls back to a fixed constant, NOT `object_id` — object_id is process-local and would make the worker’s read key miss the writer’s key. The context_id in the key still disambiguates distinct anonymous reactors. (A truly anonymous class can’t be reconstituted by name in another process, so cross-process resume of one is inherently unsupported; this only keeps the keys self-consistent within a process — e.g. inline tests.)



344
345
346
347
348
 
# File 'lib/ruby_reactor.rb', line 344

def self.reactor_storage_name(reactor_class)
  return "AnonymousReactor" if reactor_class.nil?

  reactor_class.name || "AnonymousReactor"
end

.root ⇒ Object 



375
376
377
 
# File 'lib/ruby_reactor.rb', line 375

def self.root
  Pathname.new(File.expand_path("..", __dir__))
end

.Skipped(reason: nil, **kwargs) ⇒ Object

Build a ‘Skipped` result. Return one from a step’s ‘run` block to halt the reactor cleanly without triggering compensation of previous steps.



322
323
324
 
# File 'lib/ruby_reactor.rb', line 322

def self.Skipped(reason: nil, **kwargs)
  Skipped.new(reason: reason, **kwargs)
end

.start_sweeper! ⇒ Object

Kick the self-rescheduling recovery sweeper chain. Call once per cluster —typically from an initializer (‘RubyReactor.start_sweeper!`). Idempotent: calling it on every process boot is safe because the worker claims each tick by time-window, so duplicate kicks collapse to a single chain. No-op when `config.sweeper_enabled` is false. Returns the scheduled job id, or nil when disabled or when this window’s tick was already claimed by another caller.



356
357
358
359
360
 
# File 'lib/ruby_reactor.rb', line 356

def self.start_sweeper!
  return unless configuration.sweeper_enabled

  SidekiqWorkers::SweeperWorker.schedule_next
end

.Success(value = nil) ⇒ Object

Global helper methods



312
313
314
 
# File 'lib/ruby_reactor.rb', line 312

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

.sweep_once(limit: nil) ⇒ Object

Run both recovery sweepers exactly once and return their counts. The synchronous escape hatch for hosts that schedule recovery with their own cron / k8s CronJob instead of the in-cluster chain (set ‘config.sweeper_enabled = false` and call this from `rake ruby_reactor:sweep` or a binstub).



367
368
369
370
371
372
373
 
# File 'lib/ruby_reactor.rb', line 367

def self.sweep_once(limit: nil)
  limit ||= configuration.sweeper_limit
  {
    reactors: Sweeper.run_once(limit: limit),
    maps: Map::Sweeper.run_once(limit: limit)
  }
end