Class: EventSourcery::Postgres::Config

Inherits:
Object
  • Object
show all
Defined in:
lib/event_sourcery/postgres/config.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Config

Returns a new instance of Config.



24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/event_sourcery/postgres/config.rb', line 24

def initialize
  @lock_table_to_guarantee_linear_sequence_id_growth = true
  @write_events_function_name = 'writeEvents'
  @events_table_name = :events
  @aggregates_table_name = :aggregates
  @tracker_table_name = :projector_tracker
  @callback_interval_if_no_new_events = 10
  @event_store_database = nil
  @auto_create_projector_tracker = true
  @projector_transaction_size = 1
  @on_events_recorded = ->(events) {}
end

Instance Attribute Details

#aggregates_table_name ⇒ Object

Returns the value of attribute aggregates_table_name.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def aggregates_table_name
  @aggregates_table_name
end

#auto_create_projector_tracker ⇒ Object

Returns the value of attribute auto_create_projector_tracker.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def auto_create_projector_tracker
  @auto_create_projector_tracker
end

#callback_interval_if_no_new_events ⇒ Object

Returns the value of attribute callback_interval_if_no_new_events.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def callback_interval_if_no_new_events
  @callback_interval_if_no_new_events
end

#event_sink ⇒ Object 



45
46
47
 
# File 'lib/event_sourcery/postgres/config.rb', line 45

def event_sink
  @event_sink ||= ::EventSourcery::EventStore::EventSink.new(event_store)
end

#event_source ⇒ Object 



41
42
43
 
# File 'lib/event_sourcery/postgres/config.rb', line 41

def event_source
  @event_source ||= ::EventSourcery::EventStore::EventSource.new(event_store)
end

#event_store ⇒ Object 



37
38
39
 
# File 'lib/event_sourcery/postgres/config.rb', line 37

def event_store
  @event_store ||= EventStore.new(event_store_database)
end

#event_store_database ⇒ Object

Returns the value of attribute event_store_database.



21
22
23
 
# File 'lib/event_sourcery/postgres/config.rb', line 21

def event_store_database
  @event_store_database
end

#event_tracker ⇒ Object

Returns the value of attribute event_tracker.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def event_tracker
  @event_tracker
end

#events_table_name ⇒ Object

Returns the value of attribute events_table_name.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def events_table_name
  @events_table_name
end

#lock_table_to_guarantee_linear_sequence_id_growth ⇒ Object

Returns the value of attribute lock_table_to_guarantee_linear_sequence_id_growth.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def lock_table_to_guarantee_linear_sequence_id_growth
  @lock_table_to_guarantee_linear_sequence_id_growth
end

#on_events_recorded ⇒ Object

Returns the value of attribute on_events_recorded.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def on_events_recorded
  @on_events_recorded
end

#projections_database ⇒ Object

Returns the value of attribute projections_database.



21
22
23
 
# File 'lib/event_sourcery/postgres/config.rb', line 21

def projections_database
  @projections_database
end

#projector_transaction_size ⇒ Object

Returns the value of attribute projector_transaction_size.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def projector_transaction_size
  @projector_transaction_size
end

#tracker_table_name ⇒ Object

Returns the value of attribute tracker_table_name.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def tracker_table_name
  @tracker_table_name
end

#write_events_function_name ⇒ Object

Returns the value of attribute write_events_function_name.



6
7
8
 
# File 'lib/event_sourcery/postgres/config.rb', line 6

def write_events_function_name
  @write_events_function_name
end