ddd

Documentation

Index

• type Aggregate
• type AggregateBase
  • func (a *AggregateBase) AddEvent(event Event)
  • func (a AggregateBase) GetEvents() []Event
  • func (a AggregateBase) GetID() string
• type Entity
• type EntityBase
  • func (e EntityBase) GetID() string
• type Event
• type EventDispatcher
  • func NewEventDispatcher() *EventDispatcher
  • func (h *EventDispatcher) Publish(ctx context.Context, events ...Event) error
  • func (h *EventDispatcher) Subscribe(event Event, handler EventHandler)
• type EventHandler
• type EventPublisher
• type EventSubscriber

Types

type Aggregate

type Aggregate interface {
	Entity
	AddEvent(event Event)
	GetEvents() []Event
}

type AggregateBase

type AggregateBase struct {
	ID string
	// contains filtered or unexported fields
}

func (*AggregateBase) AddEvent

func (a *AggregateBase) AddEvent(event Event)

func (AggregateBase) GetEvents

func (a AggregateBase) GetEvents() []Event

func (AggregateBase) GetID

func (a AggregateBase) GetID() string

type Entity

type Entity interface {
	GetID() string
}

type EntityBase

type EntityBase struct {
	ID string
}

func (EntityBase) GetID

func (e EntityBase) GetID() string

type Event

type Event interface {
	EventName() string
}

type EventDispatcher

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

func NewEventDispatcher

func NewEventDispatcher() *EventDispatcher

func (*EventDispatcher) Publish

func (h *EventDispatcher) Publish(ctx context.Context, events ...Event) error

func (*EventDispatcher) Subscribe

func (h *EventDispatcher) Subscribe(event Event, handler EventHandler)

type EventHandler

type EventHandler func(ctx context.Context, event Event) error

type EventPublisher

type EventPublisher interface {
	Publish(ctx context.Context, events ...Event) error
}

type EventSubscriber

type EventSubscriber interface {
	Subscribe(event Event, handler EventHandler)
}