Module: Liebre

Defined in:

lib/liebre.rb,
lib/liebre/actor.rb,
lib/liebre/bridge.rb,
lib/liebre/config.rb,
lib/liebre/engine.rb,
lib/liebre/runner.rb,
lib/liebre/adapter.rb,
lib/liebre/version.rb,
lib/liebre/engine/state.rb,
lib/liebre/actor/context.rb,
lib/liebre/adapter/bunny.rb,
lib/liebre/actor/consumer.rb,
lib/liebre/engine/builder.rb,
lib/liebre/actor/publisher.rb,
lib/liebre/actor/rpc/client.rb,
lib/liebre/actor/rpc/server.rb,
lib/liebre/adapter/interface.rb,
lib/liebre/engine/repository.rb,
lib/liebre/adapter/bunny/chan.rb,
lib/liebre/adapter/bunny/conn.rb,
lib/liebre/actor/consumer/core.rb,
lib/liebre/adapter/bunny/queue.rb,
lib/liebre/actor/publisher/core.rb,
lib/liebre/actor/context/declare.rb,
lib/liebre/actor/context/handler.rb,
lib/liebre/actor/rpc/client/core.rb,
lib/liebre/actor/rpc/client/task.rb,
lib/liebre/actor/rpc/server/core.rb,
lib/liebre/adapter/bunny/exchange.rb,
lib/liebre/adapter/interface/chan.rb,
lib/liebre/adapter/interface/conn.rb,
lib/liebre/bridge/channel_builder.rb,
lib/liebre/actor/consumer/callback.rb,
lib/liebre/actor/consumer/reporter.rb,
lib/liebre/adapter/interface/queue.rb,
lib/liebre/actor/consumer/resources.rb,
lib/liebre/actor/publisher/reporter.rb,
lib/liebre/actor/rpc/client/pending.rb,
lib/liebre/actor/publisher/resources.rb,
lib/liebre/actor/rpc/client/reporter.rb,
lib/liebre/actor/rpc/server/callback.rb,
lib/liebre/actor/rpc/server/reporter.rb,
lib/liebre/actor/rpc/client/resources.rb,
lib/liebre/actor/rpc/server/resources.rb,
lib/liebre/adapter/interface/exchange.rb,
lib/liebre/actor/consumer/resources/config.rb

Defined Under Namespace

Modules: Actor, Adapter Classes: Bridge, Config, Engine, Runner

Constant Summary

VERSION =

"0.2.1"

Class Method Summary

• .config ⇒ Object
• .configure {|config| ... } ⇒ Object
• .engine ⇒ Object
• .repo ⇒ Object
• .start(only: nil) ⇒ Object

Class Method Details

.config ⇒ Object

# File 'lib/liebre.rb', line 19

def self.config
  @config ||= Config.new
end

.configure {|config| ... } ⇒ Object

Yields:

• (config)

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

def self.configure
  yield(config)
end

.engine ⇒ Object

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

def self.engine
  @engine ||= Engine.new(config)
end

.repo ⇒ Object

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

def self.repo
  engine.repo
end

.start(only: nil) ⇒ Object

# File 'lib/liebre.rb', line 14

def self.start only: nil
  runner = Runner.new(engine: Liebre.engine)
  runner.run(only: only)
end