Documentation
¶
Index ¶
- func NewCommandHandlers(reg registry.Registry, app application.App, replyPublisher am.ReplyPublisher, ...) am.MessageHandler
- func NewDomainEventHandlers(publisher am.EventPublisher) ddd.EventHandler[ddd.AggregateEvent]
- func NewIntegrationEventHandlers(reg registry.Registry, stores domain.StoreCacheRepository, ...) am.MessageHandler
- func RegisterCommandHandlers(subscriber am.MessageSubscriber, handlers am.MessageHandler) error
- func RegisterCommandHandlersTx(container di.Container) error
- func RegisterDomainEventHandlers(subscriber ddd.EventSubscriber[ddd.AggregateEvent], ...)
- func RegisterDomainEventHandlersTx(container di.Container)
- func RegisterIntegrationEventHandlers(subscriber am.MessageSubscriber, handlers am.MessageHandler) (err error)
- func RegisterIntegrationEventHandlersTx(container di.Container) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCommandHandlers ¶
func NewCommandHandlers(reg registry.Registry, app application.App, replyPublisher am.ReplyPublisher, mws ...am.MessageHandlerMiddleware) am.MessageHandler
func NewDomainEventHandlers ¶
func NewDomainEventHandlers(publisher am.EventPublisher) ddd.EventHandler[ddd.AggregateEvent]
func NewIntegrationEventHandlers ¶
func NewIntegrationEventHandlers(reg registry.Registry, stores domain.StoreCacheRepository, products domain.ProductCacheRepository, mws ...am.MessageHandlerMiddleware) am.MessageHandler
func RegisterCommandHandlers ¶
func RegisterCommandHandlers(subscriber am.MessageSubscriber, handlers am.MessageHandler) error
func RegisterDomainEventHandlers ¶
func RegisterDomainEventHandlers(subscriber ddd.EventSubscriber[ddd.AggregateEvent], handlers ddd.EventHandler[ddd.AggregateEvent])
func RegisterIntegrationEventHandlers ¶
func RegisterIntegrationEventHandlers(subscriber am.MessageSubscriber, handlers am.MessageHandler) (err error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.