Versions in this module Expand all Collapse all v0 v0.0.1 Feb 2, 2025 Changes in this version + var ErrHandlerAlreadyRegistered = errors.New("handler already registered") + type BaseEvent struct + AggregateID string + AggregateType string + Data interface{} + ID string + Metadata map[string]string + Timestamp time.Time + Type string + Version int + func (e BaseEvent) GetAggregateID() string + func (e BaseEvent) GetAggregateType() string + func (e BaseEvent) GetData() interface{} + func (e BaseEvent) GetID() string + func (e BaseEvent) GetMetadata() map[string]string + func (e BaseEvent) GetTimestamp() time.Time + func (e BaseEvent) GetType() string + func (e BaseEvent) GetVersion() int + type DomainEventDispatcher struct + func NewEventDispatcher() *DomainEventDispatcher + func (ed *DomainEventDispatcher) Clear() + func (ed *DomainEventDispatcher) Dispatch(ctx context.Context, event Event) error + func (ed *DomainEventDispatcher) Has(eventName string, handler EventHandler) bool + func (ed *DomainEventDispatcher) Register(eventName string, handler EventHandler) error + func (ed *DomainEventDispatcher) Remove(eventName string, handler EventHandler) error + type Event interface + GetAggregateID func() string + GetAggregateType func() string + GetData func() interface{} + GetID func() string + GetMetadata func() map[string]string + GetTimestamp func() time.Time + GetType func() string + GetVersion func() int + type EventDispatcher interface + Clear func() + Dispatch func(ctx context.Context, event Event) error + Has func(eventName string, handler EventHandler) bool + Register func(eventName string, handler EventHandler) error + Remove func(eventName string, handler EventHandler) error + type EventHandler interface + Handle func(ctx context.Context, event Event, wg *sync.WaitGroup) + type MockEventHandler struct + Called chan bool + func NewMockEventHandler() *MockEventHandler + func (m *MockEventHandler) Handle(ctx context.Context, event Event, wg *sync.WaitGroup)
Go to main page