cqrs

package

v0.7.2 Latest Latest Go to latest Published: Jan 26, 2021 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func New(store rangedb.Store, options ...Option) *cqrs

New constructs an event sourced CQRS application

type Aggregate interface {
	Load(rangedb.RecordIterator)
	Handle(Command) []rangedb.Event
	CommandTypes() []string
}

Aggregate defines the interface for a CQRS aggregate, or Unit of Certainty.

type Command interface {
	rangedb.AggregateMessage
	CommandType() string
}

Command defines a CQRS command.

type CommandDispatcher interface {
	Dispatch(Command) []rangedb.Event
}

CommandDispatcher defines the interface for dispatching a cqrs.Command.

type Option func(*cqrs)

Option defines functional option parameters for App.

func WithAggregates(aggregates ...Aggregate) Option

WithAggregates is a functional option to inject an aggregate command handler.

func WithLogger(logger *log.Logger) Option

WithLogger is a functional option to inject a Logger.