# Functions
FailureReply wraps a reply and returns it as a Failure reply Deprecated: Use the WithReply() reply builder.
NewCommandDispatcher constructs a new CommandDispatcher.
NewEntityEventDispatcher constructs a new EntityEventDispatcher.
NewEventDispatcher constructs a new EventDispatcher.
NewMessage message constructor.
NewPublisher constructs a new Publisher.
NewReply constructs a new reply with headers.
NewSubscriber constructs a new Subscriber.
RegisterTypes should be called after registering a new marshaller; especially after registering a new default.
SuccessReply wraps a reply and returns it as a Success reply Deprecated: Use the WithReply() reply builder.
WithAggregateInfo is an option to set additional Aggregate specific headers.
WithCommandDispatcherLogger is an option to set the log.Logger of the CommandDispatcher.
WithDestinationChannel is and option to set the destination of the outgoing Message
This will override the previous value set by interface { DestinationChannel() string }.
WithEntityEventDispatcherLogger is an option to set the log.Logger of the EntityEventDispatcher.
WithEventDispatcherLogger is an option to set the log.Logger of the EventDispatcher.
WithFailure returns a generic Failure reply.
WithHeaders is an option to set additional headers onto the Message.
WithMessageID is an option to set the ID of the Message.
WithPublisherLogger is an option to set the log.Logger of the Publisher.
WithReply starts a reply builder allowing custom headers to be injected.
WithSubscriberLogger is an option to set the log.Logger of the Subscriber.
WithSuccess returns a generic Success reply.
# Constants
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Message header keys.
Reply outcomes.
Reply outcomes.
# Structs
CommandDispatcher is a MessageReceiver for Commands.
EntityEventDispatcher is a MessageReceiver for DomainEvents.
EventDispatcher is a MessageReceiver for Events.
Failure reply type for generic failure replies to commands.
Publisher send domain events, commands, and replies to the publisher.
ReplyBuilder is used to build custom replies.
Subscriber receives domain events, commands, and replies from the consumer.
Success reply type for generic successful replies to commands.
# Interfaces
Command is a core.Command with message header information.
CommandMessagePublisher interface.
Consumer is the interface that infrastructures should implement to be used in MessageDispatchers.
DomainCommand interface for commands that are shared across the domain.
DomainEvent interface for events that are shared across the domain.
EntityEvent is an event with message header information.
EntityEventMessagePublisher interface.
Event is an event with message header information.
EventMessagePublisher interface.
Message interface for messages containing payloads and headers.
MessagePublisher interface.
MessageReceiver interface for channel subscription receivers.
MessageSubscriber interface.
Producer is the interface that infrastructures should implement to be used in a Publisher.
Reply interface.
ReplyMessagePublisher interface.
# Type aliases
CommandDispatcherOption options for CommandDispatcher.
CommandHandlerFunc function handlers for msg.Command.
EntityEventDispatcherOption options for EntityEventDispatcher.
EntityEventHandlerFunc function handlers for msg.EntityEvent.
EventDispatcherOption options for EventDispatcher.
EventHandlerFunc function handlers for msg.Event.
Headers a map of strings keyed by Message header keys.
MessageOption options for Message.
PublisherOption options for PublisherPublisher.
ReceiveMessageFunc makes it easy to drop in functions as receivers.
SubscriberOption options for MessageConsumers.