async

func NewCommandPublisher ¶

func NewCommandPublisher(reg registry.Registry, publisher MessagePublisher, msw ...MessagePublisherMiddleware) CommandPublisher

func NewEventPublisher ¶

func NewEventPublisher(reg registry.Registry, msgPublisher MessagePublisher, mws ...MessagePublisherMiddleware) EventPublisher

func MessageHandlerWithMiddleware ¶

func MessageHandlerWithMiddleware(handler MessageHandler, mws ...MessageHandlerMiddleware) MessageHandler

MessageHandlerWithMiddleware builds a applyMiddleware chain around a handler

Middleware are applied in reverse; this makes the first applyMiddleware in the slice the outermost i.e. first to enter, last to exit given: handler, A, B, C result: A(B(C(handler)))

func NewCommandHandler ¶

func NewCommandHandler(reg registry.Registry, publisher ReplyPublisher, handler ddd.CommandHandler[ddd.Command], msw ...MessageHandlerMiddleware) MessageHandler

func NewEventHandler ¶

func NewEventHandler(reg registry.Registry, handler ddd.EventHandler[ddd.Event], mws ...MessageHandlerMiddleware) MessageHandler

func NewReplyHandler ¶

func NewReplyHandler(reg registry.Registry, handler ddd.ReplyHandler[ddd.Reply], mws ...MessageHandlerMiddleware) MessageHandler

func MessagePublisherWithMiddleware ¶

func MessagePublisherWithMiddleware(publisher MessagePublisher, mws ...MessagePublisherMiddleware) MessagePublisher

MessagePublisherWithMiddleware builds a applyMiddleware chain around a publisher

Middleware are applied in reverse; this makes the first applyMiddleware in the slice the outermost i.e. first to enter, last to exit given: publisher, A, B, C result: A(B(C(publisher)))

func NewMessagePublisher ¶

func NewMessagePublisher(publisher MessagePublisher, mws ...MessagePublisherMiddleware) MessagePublisher

func MessageStreamWithMiddleware ¶

func MessageStreamWithMiddleware(stream MessageStream, mws ...MessageStreamMiddleware) MessageStream

MessageStreamWithMiddleware builds a applyMiddleware chain around a stream

Middleware are applied in reverse; this makes the first applyMiddleware in the slice the outermost i.e. first to enter, last to exit given: stream, A, B, C result: A(B(C(stream)))

func NewMessageSubscriber ¶

func NewMessageSubscriber(subscriber MessageSubscriber, mws ...MessageHandlerMiddleware) MessageSubscriber

func NewMockCommandPublisher ¶

func NewMockCommandPublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockCommandPublisher

NewMockCommandPublisher creates a new instance of MockCommandPublisher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func NewMockEventPublisher ¶

func NewMockEventPublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockEventPublisher

NewMockEventPublisher creates a new instance of MockEventPublisher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func NewMockMessageHandler ¶

func NewMockMessageHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockMessageHandler

NewMockMessageHandler creates a new instance of MockMessageHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func NewMockMessagePublisher ¶

func NewMockMessagePublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockMessagePublisher

NewMockMessagePublisher creates a new instance of MockMessagePublisher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func NewMockMessageSubscriber ¶

func NewMockMessageSubscriber(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockMessageSubscriber

NewMockMessageSubscriber creates a new instance of MockMessageSubscriber. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func NewMockReplyPublisher ¶

func NewMockReplyPublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockReplyPublisher

NewMockReplyPublisher creates a new instance of MockReplyPublisher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func NewReplyPublisher ¶

func NewReplyPublisher(reg registry.Registry, msgPublisher MessagePublisher, mws ...MessagePublisherMiddleware) ReplyPublisher

func NewSubscriberConfig ¶

func NewSubscriberConfig(options []SubscriberOption) SubscriberConfig