Class: EventStore::Client

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/event_store/client.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(aggregate_id, aggregate_type = EventStore.table_name, checkpoint_events = []) ⇒ Client

Returns a new instance of Client.



25
26
27
28
 
# File 'lib/event_store/client.rb', line 25

def initialize(aggregate_id, aggregate_type = EventStore.table_name, checkpoint_events = [])
  checkpoint_events = [checkpoint_events].flatten
  @aggregate = Aggregate.new(aggregate_id, aggregate_type, checkpoint_events)
end

Class Method Details

.count ⇒ Object 



17
18
19
 
# File 'lib/event_store/client.rb', line 17

def self.count
  Aggregate.count
end

.ids(offset, limit) ⇒ Object 



21
22
23
 
# File 'lib/event_store/client.rb', line 21

def self.ids(offset, limit)
  Aggregate.ids(offset, limit)
end

Instance Method Details

#append(event_data, logger = default_logger) {|event_data| ... } ⇒ Object

Yields:

  • (event_data) 


34
35
36
37
38
39
40
 
# File 'lib/event_store/client.rb', line 34

def append(event_data, logger=default_logger)
  logger.debug("Start Appending #{event_data} to #{id}")
  aggregate.append(event_data, logger)
  logger.debug("Done Appending #{event_data} to #{id}")
  yield(event_data) if block_given?
  nil
end

#destroy! ⇒ Object 



78
79
80
81
 
# File 'lib/event_store/client.rb', line 78

def destroy!
  aggregate.delete_events!
  aggregate.delete_snapshot!
end

#event_stream ⇒ Object 



46
47
48
 
# File 'lib/event_store/client.rb', line 46

def event_stream
  translate_events(raw_event_stream)
end

#event_stream_between(start_time, end_time, fully_qualified_names = []) ⇒ Object 



58
59
60
 
# File 'lib/event_store/client.rb', line 58

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(event_id, max = nil) ⇒ Object 



50
51
52
 
# File 'lib/event_store/client.rb', line 50

def event_stream_from(event_id, max=nil)
  translate_events(aggregate.events_from(event_id, max))
end

#exists? ⇒ Boolean

Returns:

  • (Boolean) 


30
31
32
 
# File 'lib/event_store/client.rb', line 30

def exists?
  aggregate.snapshot_exists?
end

#last_event_before(start_time, fully_qualified_names = []) ⇒ Object 



54
55
56
 
# File 'lib/event_store/client.rb', line 54

def last_event_before(start_time, fully_qualified_names = [])
  translate_events(aggregate.last_event_before(start_time, fully_qualified_names))
end

#peek ⇒ Object 



62
63
64
 
# File 'lib/event_store/client.rb', line 62

def peek
  aggregate.last_event
end

#raw_event_stream ⇒ Object 



70
71
72
 
# File 'lib/event_store/client.rb', line 70

def raw_event_stream
  aggregate.event_stream
end

#raw_event_stream_from(event_id, max = nil) ⇒ Object 



74
75
76
 
# File 'lib/event_store/client.rb', line 74

def raw_event_stream_from(event_id, max=nil)
  aggregate.events_from(event_id, max)
end

#raw_snapshot ⇒ Object 



66
67
68
 
# File 'lib/event_store/client.rb', line 66

def raw_snapshot
  aggregate.snapshot
end

#rebuild_snapshot! ⇒ Object 



83
84
85
86
 
# File 'lib/event_store/client.rb', line 83

def rebuild_snapshot!
  aggregate.delete_snapshot!
  aggregate.rebuild_snapshot!
end

#snapshot ⇒ Object 



42
43
44
 
# File 'lib/event_store/client.rb', line 42

def snapshot
  raw_snapshot
end