domain

Documentation

Index

• Constants
• func Setup(eventStore eh.EventStore, eventBus eh.EventBus, ...)
• type AcceptInvite
  • func (c AcceptInvite) AggregateID() eh.UUID
  • func (c AcceptInvite) AggregateType() eh.AggregateType
  • func (c AcceptInvite) CommandType() eh.CommandType
• type ConfirmInvite
  • func (c ConfirmInvite) AggregateID() eh.UUID
  • func (c ConfirmInvite) AggregateType() eh.AggregateType
  • func (c ConfirmInvite) CommandType() eh.CommandType
• type CreateInvite
  • func (c CreateInvite) AggregateID() eh.UUID
  • func (c CreateInvite) AggregateType() eh.AggregateType
  • func (c CreateInvite) CommandType() eh.CommandType
• type DeclineInvite
  • func (c DeclineInvite) AggregateID() eh.UUID
  • func (c DeclineInvite) AggregateType() eh.AggregateType
  • func (c DeclineInvite) CommandType() eh.CommandType
• type DenyInvite
  • func (c DenyInvite) AggregateID() eh.UUID
  • func (c DenyInvite) AggregateType() eh.AggregateType
  • func (c DenyInvite) CommandType() eh.CommandType
• type GuestList
  • func (g *GuestList) EntityID() eh.UUID
• type GuestListProjector
  • func NewGuestListProjector(repo eh.ReadWriteRepo, eventID eh.UUID) *GuestListProjector
  • func (p *GuestListProjector) HandleEvent(ctx context.Context, event eh.Event) error
  • func (p *GuestListProjector) HandlerType() eh.EventHandlerType
• type Invitation
  • func (i *Invitation) AggregateVersion() int
  • func (i *Invitation) EntityID() eh.UUID
• type InvitationAggregate
  • 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
  • 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
• type Logger
  • func (l *Logger) Notify(ctx context.Context, event eh.Event)
• type ResponseSaga
  • func NewResponseSaga(guestLimit int) *ResponseSaga
  • func (s *ResponseSaga) RunSaga(ctx context.Context, event eh.Event) []eh.Command
  • func (s *ResponseSaga) SagaType() saga.Type

Constants

const (
	CreateInviteCommand eh.CommandType = "CreateInvite"

	AcceptInviteCommand  eh.CommandType = "AcceptInvite"
	DeclineInviteCommand eh.CommandType = "DeclineInvite"

	ConfirmInviteCommand eh.CommandType = "ConfirmInvite"
	DenyInviteCommand    eh.CommandType = "DenyInvite"
)

const (
	// InviteCreatedEvent is when an invite is created.
	InviteCreatedEvent eh.EventType = "InviteCreated"

	// InviteAcceptedEvent is when an invite has been accepted by the guest.
	InviteAcceptedEvent eh.EventType = "InviteAccepted"
	// InviteDeclinedEvent is when an invite has been declined by the guest.
	InviteDeclinedEvent eh.EventType = "InviteDeclined"

	// InviteConfirmedEvent is when an invite has been cornfirmed as booked.
	InviteConfirmedEvent eh.EventType = "InviteConfirmed"
	// InviteDeniedEvent is when an invite has been declined to be booked.
	InviteDeniedEvent eh.EventType = "InviteDenied"
)

const InvitationAggregateType eh.AggregateType = "Invitation"

InvitationAggregateType is the type name of the aggregate.

const ResponseSagaType saga.Type = "ResponseSaga"

ResponseSagaType is the type of the saga.

Functions

func Setup

func Setup(
	eventStore eh.EventStore,
	eventBus eh.EventBus,
	eventPublisher eh.EventPublisher,
	commandBus *bus.CommandHandler,
	invitationRepo, guestListRepo eh.ReadWriteRepo,
	eventID eh.UUID)

Setup configures the domain.

Types

type AcceptInvite

type AcceptInvite struct {
	ID eh.UUID
}

AcceptInvite is a command for accepting invites.

func (AcceptInvite) AggregateID

func (c AcceptInvite) AggregateID() eh.UUID

func (AcceptInvite) AggregateType

func (c AcceptInvite) AggregateType() eh.AggregateType

func (AcceptInvite) CommandType

func (c AcceptInvite) CommandType() eh.CommandType

type ConfirmInvite

type ConfirmInvite struct {
	ID eh.UUID
}

ConfirmInvite is a command for confirming invites.

func (ConfirmInvite) AggregateID

func (c ConfirmInvite) AggregateID() eh.UUID

func (ConfirmInvite) AggregateType

func (c ConfirmInvite) AggregateType() eh.AggregateType

func (ConfirmInvite) CommandType

func (c ConfirmInvite) CommandType() eh.CommandType

type CreateInvite

type CreateInvite struct {
	ID   eh.UUID
	Name string
	Age  int `eh:"optional"`
}

CreateInvite is a command for creating invites.

func (CreateInvite) AggregateID

func (c CreateInvite) AggregateID() eh.UUID

func (CreateInvite) AggregateType

func (c CreateInvite) AggregateType() eh.AggregateType

func (CreateInvite) CommandType

func (c CreateInvite) CommandType() eh.CommandType

