Module: SolidFlow

Defined in:

lib/solid_flow.rb,
lib/solid_flow/cli.rb,
lib/solid_flow/task.rb,
lib/solid_flow/wait.rb,
lib/solid_flow/engine.rb,
lib/solid_flow/errors.rb,
lib/solid_flow/replay.rb,
lib/solid_flow/runner.rb,
lib/solid_flow/signals.rb,
lib/solid_flow/testing.rb,
lib/solid_flow/version.rb,
lib/solid_flow/workflow.rb,
app/models/solidflow/event.rb,
app/models/solidflow/timer.rb,
lib/solid_flow/determinism.rb,
lib/solid_flow/idempotency.rb,
lib/solid_flow/stores/base.rb,
lib/solid_flow/serializers/oj.rb,
app/models/solidflow/execution.rb,
lib/solid_flow/instrumentation.rb,
app/models/solidflow/signal_message.rb,
lib/solid_flow/stores/active_record.rb,
app/jobs/solidflow/jobs/run_task_job.rb,
app/jobs/solidflow/jobs/timer_sweep_job.rb,
app/models/solidflow/application_record.rb,
lib/solid_flow/registries/task_registry.rb,
app/jobs/solidflow/jobs/run_execution_job.rb,
lib/solid_flow/registries/workflow_registry.rb

Defined Under Namespace

Modules: Determinism, Errors, Idempotency, Instrumentation, Jobs, Registries, Serializers, Signals, Stores, Testing, Wait Classes: ApplicationRecord, CLI, Configuration, Engine, Event, Execution, Replay, Runner, SignalMessage, Task, Timer, Workflow

Constant Summary

VERSION =

"0.1.0"

Class Method Summary

• .configuration ⇒ Object
• .configure {|configuration| ... } ⇒ Object
• .instrument(event, payload = {}) ⇒ Object
• .logger ⇒ Object
• .store ⇒ Object
• .task_registry ⇒ Object

Class Method Details

.configuration ⇒ Object

# File 'lib/solid_flow.rb', line 23

def configuration
  @configuration ||= Configuration.new
end

.configure {|configuration| ... } ⇒ Object

Yields:

• (configuration)

# File 'lib/solid_flow.rb', line 27

def configure
  yield(configuration)
end

.instrument(event, payload = {}) ⇒ Object

# File 'lib/solid_flow.rb', line 43

def instrument(event, payload = {})
  ActiveSupport::Notifications.instrument(event, payload)
end

.logger ⇒ Object

# File 'lib/solid_flow.rb', line 31

def logger
  configuration.logger
end

.store ⇒ Object

# File 'lib/solid_flow.rb', line 35

def store
  configuration.store
end

.task_registry ⇒ Object

# File 'lib/solid_flow.rb', line 39

def task_registry
  configuration.task_registry
end