setup

Mar 24, 2020

Changes in this version

type Option

+ func WithSnapshotConfig(cfg aggregate.SnapshotConfig) Option

Mar 24, 2020

Changes in this version

type Option

+ func Logger(logger *log.Logger) Option

+ func WithAggregateConfig(cfg cqrs.AggregateConfig) Option

+ func WithEventConfig(cfg cqrs.EventConfig) Option

type Setup

+ func (s *Setup) Command(h cqrs.CommandHandler, types ...cqrs.CommandType) *Setup

+ func (s *Setup) Container(ctx context.Context) (cqrs.Container, error)

Jan 6, 2020

Changes in this version

type Setup

+ AggregateRepositoryResolver func() func() (cqrs.AggregateRepository, bool)

+ CommandBusResolver func() func() (cqrs.CommandBus, bool)

+ EventBusResolver func() func() (cqrs.EventBus, bool)

+ EventPublisherResolver func() func() (cqrs.EventPublisher, bool)

+ EventStoreResolver func() func() (cqrs.EventStore, bool)

+ EventSubscriberResolver func() func() (cqrs.EventSubscriber, bool)

+ SnapshotRepositoryResolver func() func() (cqrs.SnapshotRepository, bool)

Jan 3, 2020

Changes in this version

+ func Aggregate(typ cqrs.AggregateType, factory cqrs.AggregateFactory)

+ func Event(typ cqrs.EventType, proto cqrs.EventData)

Jan 3, 2020

Changes in this version

+ func RegisterAggregate(typ cqrs.AggregateType, factory cqrs.AggregateFactory)

+ func RegisterEvent(typ cqrs.EventType, proto cqrs.EventData)

Dec 29, 2019

Changes in this version

+ func New(ctx context.Context, options ...Option) (cqrs.Container, error)

+ func NewWithConfigs(ctx context.Context, aggregateConfig cqrs.AggregateConfig, ...) (cqrs.Container, error)

+ type AggregateRepositoryFactory func(context.Context, Setup) (cqrs.AggregateRepository, error)

+ type CommandBusFactory func(context.Context, Setup) (cqrs.CommandBus, error)

+ type CommandHandlerFactory func(context.Context, Setup) (cqrs.CommandHandler, []cqrs.CommandType, error)

+ type EventBusFactory func(context.Context, Setup) (cqrs.EventBus, error)

+ type EventStoreFactory func(context.Context, Setup) (cqrs.EventStore, error)

+ type Option func(Setup)

+ func WithAggregate(typ cqrs.AggregateType, factory cqrs.AggregateFactory) Option

+ func WithAggregateRepositoryFactory(f AggregateRepositoryFactory) Option

+ func WithCommand(typ cqrs.CommandType, handler cqrs.CommandHandler) Option

+ func WithCommandBusFactory(f CommandBusFactory) Option

+ func WithCommandHandlerFactory(factories ...CommandHandlerFactory) Option

+ func WithEvent(typ cqrs.EventType, proto cqrs.EventData) Option

+ func WithEventBusFactory(f EventBusFactory) Option

+ func WithEventStoreFactory(f EventStoreFactory) Option

+ func WithLogger(logger *log.Logger) Option

+ func WithSnapshotRepositoryFactory(f SnapshotRepositoryFactory) Option

+ type Setup interface

+ AddCommandHandlerFactory func(...CommandHandlerFactory)

+ AggregateConfig func() cqrs.AggregateConfig

+ AggregateRepository func() cqrs.AggregateRepository

+ CommandBus func() cqrs.CommandBus

+ CommandConfig func() cqrs.CommandConfig

+ EventBus func() cqrs.EventBus

+ EventConfig func() cqrs.EventConfig

+ EventStore func() cqrs.EventStore

+ RegisterAggregate func(cqrs.AggregateType, cqrs.AggregateFactory)

+ RegisterCommand func(cqrs.CommandType, cqrs.CommandHandler)

+ RegisterEvent func(cqrs.EventType, cqrs.EventData)

+ SetAggregateRepositoryFactory func(AggregateRepositoryFactory)

+ SetCommandBusFactory func(CommandBusFactory)

+ SetEventBusFactory func(EventBusFactory)

+ SetEventStoreFactory func(EventStoreFactory)

+ SetLogger func(*log.Logger)

+ SetSnapshotRepositoryFactory func(SnapshotRepositoryFactory)

+ SnapshotRepository func() cqrs.SnapshotRepository

+ type SnapshotRepositoryFactory func(context.Context, Setup) (cqrs.SnapshotRepository, error)