Contents

module EventSourcery
  module Postgres
    class Config
      attr_accessor :lock_table_to_guarantee_linear_sequence_id_growth,
                    :write_events_function_name,
                    :events_table_name,
                    :aggregates_table_name,
                    :tracker_table_name,
                    :callback_interval_if_no_new_events,
                    :auto_create_projector_tracker,
                    :event_tracker

      attr_writer :event_store,
                  :event_source,
                  :event_sink

      attr_reader :event_store_database,
                  :projections_database

      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
      end

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

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

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

      def event_store_database=(db_connection)
        setup_connection(db_connection)

        @event_store_database = db_connection
      end

      def projections_database=(db_connection)
        setup_connection(db_connection)

        @projections_database = db_connection
        @event_tracker = Postgres::Tracker.new(db_connection)
      end

      private

      def setup_connection(db_connection)
        return unless db_connection

        db_connection.extension :pg_json
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
event_sourcery-postgres-0.6.0	lib/event_sourcery/postgres/config.rb