NewCommandBus creates a new CommandBus.

NewEventBus creates a new EventBus.

NewFacade creates a new CQRS Facade.

NewLogrusWrapper returns new instance of logrusWrapper.

NewPublisher initializes the events publisher based on the Redis stream client.

NewRouter creates a new cqrs.Router.

NewSubscriber creates a new subscriber for the given consumer group.

CommandBus interface.

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

EventBus interface.

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

Logger is an interface, that you need to implement to support Watermill logging.