Versions in this module Expand all Collapse all v0 v0.2.0 Mar 21, 2018 v0.1.0 Mar 21, 2018 Changes in this version + const AcceptInviteCommand + const ConfirmInviteCommand + const CreateInviteCommand + const DeclineInviteCommand + const DenyInviteCommand + const InvitationAggregateType + const InviteAcceptedEvent + const InviteConfirmedEvent + const InviteCreatedEvent + const InviteDeclinedEvent + const InviteDeniedEvent + const ResponseSagaType + func LoggingMiddleware(h eh.CommandHandler) eh.CommandHandler + func Setup(eventStore eh.EventStore, eventBus eh.EventBus, commandBus *bus.CommandHandler, ...) + type AcceptInvite struct + ID eh.UUID + func (c AcceptInvite) AggregateID() eh.UUID + func (c AcceptInvite) AggregateType() eh.AggregateType + func (c AcceptInvite) CommandType() eh.CommandType + type ConfirmInvite struct + ID eh.UUID + func (c ConfirmInvite) AggregateID() eh.UUID + func (c ConfirmInvite) AggregateType() eh.AggregateType + func (c ConfirmInvite) CommandType() eh.CommandType + type CreateInvite struct + Age int + ID eh.UUID + Name string + func (c CreateInvite) AggregateID() eh.UUID + func (c CreateInvite) AggregateType() eh.AggregateType + func (c CreateInvite) CommandType() eh.CommandType + type DeclineInvite struct + ID eh.UUID + func (c DeclineInvite) AggregateID() eh.UUID + func (c DeclineInvite) AggregateType() eh.AggregateType + func (c DeclineInvite) CommandType() eh.CommandType + type DenyInvite struct + ID eh.UUID + func (c DenyInvite) AggregateID() eh.UUID + func (c DenyInvite) AggregateType() eh.AggregateType + func (c DenyInvite) CommandType() eh.CommandType + type GuestList struct + ID eh.UUID + NumAccepted int + NumConfirmed int + NumDeclined int + NumDenied int + NumGuests int + func (g *GuestList) EntityID() eh.UUID + type GuestListProjector struct + func NewGuestListProjector(repo eh.ReadWriteRepo, eventID eh.UUID) *GuestListProjector + func (p *GuestListProjector) HandleEvent(ctx context.Context, event eh.Event) error + type Invitation struct + Age int + ID eh.UUID + Name string + Status string + Version int + func (i *Invitation) AggregateVersion() int + func (i *Invitation) EntityID() eh.UUID + type InvitationAggregate struct + func NewInvitationAggregate(id eh.UUID) *InvitationAggregate + func (a *InvitationAggregate) ApplyEvent(ctx context.Context, event eh.Event) error + func (a *InvitationAggregate) HandleCommand(ctx context.Context, cmd eh.Command) error + type InvitationProjector struct + func NewInvitationProjector() *InvitationProjector + func (p *InvitationProjector) Project(ctx context.Context, event eh.Event, entity eh.Entity) (eh.Entity, error) + func (p *InvitationProjector) ProjectorType() projector.Type + type InviteCreatedData struct + Age int + Name string + type Logger struct + func (l *Logger) Notify(ctx context.Context, event eh.Event) + type ResponseSaga struct + func NewResponseSaga(guestLimit int) *ResponseSaga + func (s *ResponseSaga) RunSaga(ctx context.Context, event eh.Event) []eh.Command + func (s *ResponseSaga) SagaType() saga.Type