postgres

Apr 21, 2026

retracted

Changes in this version

+ const DefaultAggregateTableName

+ const DefaultEventsTableName

+ const DefaultStreamsTableName

+ func RunMigrations(db *sql.DB) error

+ type AggregateRepository struct

+ func NewAggregateRepository[ID aggregate.ID, T aggregate.Root[ID]](conn *pgxpool.Pool, aggregateType aggregate.Type[ID, T], ...) AggregateRepository[ID, T]

+ func (repo AggregateRepository[ID, T]) Get(ctx context.Context, id ID) (T, error)

+ func (repo AggregateRepository[ID, T]) Save(ctx context.Context, root T) (err error)

+ type EventStore struct

+ func NewEventStore(conn *pgxpool.Pool, messageSerde serde.Bytes[message.Message]) EventStore

+ func (es EventStore) Append(ctx context.Context, id event.StreamID, expected version.Check, ...) (version.Version, error)

+ func (es EventStore) Stream(ctx context.Context, stream event.StreamWrite, id event.StreamID, ...) error

+ type Option interface

+ func WithAggregateTableName[ID aggregate.ID, T aggregate.Root[ID]](tableName string) Option[*AggregateRepository[ID, T]]

+ func WithEventsTableName[ID aggregate.ID, T aggregate.Root[ID]](tableName string) Option[*AggregateRepository[ID, T]]

+ func WithStreamsTableName[ID aggregate.ID, T aggregate.Root[ID]](tableName string) Option[*AggregateRepository[ID, T]]