Versions in this module Expand all Collapse all v2 v2.1.0 Sep 15, 2022 v2.0.0 Sep 14, 2021 Changes in this version + var ErrNoCreateTableQueries = errors.New("goengine: create table queries are not provided") + var ErrTableAlreadyExists = errors.New("goengine: table already exists") + var ErrTableNameEmpty = errors.New("goengine: table name could not be empty") + func QuoteIdentifier(name string) string + func QuoteString(str string) string + type AdvisoryLockAggregateProjectionStorage struct + func NewAdvisoryLockAggregateProjectionStorage(eventStoreTable, projectionTable string, ...) (*AdvisoryLockAggregateProjectionStorage, error) + func (a *AdvisoryLockAggregateProjectionStorage) Acquire(ctx context.Context, conn *sql.Conn, ...) (driverSQL.ProjectorTransaction, int64, error) + func (a *AdvisoryLockAggregateProjectionStorage) LoadOutOfSync(ctx context.Context, conn driverSQL.Queryer) (*sql.Rows, error) + func (a *AdvisoryLockAggregateProjectionStorage) PersistFailure(conn driverSQL.Execer, notification *driverSQL.ProjectionNotification) error + type AdvisoryLockStreamProjectionStorage struct + func NewAdvisoryLockStreamProjectionStorage(projectionName, projectionTable string, ...) (*AdvisoryLockStreamProjectionStorage, error) + func (s *AdvisoryLockStreamProjectionStorage) Acquire(ctx context.Context, conn *sql.Conn, ...) (driverSQL.ProjectorTransaction, int64, error) + func (s *AdvisoryLockStreamProjectionStorage) CreateProjection(ctx context.Context, conn driverSQL.Execer) error + type ConjoinedEventStore struct + func NewConjoinedEventStore(eventstore *EventStore, resolver goengine.MessagePayloadResolver, ...) (*ConjoinedEventStore, error) + func (e *ConjoinedEventStore) AppendTo(ctx context.Context, streamName goengine.StreamName, ...) error + type ConjoinedMessageHandler func(ctx context.Context, tx *sql.Tx, message goengine.Message) error + type EventStore struct + func NewEventStore(persistenceStrategy driverSQL.PersistenceStrategy, db *sql.DB, ...) (*EventStore, error) + func (e *EventStore) AppendTo(ctx context.Context, streamName goengine.StreamName, ...) error + func (e *EventStore) AppendToWithExecer(ctx context.Context, conn driverSQL.Execer, streamName goengine.StreamName, ...) error + func (e *EventStore) Create(ctx context.Context, streamName goengine.StreamName) error + func (e *EventStore) HasStream(ctx context.Context, streamName goengine.StreamName) bool + func (e *EventStore) Load(ctx context.Context, streamName goengine.StreamName, fromNumber int64, ...) (goengine.EventStream, error) + func (e *EventStore) LoadWithConnection(ctx context.Context, conn driverSQL.Queryer, streamName goengine.StreamName, ...) (goengine.EventStream, error) Other modules containing this package github.com/hellofresh/goengine
Go to main page