Versions in this module Expand all Collapse all v1 v1.0.0 Aug 18, 2017 Changes in this version + type Bus interface + Publish func(msg Message, qos QOS, retained bool) error + Retained func(topicQuery string) ([]Message, error) + Subscribe func(topicQuery string, qos QOS) (<-chan Message, error) + Unsubscribe func(topicQuery string) + func Log(b Bus) Bus + func New() Bus + func NewMQTT(server, clientID, user, password string, will Message) (Bus, error) + func RebasePub(b Bus, root string) Bus + func RebaseSub(b Bus, root string) Bus + type Message struct + Payload []byte + Topic string + type QOS int8 + const BestEffort + const ExactlyOnce + const MinOnce + func (i QOS) String() string Incompatible versions in this module v2.0.0+incompatible Nov 1, 2017 Other modules containing this package github.com/maruel/msgbus/v3
Go to main page