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.



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

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.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

def aggregates_table_name
  @aggregates_table_name
end

#auto_create_projector_tracker ⇒ Object

Returns the value of attribute auto_create_projector_tracker.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

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.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

def callback_interval_if_no_new_events
  @callback_interval_if_no_new_events
end

#event_sink ⇒ Object 



43
44
45
 
# File 'lib/event_sourcery/postgres/config.rb', line 43

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

#event_source ⇒ Object 



39
40
41
 
# File 'lib/event_sourcery/postgres/config.rb', line 39

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

#event_store ⇒ Object 



35
36
37
 
# File 'lib/event_sourcery/postgres/config.rb', line 35

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

#event_store_database ⇒ Object

Returns the value of attribute event_store_database.



19
20
21
 
# File 'lib/event_sourcery/postgres/config.rb', line 19

def event_store_database
  @event_store_database
end

#event_tracker ⇒ Object

Returns the value of attribute event_tracker.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

def event_tracker
  @event_tracker
end

#events_table_name ⇒ Object

Returns the value of attribute events_table_name.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

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.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

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.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

def on_events_recorded
  @on_events_recorded
end

#projections_database ⇒ Object

Returns the value of attribute projections_database.



19
20
21
 
# File 'lib/event_sourcery/postgres/config.rb', line 19

def projections_database
  @projections_database
end

#projector_transaction_size ⇒ Object

Returns the value of attribute projector_transaction_size.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

def projector_transaction_size
  @projector_transaction_size
end

#tracker_table_name ⇒ Object

Returns the value of attribute tracker_table_name.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

def tracker_table_name
  @tracker_table_name
end

#write_events_function_name ⇒ Object

Returns the value of attribute write_events_function_name.



4
5
6
 
# File 'lib/event_sourcery/postgres/config.rb', line 4

def write_events_function_name
  @write_events_function_name
end