Sha256: bfc1b5712c7ef75dc119f4232b2692efa1060b22ae2c5b757ed6486a6c61ea5c

Contents?: true

Size: 822 Bytes

Versions: 1

Compression:

Stored size: 822 Bytes

Contents

require "forwardable"
require "invokr"
require "observer"
require "securerandom"

module Orchestra
  extend self

  def configure &block
    Configuration.module_eval &block
  end

  def define &block
    builder = DSL::Operations::Builder.new
    DSL::Operations::Context.evaluate builder, &block
    builder.build_operation
  end

  def perform operation, inputs = {}
    Conductor.new.perform operation, inputs
  end

  def replay_recording operation, store, input = {}
    store = Util.recursively_symbolize store
    input = input.merge store[:input]
    svc_recordings = store[:service_recordings]
    Recording.replay operation, input, svc_recordings
  end

  load File.expand_path('../orchestra/errors.rb', __FILE__)
end

Dir[File.expand_path '../orchestra/**/*.rb', __FILE__].each do |rb_file|
  load rb_file
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
ntl-orchestra-0.9.0 lib/orchestra.rb