vlsubscriber

package
Version: v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 29, 2019 License: Apache-2.0 Imports: 1 Imported by: 0

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.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

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL