postgres

Documentation

Index

• func NewSnapshotStore(tableName string, db *sql.DB, registry registry.Registry) es.AggregateStoreMiddleware
• type EventStore
  • func NewEventStore(tableName string, db *sql.DB, registry registry.Registry) EventStore
  • func (s EventStore) Load(ctx context.Context, aggregate es.EventSourcedAggregate) (err error)
  • func (s EventStore) Save(ctx context.Context, aggregate es.EventSourcedAggregate) (err error)
• type SnapshotStore
  • func (s SnapshotStore) Load(ctx context.Context, aggregate es.EventSourcedAggregate) error
  • func (s SnapshotStore) Save(ctx context.Context, aggregate es.EventSourcedAggregate) error

Functions

func NewSnapshotStore

func NewSnapshotStore(tableName string, db *sql.DB, registry registry.Registry) es.AggregateStoreMiddleware

Types

type EventStore

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

func NewEventStore

func NewEventStore(tableName string, db *sql.DB, registry registry.Registry) EventStore

func (EventStore) Load

func (s EventStore) Load(ctx context.Context, aggregate es.EventSourcedAggregate) (err error)

func (EventStore) Save

func (s EventStore) Save(ctx context.Context, aggregate es.EventSourcedAggregate) (err error)

type SnapshotStore

type SnapshotStore struct {
	es.AggregateStore
	// contains filtered or unexported fields
}

func (SnapshotStore) Load

func (s SnapshotStore) Load(ctx context.Context, aggregate es.EventSourcedAggregate) error

func (SnapshotStore) Save

func (s SnapshotStore) Save(ctx context.Context, aggregate es.EventSourcedAggregate) error