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 collapse

VERSION = 
"2.0.0"

Class Method Summary collapse

Class Method Details

.pipeline ⇒ Object 



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

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

.store(type = :yaml) ⇒ Object 



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

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