class EventStore::Client
Public Class Methods
count()
click to toggle source
# File lib/event_store/client.rb, line 4 def self.count Aggregate.count end
ids(offset, limit)
click to toggle source
# File lib/event_store/client.rb, line 8 def self.ids(offset, limit) Aggregate.ids(offset, limit) end
new( aggregate_id, aggregate_type = EventStore.table_name)
click to toggle source
# File lib/event_store/client.rb, line 12 def initialize( aggregate_id, aggregate_type = EventStore.table_name) @aggregate = Aggregate.new(aggregate_id, aggregate_type) end
Public Instance Methods
append(event_data) { |event_data| ... }
click to toggle source
# File lib/event_store/client.rb, line 28 def append event_data event_appender.append(event_data) yield(event_data) if block_given? nil end
count()
click to toggle source
# File lib/event_store/client.rb, line 70 def count event_stream.length end
destroy!()
click to toggle source
# File lib/event_store/client.rb, line 74 def destroy! @aggregate.delete_events! @aggregate.delete_snapshot! end
event_stream()
click to toggle source
# File lib/event_store/client.rb, line 38 def event_stream translate_events raw_event_stream end
event_stream_between(start_time, end_time, fully_qualified_names = [])
click to toggle source
# File lib/event_store/client.rb, line 46 def event_stream_between(start_time, end_time, fully_qualified_names = []) translate_events @aggregate.event_stream_between(start_time, end_time, fully_qualified_names) end
event_stream_from(version_number, max=nil)
click to toggle source
# File lib/event_store/client.rb, line 42 def event_stream_from version_number, max=nil translate_events @aggregate.events_from(version_number, max) end
event_table()
click to toggle source
# File lib/event_store/client.rb, line 24 def event_table @aggregate.event_table end
id()
click to toggle source
# File lib/event_store/client.rb, line 16 def id @aggregate.id end
peek()
click to toggle source
# File lib/event_store/client.rb, line 50 def peek translate_event @aggregate.last_event end
raw_event_stream()
click to toggle source
# File lib/event_store/client.rb, line 58 def raw_event_stream @aggregate.event_stream end
raw_event_stream_from(version_number, max=nil)
click to toggle source
# File lib/event_store/client.rb, line 62 def raw_event_stream_from version_number, max=nil @aggregate.events_from(version_number, max) end
raw_snapshot()
click to toggle source
# File lib/event_store/client.rb, line 54 def raw_snapshot @aggregate.snapshot end
rebuild_snapshot!()
click to toggle source
# File lib/event_store/client.rb, line 79 def rebuild_snapshot! @aggregate.delete_snapshot! @aggregate.rebuild_snapshot! end
snapshot()
click to toggle source
# File lib/event_store/client.rb, line 34 def snapshot raw_snapshot end
type()
click to toggle source
# File lib/event_store/client.rb, line 20 def type @aggregate.type end
version()
click to toggle source
# File lib/event_store/client.rb, line 66 def version @aggregate.version end
Private Instance Methods
event_appender()
click to toggle source
# File lib/event_store/client.rb, line 86 def event_appender EventAppender.new(@aggregate) end
translate_event(event_hash)
click to toggle source
# File lib/event_store/client.rb, line 94 def translate_event(event_hash) occurred_at = TimeHacker.translate_occurred_at_from_local_to_gmt(event_hash[:occurred_at]) SerializedEvent.new event_hash[:fully_qualified_name], event_hash[:serialized_event], event_hash[:version], occurred_at end
translate_events(event_hashs)
click to toggle source
# File lib/event_store/client.rb, line 90 def translate_events(event_hashs) event_hashs.map { |eh| translate_event(eh) } end