model

Documentation

Index

• Variables
• type AggregateStore
  • func NewAggregateStore(repo eh.ReadWriteRepo) (*AggregateStore, error)
  • func (r *AggregateStore) Load(ctx context.Context, aggregateType eh.AggregateType, id eh.UUID) (eh.Aggregate, error)
  • func (r *AggregateStore) Save(ctx context.Context, aggregate eh.Aggregate) error

Variables

var ErrInvalidAggregate = errors.New("invalid aggregate")

ErrInvalidAggregate occurs when a loaded aggregate is not an aggregate.

var ErrInvalidRepo = errors.New("invalid repo")

ErrInvalidRepo is when a dispatcher is created with a nil repo.

Types

type AggregateStore

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

AggregateStore is an aggregate store that uses a read write repo for loading and saving aggregates.

func NewAggregateStore

func NewAggregateStore(repo eh.ReadWriteRepo) (*AggregateStore, error)

NewAggregateStore creates an aggregate store with a read write repo.

func (*AggregateStore) Load

func (r *AggregateStore) Load(ctx context.Context, aggregateType eh.AggregateType, id eh.UUID) (eh.Aggregate, error)

Load implements the Load method of the eventhorizon.AggregateStore interface.

func (*AggregateStore) Save

func (r *AggregateStore) Save(ctx context.Context, aggregate eh.Aggregate) error

Save implements the Save method of the eventhorizon.AggregateStore interface.