vlsubscriber

Documentation

Index

• type IFace
• type Publisher
• type SubscriptionParams
• type Subscriptions

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

type Publisher func(string, *mqttp.Publish)

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