Module: ConcurrentPipeline

Defined in:
lib/concurrent_pipeline.rb,
lib/concurrent_pipeline/shell.rb,
lib/concurrent_pipeline/store.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/stores/storage/yaml.rb,
lib/concurrent_pipeline/stores/schema/record.rb,
lib/concurrent_pipeline/stores/storage/yaml/fs.rb,
lib/concurrent_pipeline/pipelines/processors/locker.rb,
lib/concurrent_pipeline/pipelines/processors/synchronous.rb,
lib/concurrent_pipeline/pipelines/processors/asynchronous.rb

Defined Under Namespace

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

Constant Summary collapse

VERSION = 
"1.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 ⇒ Object 



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

def store(&)
  Store.define(&)
end