TransactionEventStore

An extension of https://github.com/arkency/ruby_event_store with support for pessimistic locking and snapshots.

Implementations

Mongoid
Active Record coming soon

See Also

Snapshot Aggregate Root an "Aggregate Root" implementation using this event store.

API

Same as RubyEventStore::Client except the following additions

Snapshots

publish_snapshot - delegates to repository#create_snapshot
last_stream_snapshot - delegates to repository#last_stream_snapshot

Concurrent writers

with_lock method added, which delegates to repository#with_lock
notify_susbsribers method added, which exposes the exising event_broker#notify_subscribers function (this is used with_write_context to ensure event handlers aren't called until after the events are committed)

Unlimited queries

Event store reader methods (read_events_forward etc), that accept a count: parameter can be passed count: nil to disable limits