es_postgres

Documentation

Index

• type Aggregates
• type Events
• type Store
  • func (s *Store) GetAggregateWithoutSnapshot(ctx context.Context) ([]*eventsourcing.BaseAggregate, error)
  • func (s *Store) Init(ctx context.Context, db *db.Store) error
  • func (s *Store) Load(ctx context.Context, aggregateID string) (*eventsourcing.Snapshot, []*eventsourcing.Event, error)
  • func (s *Store) SafeSave(ctx context.Context, events []*eventsourcing.Event) error
  • func (s *Store) Save(ctx context.Context, events []*eventsourcing.Event) error
  • func (s *Store) SaveSnapshot(ctx context.Context, snapshot *eventsourcing.Snapshot) error

Types

type Aggregates

type Aggregates interface {
	// contains filtered or unexported methods
}

type Events

type Events interface {
	// contains filtered or unexported methods
}

type Store

type Store struct {
	Aggregates
	Events
	// contains filtered or unexported fields
}

func (*Store) GetAggregateWithoutSnapshot

func (s *Store) GetAggregateWithoutSnapshot(ctx context.Context) ([]*eventsourcing.BaseAggregate, error)

GetAggregateWithoutSnapshot - get aggregates without a snapshot

func (*Store) Init

func (s *Store) Init(ctx context.Context, db *db.Store) error

func (*Store) Load

func (s *Store) Load(ctx context.Context, aggregateID string) (*eventsourcing.Snapshot, []*eventsourcing.Event, error)

func (*Store) SafeSave

func (s *Store) SafeSave(ctx context.Context, events []*eventsourcing.Event) error

func (*Store) Save

func (s *Store) Save(ctx context.Context, events []*eventsourcing.Event) error

func (*Store) SaveSnapshot

func (s *Store) SaveSnapshot(ctx context.Context, snapshot *eventsourcing.Snapshot) error