pgstore

Documentation

Index

• type Postgres
  • func New(options *pg.Options, logger logrus.FieldLogger) *Postgres
  • func (p *Postgres) Load(ctx context.Context, aggregateID string, fromVersion, toVersion int) (eventsourcing.History, eventsourcing.Error)
  • func (p *Postgres) Save(ctx context.Context, aggregateID string, records ...eventsourcing.Record) eventsourcing.Error

Types

type Postgres

type Postgres struct {
	// contains filtered or unexported fields
}

Postgres provides a Postgres backed store

func New

func New(options *pg.Options, logger logrus.FieldLogger) *Postgres

New returns a Postgres backed store

func (*Postgres) Load

func (p *Postgres) Load(ctx context.Context, aggregateID string, fromVersion, toVersion int) (eventsourcing.History, eventsourcing.Error)

Load implements the Store interface and retrieve events from Postgres

func (*Postgres) Save

func (p *Postgres) Save(ctx context.Context, aggregateID string, records ...eventsourcing.Record) eventsourcing.Error

Save implements the Store interface and saves records, serialized events, in Postgres