AcquireConn will return a new connection.

AggregateProjectionEventStreamLoader returns a EventStreamLoader for the AggregateProjector.

GetProjectionStateSerialization returns a ProjectionStateSerialization based on the provided projection.

NewAggregateProjector creates a new projector for a projection.

NewBackgroundProcessor create a new projectionNotificationProcessor.

NewProjectionHandlerError return a ProjectionHandlerError with the cause being the provided error.

NewStreamProjector creates a new projector for a projection.

StreamProjectionEventStreamLoader returns a EventStreamLoader for the StreamProjector.

ProjectionFail indicated that the projection failed and cannot be recovered This means that a human as a service is needed.

ProjectionIgnoreError indicated that the projection failed but the failure can be ignored This can be used when the ProjectorErrorCallback recovered the system from the error.

ProjectionRetry indicated that the notification should be retried This can be used in combination with retry mechanism in the ProjectorErrorCallback.

ErrConnFailedToAcquire occurs when a connection cannot be acquired within the timelimit.

ErrNoProjectionRequired occurs when a notification was being acquired but the projection was already at the indicated position.

ErrProjectionFailedToLock occurs when the projector cannot acquire the projection lock.

ErrProjectionPreviouslyLocked occurs when a projection was lock was acquired but a previous lock is still in place.

NopMetrics is default Metrics handler in case nil is passed.

AggregateProjector is a postgres projector used to execute a projection per aggregate instance against an event stream.

ProjectionHandlerError an error indicating that a projection handler failed.

StreamProjector is a postgres projector used to execute a projection against an event stream.

Listener listens to an event stream and triggers a notification when an event was appended.

MessageFactory reconstruct messages from the database.

PersistenceStrategy interface describes strategy of persisting messages in the database.

ReadOnlyEventStore an interface describing a readonly event store that supports providing a SQL conn.