mqtt

package

v0.0.0-...-ca90ad5 Latest Latest Go to latest Published: Nov 23, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rdoorn/alfred

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	NAME    = "mqtt"
	VERSION = "1.0"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Handler ¶

type Handler struct {
	// contains filtered or unexported fields
}

func New ¶

func New(opts ...Option) *Handler

New initializes the plugin

func (*Handler) Name ¶

func (h *Handler) Name() string

Name returns the name of the plugin

func (*Handler) Publish ¶

func (h *Handler) Publish(e *integration.Event) error

func (*Handler) Shutdown ¶

func (h *Handler) Shutdown()

Close closes all connections and channels

func (h *Handler) Subscribe(e <-chan integration.Event) error

func (*Handler) Version ¶

func (h *Handler) Version() string

Version returns the version of the plugin

type Option ¶

type Option func(*Handler)

func ClientID ¶

func ClientID(s string) Option

ClientID overrides the name as which to connect to mqtt (Default: uuid)

func Debug ¶

func Debug(b bool) Option

Debug enable or disabled debug

func MessageReader ¶

func MessageReader(messageReader func(client mqtt.Client, msg mqtt.Message)) Option

MessageReader overrides the default message handler for reads

func MessageWriter ¶

func MessageWriter(messageWriter func(topic string, qos byte, retained bool, payload interface{}) error) Option

MessageWriter overrides the default message handler for reads

func Topic ¶

func Topic(s string) Option

Topic adds a subscription to a topic (can be used multiple times)

Source Files ¶

View all Source files

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