model

Documentation

Index

• Variables
• type AggregateStore
  • func NewAggregateStore(repo eh.ReadWriteRepo, eventHandler eh.EventHandler) (*AggregateStore, error)
  • func (r *AggregateStore) Load(ctx context.Context, aggregateType eh.AggregateType, id uuid.UUID) (eh.Aggregate, error)
  • func (r *AggregateStore) Save(ctx context.Context, aggregate eh.Aggregate) error
• type SliceEventSource
  • func (a *SliceEventSource) AppendEvent(e eh.Event)
  • func (a *SliceEventSource) ClearUncommittedEvents()
  • func (a *SliceEventSource) UncommittedEvents() []eh.Event

Variables

var (
	// ErrInvalidRepo is when a dispatcher is created with a nil repo.
	ErrInvalidRepo = errors.New("invalid repo")
	// ErrInvalidAggregate occurs when a loaded aggregate is not an aggregate.
	ErrInvalidAggregate = errors.New("invalid aggregate")
)

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, eventHandler eh.EventHandler) (*AggregateStore, error)

NewAggregateStore creates an aggregate store with a read write repo and an event handler that can handle any resulting events (for example by publishing them on an event bus).

func (*AggregateStore) Load

func (r *AggregateStore) Load(ctx context.Context, aggregateType eh.AggregateType, id uuid.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.

type SliceEventSource

type SliceEventSource []eh.Event

SliceEventSource is an eh.EventSource using a slice to store events.

func (*SliceEventSource) AppendEvent

func (a *SliceEventSource) AppendEvent(e eh.Event)

AppendEvent appends an event to be handled after the aggregate has been successfully saved.

func (*SliceEventSource) ClearUncommittedEvents

func (a *SliceEventSource) ClearUncommittedEvents()

ClearUncommittedEvents implements the ClearUncommittedEvents method of the eh.EventSource interface.

func (*SliceEventSource) UncommittedEvents

func (a *SliceEventSource) UncommittedEvents() []eh.Event

UncommittedEvents implements the UncommittedEvents method of the eh.EventSource interface.