CtxWithOriginalMessage returns a new context with the original message attached.

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.

NewCommandBus creates a new CommandBus.

NewCommandBusWithConfig creates a new CommandBus.

NewCommandHandler creates a new CommandHandler implementation based on provided function and command type inferred from function argument.

NewCommandProcessor creates a new CommandProcessor.

NewEventBus creates a new CommandBus.

NewEventBusWithConfig creates a new EventBus.

NewEventGroupProcessorWithConfig creates a new EventGroupProcessor.

NewEventHandler creates a new EventHandler implementation based on provided function and event type inferred from function argument.

NewEventProcessor creates a new EventProcessor.

NewEventProcessorWithConfig creates a new EventProcessor.

Deprecated: use CommandHandler and EventHandler instead.

NewGroupEventHandler creates a new GroupEventHandler implementation based on provided function and event type inferred from function argument.

OriginalMessageFromCtx returns the original message that was received by the event/command handler.

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.

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

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

Deprecated: use CommandHandler and EventHandler instead.

Deprecated: use CommandProcessor and EventProcessor instead.

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

ProtobufMarshaler a protobuf marshaler using github.com/gogo/protobuf/proto (deprecated).

ProtoMarshaler 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.

CommandProcessorSubscriberConstructorFn creates subscriber for CommandHandler.

CommandsSubscriberConstructor creates subscriber for CommandHandler.

EventsSubscriberConstructor creates a subscriber for EventHandler.