Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

postgres

package

Go to main page

Versions in this module

v0

v0.11.0

Aug 25, 2021

v0.10.0

Sep 4, 2019

v0.9.0

Mar 1, 2019

Changes in this version

+ type AggregateProjector struct

+ func NewAggregateProjector(db *sql.DB, eventStore driverSQL.ReadOnlyEventStore, eventStoreTable string, ...) (*AggregateProjector, error)

+ func (a *AggregateProjector) Run(ctx context.Context) error

+ func (a *AggregateProjector) RunAndListen(ctx context.Context, listener driverSQL.Listener) error

+ type StreamProjector struct

+ func NewStreamProjector(db *sql.DB, eventStore driverSQL.ReadOnlyEventStore, ...) (*StreamProjector, error)

+ func (s *StreamProjector) Run(ctx context.Context) error

+ func (s *StreamProjector) RunAndListen(ctx context.Context, listener driverSQL.Listener) error

v0.3.5

Aug 26, 2020

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/v2