NewAdvisoryLockAggregateProjectionStorage returns a new AdvisoryLockAggregateProjectionStorage.

NewAdvisoryLockStreamProjectionStorage returns a new AdvisoryLockStreamProjectionStorage.

NewConjoinedEventStore return a new postgres.ConjoinedEventStore.

NewEventStore return a new postgres.EventStore.

QuoteIdentifier quotes an "identifier" (e.g.

QuoteString returns the given string quoted.

ErrNoCreateTableQueries occurs when table create queries are not presented in the strategy.

ErrTableAlreadyExists occurs when table cannot be created as it exists already.

ErrTableNameEmpty occurs when table cannot be created because it has an empty name.

AdvisoryLockAggregateProjectionStorage is a AggregateProjectorStorage that uses an advisory locks to lock a projection.

AdvisoryLockStreamProjectionStorage is a StreamProjectorStorage that uses an advisory locks to lock a projection.

EventStore a in postgres event store implementation.