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