Versions in this module Expand all Collapse all v0 v0.0.1 Apr 16, 2026 Changes in this version + func IsUniqueViolation(err error) bool + type Store struct + func NewStore(config *StoreConfig) *Store + func (s *Store) Append(ctx context.Context, tx *sql.Tx, expectedVersion store.ExpectedVersion, ...) (store.AppendResult, error) + func (s *Store) GetLatestGlobalPosition(ctx context.Context, tx *sql.Tx) (int64, error) + func (s *Store) ReadAggregateStream(ctx context.Context, tx *sql.Tx, aggregateType, aggregateID string, ...) (store.Stream, error) + func (s *Store) ReadEvents(ctx context.Context, tx *sql.Tx, fromPosition int64, limit int) ([]store.PersistedEvent, error) + type StoreConfig struct + AggregateHeadsTable string + EventsTable string + Logger store.Logger + NotifyChannel string + func DefaultStoreConfig() *StoreConfig + func NewStoreConfig(opts ...StoreOption) *StoreConfig + type StoreOption func(*StoreConfig) + func WithAggregateHeadsTable(tableName string) StoreOption + func WithEventsTable(tableName string) StoreOption + func WithLogger(logger store.Logger) StoreOption + func WithNotifyChannel(channel string) StoreOption
Go to main page