type DeclineInvite

type DeclineInvite struct {
	ID eh.UUID
}

DeclineInvite is a command for declining invites.

func (DeclineInvite) AggregateID

func (c DeclineInvite) AggregateID() eh.UUID

func (DeclineInvite) AggregateType

func (c DeclineInvite) AggregateType() eh.AggregateType

func (DeclineInvite) CommandType

func (c DeclineInvite) CommandType() eh.CommandType

type DenyInvite

type DenyInvite struct {
	ID eh.UUID
}

DenyInvite is a command for confirming invites.

func (DenyInvite) AggregateID

func (c DenyInvite) AggregateID() eh.UUID

func (DenyInvite) AggregateType

func (c DenyInvite) AggregateType() eh.AggregateType

func (DenyInvite) CommandType

func (c DenyInvite) CommandType() eh.CommandType

type GuestList

type GuestList struct {
	ID           eh.UUID `bson:"_id"`
	NumGuests    int
	NumAccepted  int
	NumDeclined  int
	NumConfirmed int
	NumDenied    int
}

GuestList is a read model object for the guest list.

func (*GuestList) EntityID

func (g *GuestList) EntityID() eh.UUID

EntityID implements the EntityID method of the eventhorizon.Entity interface.

type GuestListProjector

type GuestListProjector struct {
	// contains filtered or unexported fields
}

GuestListProjector is a projector that updates the guest list. It is implemented as a manual projector, not using the Projector interface.

func NewGuestListProjector

func NewGuestListProjector(repo eh.ReadWriteRepo, eventID eh.UUID) *GuestListProjector

NewGuestListProjector creates a new GuestListProjector.

func (*GuestListProjector) HandleEvent

func (p *GuestListProjector) HandleEvent(ctx context.Context, event eh.Event) error

HandleEvent implements the HandleEvent method of the EventHandler interface.

func (*GuestListProjector) HandlerType

func (p *GuestListProjector) HandlerType() eh.EventHandlerType

HandlerType implements the HandlerType method of the EventHandler interface.

type Invitation

type Invitation struct {
	ID      eh.UUID `bson:"_id"`
	Version int
	Name    string
	Age     int
	Status  string
}

Invitation is a read model object for an invitation.

func (*Invitation) AggregateVersion

func (i *Invitation) AggregateVersion() int

AggregateVersion implements the AggregateVersion method of the eventhorizon.Versionable interface.

func (*Invitation) EntityID

func (i *Invitation) EntityID() eh.UUID

EntityID implements the EntityID method of the eventhorizon.Entity interface.

type InvitationAggregate

type InvitationAggregate struct {
	// AggregateBase implements most of the eventhorizon.Aggregate interface.
	*events.AggregateBase
	// contains filtered or unexported fields
}

InvitationAggregate is the root aggregate.

The aggregate root will guard that the invitation can only be accepted OR declined, but not both.

func NewInvitationAggregate

func NewInvitationAggregate(id eh.UUID) *InvitationAggregate

NewInvitationAggregate creates a new InvitationAggregate with an ID.

func (*InvitationAggregate) ApplyEvent

func (a *InvitationAggregate) ApplyEvent(ctx context.Context, event eh.Event) error

ApplyEvent implements the ApplyEvent method of the Aggregate interface.

func (*InvitationAggregate) HandleCommand

func (a *InvitationAggregate) HandleCommand(ctx context.Context, cmd eh.Command) error

HandleCommand implements the HandleCommand method of the Aggregate interface.

type InvitationProjector

type InvitationProjector struct{}

InvitationProjector is a projector that updates the invitations.

func NewInvitationProjector

func NewInvitationProjector() *InvitationProjector

NewInvitationProjector creates a new InvitationProjector.

func (*InvitationProjector) Project

func (p *InvitationProjector) Project(ctx context.Context, event eh.Event, entity eh.Entity) (eh.Entity, error)

Project implements the Project method of the Projector interface.

func (*InvitationProjector) ProjectorType

func (p *InvitationProjector) ProjectorType() projector.Type

ProjectorType implements the ProjectorType method of the Projector interface.

type InviteCreatedData

type InviteCreatedData struct {
	Name string `bson:"name"`
	Age  int    `bson:"age"`
}

InviteCreatedData is the event data for when an invite has been created.

type Logger

type Logger struct{}

Logger is a simple event handler for logging all events.

func (*Logger) Notify

func (l *Logger) Notify(ctx context.Context, event eh.Event)

Notify implements the Notify method of the EventObserver interface.

type ResponseSaga

type ResponseSaga struct {
	// contains filtered or unexported fields
}

ResponseSaga is a saga that confirmes all accepted invites until a guest limit has been reached.

func NewResponseSaga

func NewResponseSaga(guestLimit int) *ResponseSaga

NewResponseSaga returns a new ResponseSage with a guest limit.

func (*ResponseSaga) RunSaga

func (s *ResponseSaga) RunSaga(ctx context.Context, event eh.Event) []eh.Command

RunSaga implements the Run saga method of the Saga interface.

func (*ResponseSaga) SagaType

func (s *ResponseSaga) SagaType() saga.Type

SagaType implements the SagaType method of the Saga interface.