Module: ConcurrentPipeline

Defined in:

lib/concurrent_pipeline.rb,
lib/concurrent_pipeline/shell.rb,
lib/concurrent_pipeline/store.rb,
lib/concurrent_pipeline/errors.rb,
lib/concurrent_pipeline/version.rb,
lib/concurrent_pipeline/pipeline.rb,
lib/concurrent_pipeline/stores/schema.rb,
lib/concurrent_pipeline/pipelines/schema.rb,
lib/concurrent_pipeline/pipelines/processors/locker.rb,
lib/concurrent_pipeline/pipelines/processors/result.rb,
lib/concurrent_pipeline/pipelines/processors/synchronous.rb,
lib/concurrent_pipeline/pipelines/processors/asynchronous.rb

Defined Under Namespace

Modules: Errors, Pipelines, Stores Classes: Error, Pipeline, Shell, Store

Constant Summary

VERSION =

"2.0.0"

Class Method Summary

• .pipeline ⇒ Object
• .store(type = :yaml) ⇒ Object

Class Method Details

.pipeline ⇒ Object

# File 'lib/concurrent_pipeline.rb', line 15

def pipeline(&)
  Pipeline.define(&)
end

.store(type = :yaml) ⇒ Object

# File 'lib/concurrent_pipeline.rb', line 11

def store(type = :yaml, &)
  Store.define(&)
end