Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IFace ¶
type IFace interface { Subscriptions() Subscriptions Subscribe(string, SubscriptionParams) (mqttp.QosType, []*mqttp.Publish, error) UnSubscribe(string) error HasSubscriptions() bool Online(c Publisher) Offline(bool) Hash() uintptr }
IFace passed to present network connection
type Publisher ¶
Publisher implemented by subscribing object. By calling Publish function subscriber delivers message
type SubscriptionParams ¶
type SubscriptionParams struct { // Subscription id // V5.0 ONLY ID uint32 // Ops requested subscription options Ops mqttp.SubscriptionOptions // Granted QoS granted by topics manager Granted mqttp.QosType }
SubscriptionParams parameters of the subscription
type Subscriptions ¶
type Subscriptions map[string]SubscriptionParams
Subscriptions contains active subscriptions with respective subscription parameters