eventing

Documentation

Index

• Constants
• func CreateEventMail(data *EventData) messaging.Mail[EventData]
• type DefaultEventDispatcher
  • func (ed *DefaultEventDispatcher) AddProxy(proxies ...EventHandlerProxy)
  • func (ed *DefaultEventDispatcher) Dispatch(data *domain.EventStream)
  • func (ed *DefaultEventDispatcher) Initialize(mailboxProvider messaging.MailboxProvider[EventData], ...) *DefaultEventDispatcher
  • func (ed *DefaultEventDispatcher) Subscribe(eventTypeName string, handler EventHandler)
  • func (ed *DefaultEventDispatcher) SubscribeMulti(handlerGroup EventHandlerGroup)
• type EventBus
• type EventData
  • func (data *EventData) SetCustomExtension(ctx context.Context, key string, val string)
• type EventDispatcher
• type EventHandleFunc
• type EventHandler
• type EventHandlerGroup
• type EventHandlerProxy
• type EventProcessor

Constants

const CommandHandleResultProvider string = "eventing.dispatcher"

const MailCategory string = "event"

Functions

func CreateEventMail

func CreateEventMail(data *EventData) messaging.Mail[EventData]

Types

type DefaultEventDispatcher

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

func (*DefaultEventDispatcher) AddProxy

func (ed *DefaultEventDispatcher) AddProxy(proxies ...EventHandlerProxy)

func (*DefaultEventDispatcher) Dispatch

func (ed *DefaultEventDispatcher) Dispatch(data *domain.EventStream)

func (*DefaultEventDispatcher) Initialize

func (ed *DefaultEventDispatcher) Initialize(mailboxProvider messaging.MailboxProvider[EventData], notifier messaging.MessageHandleResultNotifier) *DefaultEventDispatcher

func (*DefaultEventDispatcher) Subscribe

func (ed *DefaultEventDispatcher) Subscribe(eventTypeName string, handler EventHandler)

func (*DefaultEventDispatcher) SubscribeMulti

func (ed *DefaultEventDispatcher) SubscribeMulti(handlerGroup EventHandlerGroup)

type EventBus

type EventBus interface {
	Publish(es domain.EventStream) error
}

type EventData

type EventData struct {
	domain.DomainEvent
	AggregateID   string
	AggregateType string
	StreamVersion int
	CommandID     string
	CommandType   string
	Extensions    map[string]string
}

func (*EventData) SetCustomExtension

func (data *EventData) SetCustomExtension(ctx context.Context, key string, val string)

type EventDispatcher

type EventDispatcher interface {
	Subscribe(eventTypeName string, handler EventHandler)
	SubscribeMulti(handlerGroup EventHandlerGroup)
	AddProxy(proxies ...EventHandlerProxy)
	Dispatch(data *domain.EventStream)
}

type EventHandleFunc

type EventHandleFunc = messaging.MessageHandleFunc[EventData]

type EventHandler

type EventHandler messaging.MessageHandler[EventData]

type EventHandlerGroup

type EventHandlerGroup interface {
	EventHandlers() map[string]EventHandler
}

type EventHandlerProxy

type EventHandlerProxy messaging.MessageHandlerProxy[EventData]

type EventProcessor

type EventProcessor interface {
	Start()
	Stop()
}