cqrs

Documentation

Index

• func New(store rangedb.Store, options ...Option) *cqrs
• type Aggregate
• type Command
• type CommandDispatcher
• type Option
  • func WithAggregates(aggregates ...Aggregate) Option
  • func WithLogger(logger *log.Logger) Option

Functions

func New

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

New constructs an event sourced CQRS application

Types

type Aggregate

type Aggregate interface {
	Load(<-chan *rangedb.Record)
	Handle(Command) []rangedb.Event
	CommandTypes() []string
}

type Command

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

type CommandDispatcher

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

type Option

type Option func(*cqrs)

Option defines functional option parameters for App.

func WithAggregates

func WithAggregates(aggregates ...Aggregate) Option

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

func WithLogger

func WithLogger(logger *log.Logger) Option

WithLogger is a functional option to inject a Logger.