Module: Jouba

Extended by:

Forwardable, Wisper::Publisher

Defined in:

lib/jouba.rb,
lib/jouba/key.rb,
lib/jouba/cache.rb,
lib/jouba/event.rb,
lib/jouba/store.rb,
lib/jouba/version.rb,
lib/jouba/aggregate.rb

Defined Under Namespace

Modules: Cache Classes: Aggregate, Event, EventStore, Key, MemoryStore

Constant Summary

DEFAULTS =

{
  Event: Jouba::Event,
  Key:   Jouba::Key,
  Cache: Cache::Null.new,
  Store: Jouba::EventStore.new
}

VERSION =

'0.0.1'

Class Method Summary

• .config ⇒ Object
• .emit(key, name, data) ⇒ Object
• .stream(key, params = {}) ⇒ Object

Class Method Details

.config ⇒ Object

# File 'lib/jouba.rb', line 28

def config
  @config ||= Hashie::Mash.new { |h, k| h[k] = DEFAULTS[k] }
end

.emit(key, name, data) ⇒ Object

# File 'lib/jouba.rb', line 32

def emit(key , name , data)
  config.Event.new(key: key, name: name, data: data).tap do |event|
    block_given? ? yield(event) : event.track
    publish(key, event)
  end
end

.stream(key, params = {}) ⇒ Object

# File 'lib/jouba.rb', line 39

def stream(key, params = {})
  config.Event.stream(key, params)
end