Documentation ¶
Index ¶
Constants ¶
View Source
const MessageIDKey = "message_id"
MessageIDKey defines the key that will be send the message unique identifier.
Variables ¶
View Source
var ( ErrEmptyTarMetadataKey = errors.New("empty target metadata key") ErrMessageDoesNotMatchWithBrokers = errors.New("message does not match with any broker") )
Errors ...
Functions ¶
This section is empty.
Types ¶
type Mux ¶ added in v0.7.0
type Mux struct {
// contains filtered or unexported fields
}
Mux contains multiple brokers and a metadata key to allow route messages depending on the metadata value of the message.
func NewMux ¶ added in v0.7.0
NewMux returns an empty Mux target, if the targetKey is empty it returns ErrEmptyTarMetadataKey error.
Click to show internal directories.
Click to hide internal directories.