# Functions
JSONSchemaMessageValidator validates a message payload based on a map of Json Schema, where the key can be any identifier (depends on who implements it).
New creates a new watermillmessage.Message.
NewValidationError creates a new ValidationError.
NewWatermillLogrusLogger creates a new WatermillLogrusLogger.
UnmarshalMetadata extracts a value from the Message Metadata and unmarshals it to the given object.
ValidationErrorFromMessage extracts a ValidationError from the message Metadata if exists.
ValidationErrorToMessage sets a ValidationError to the given message Metadata.
# Constants
MetadataChannel is the key used for storing the Channel in the message Metadata.
MetadataValidationError is the key used for storing the Validation Error if applies.
# Structs
ValidationError represents a message validation error.
WatermillLogrusLogger is a wrapper of a Logrus logger implementing watermill.LoggerAdapter interface.
# Type aliases
Validator validates a message.