Module: SandthornSequelProjection

Extended by:
Forwardable
Defined in:
lib/sandthorn_sequel_projection.rb,
lib/sandthorn_sequel_projection/lock.rb,
lib/sandthorn_sequel_projection/cursor.rb,
lib/sandthorn_sequel_projection/errors.rb,
lib/sandthorn_sequel_projection/runner.rb,
lib/sandthorn_sequel_projection/version.rb,
lib/sandthorn_sequel_projection/manifest.rb,
lib/sandthorn_sequel_projection/projection.rb,
lib/sandthorn_sequel_projection/event_store.rb,
lib/sandthorn_sequel_projection/event_handler.rb,
lib/sandthorn_sequel_projection/utilities/null_proc.rb,
lib/sandthorn_sequel_projection/event_handler_collection.rb,
lib/sandthorn_sequel_projection/processed_events_tracker.rb

Defined Under Namespace

Modules: Utilities Classes: CircularQueue, Configuration, Cursor, EventHandler, EventHandlerCollection, EventStore, InvalidEventStoreError, Lock, Manifest, MigrationError, ProcessedEventsTracker, Projection, Runner, SandthornSequelProjectionError

Constant Summary collapse

VERSION = 
"0.0.3"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.configuration ⇒ Object

Returns the value of attribute configuration.



27
28
29
 
# File 'lib/sandthorn_sequel_projection.rb', line 27

def configuration
  @configuration
end

Class Method Details

.configure {|configuration| ... } ⇒ Object

Yields:



29
30
31
32
33
 
# File 'lib/sandthorn_sequel_projection.rb', line 29

def configure
  @configuration ||= Configuration.default
  yield(configuration) if block_given?
  start
end

.find_event_store(name) ⇒ Object 



39
40
41
 
# File 'lib/sandthorn_sequel_projection.rb', line 39

def find_event_store(name)
  EventStore.new(name)
end

.start ⇒ Object 



35
36
37
 
# File 'lib/sandthorn_sequel_projection.rb', line 35

def start
  ProcessedEventsTracker.migrate!(configuration.db_connection)
end