Versions in this module Expand all Collapse all v0 v0.2.1 Sep 22, 2023 Changes in this version + func RunMigrations(db *sql.DB) error + type AggregateRepository struct + AggregateSerde serde.Bytes[T] + AggregateType aggregate.Type[ID, T] + Conn *pgxpool.Pool + MessageSerde serde.Bytes[message.Message] + func (repo AggregateRepository[ID, T]) Get(ctx context.Context, id ID) (T, error) + func (repo AggregateRepository[ID, T]) Save(ctx context.Context, root T) error + type EventStore struct + Conn *pgxpool.Pool + Serde serde.Bytes[message.Message] + 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 Other modules containing this package github.com/get-eventually/go-eventually
Go to main page