FullyQualifiedStructName name returns object name in format [package].[type name].

NamedStruct returns the name from a message implementing the following interface: type namedStruct interface { Name() string } It ignores if the value is a pointer or not.

NewCommandProcessor creates a new CommandProcessor.

StructName name returns struct name in format [type name].

CommandBus transports commands to command handlers.

CommandProcessor determines which CommandHandler should handle the command received from the command bus.

DuplicateCommandHandlerError occurs when a handler with the same name already exists.

EventBus transports events to event handlers.

EventProcessor determines which EventHandler should handle event received from event bus.

Facade is a facade for creating the Command and Event buses and processors.

NoProtoMessageError is returned when the given value does not implement proto.Message.

ProtobufMarshaler is the default Protocol Buffers marshaler.

CommandEventMarshaler marshals Commands and Events to Watermill's messages and vice versa.

CommandHandler receives a command defined by NewCommand and handles it with the Handle method.

EventHandler receives events defined by NewEvent and handles them with its Handle method.

CommandsSubscriberConstructor creates subscriber for CommandHandler.

EventsSubscriberConstructor creates a subscriber for EventHandler.