aggstore

Documentation

Index

• type AggregateStore
  • func NewStore(eventStore cqrs.EventStore, aggregateFactory cqrs.AggregateFactory) *AggregateStore
  • func (s *AggregateStore) Load(aggregateID cqrs.Identifier, aggregateType string) (cqrs.AdvancedAggregate, error)
  • func (s *AggregateStore) Store(agg cqrs.AdvancedAggregate, events ...cqrs.DomainEvent) error

Types

type AggregateStore

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

AggregateStore loads and stores aggregates.

func NewStore

func NewStore(eventStore cqrs.EventStore, aggregateFactory cqrs.AggregateFactory) *AggregateStore

NewStore creates a new instance of AggregateStore.

func (*AggregateStore) Load

func (s *AggregateStore) Load(aggregateID cqrs.Identifier, aggregateType string) (cqrs.AdvancedAggregate, error)

Load implements cqrs.AggregateStore interface.

func (*AggregateStore) Store

func (s *AggregateStore) Store(agg cqrs.AdvancedAggregate, events ...cqrs.DomainEvent) error

Store implements cqrs.AggregateStore interface.