NewEventStore creates a new EventStore using the database connection pool provided.

NewJSONRegistry creates a new registry for deserializing event types, using the provided deserializer.

RunMigrations performs the migrations for the Postgres database.

WithAppendMiddleware allows overriding the internal logic for appending events within a transaction.

Checkpointer is a checkpoint.Checkpointer implementation using Postgres as a storage backend.

EventStore is an eventstore.Store implementation which uses PostgreSQL as backend datastore.

FusedSerde is a convenience type to fuse a Serializer and Deserializer in a Serde instance.

JSONRegistry is a Serde type that serializes and deserializes into and from the JSON representation of eventually.Payload types registered.

Deserializer can be used by the EventStore to delegate deserialization of a Domain Event from binary format to its corresponding Domain Object.

Serde is a serializer/deserializer type that can be used by the EventStore to serialize Domain Events to and deserialize Domain Events from the store.

Serializer can be used by the EventStore to delegate serialization of a Domain Event from the eventually.Payload format (domain object) to binary format.

AppendToStoreFunc is the function type used by the postgres.EventStore to delegate the append call to the database instace.

DeserializerFunc is a functional type that implements the Deserializer interface.

Option defines a type for providing additional constructor adjustments for postgres.EventStore.

SerializerFunc is a functional type that implements the Serializer interface.