stream

Documentation

Index

• func NewDomainEventHandlers(publisher am.MessagePublisher[am.Message]) *domainHandler[ddd.Event]
• func NewIntegrationEventHandlers(messages MessagesController, log *logger.Logger) am.RawMessageHandler
• func RegisterDomainEventHandlers(subscriber ddd.EventSubscriber[ddd.Event], handler ddd.EventHandler[ddd.Event])
• func RegisterIntegrationEventHandlers(subscriber am.RawMessageSubscriber, handlers am.RawMessageHandler) (err error)
• type MessagesController

Functions

func NewDomainEventHandlers

func NewDomainEventHandlers(publisher am.MessagePublisher[am.Message]) *domainHandler[ddd.Event]

func NewIntegrationEventHandlers

func NewIntegrationEventHandlers(messages MessagesController, log *logger.Logger) am.RawMessageHandler

func RegisterDomainEventHandlers

func RegisterDomainEventHandlers(subscriber ddd.EventSubscriber[ddd.Event], handler ddd.EventHandler[ddd.Event])

func RegisterIntegrationEventHandlers

func RegisterIntegrationEventHandlers(subscriber am.RawMessageSubscriber, handlers am.RawMessageHandler) (err error)

Types

type MessagesController

type MessagesController interface {
	PrivateMessages(ctx context.Context, ids []int64, userID int64) error
	PublishMessages(ctx context.Context, ids []int64, userID int64) error
}