lib/event_sourcery/postgres/schema.rb in event_sourcery-postgres-0.3.0 vs lib/event_sourcery/postgres/schema.rb in event_sourcery-postgres-0.4.0

@@ -1,9 +1,9 @@
 module EventSourcery
   module Postgres
     module Schema
-      extend self
+      module_function
 
       def create_event_store(db: EventSourcery::Postgres.config.event_store_database,
                              events_table_name: EventSourcery::Postgres.config.events_table_name,
                              aggregates_table_name: EventSourcery::Postgres.config.aggregates_table_name,
                              write_events_function_name: EventSourcery::Postgres.config.write_events_function_name)
@@ -26,9 +26,11 @@
           column :causation_id,   :uuid
           column :created_at,     :'timestamp without time zone', null: false, default: Sequel.lit("(now() at time zone 'utc')")
           index [:aggregate_id, :version], unique: true
           index :uuid, unique: true
           index :type
+          index :correlation_id
+          index :causation_id
           index :created_at
         end
       end
 
       def create_aggregates(db: EventSourcery::Postgres.config.event_store_database,