mqtt

Documentation

Overview

Package mqtt implements the MQTT frontend.

Index

• func Serve(ctx context.Context, server io.Server, listener net.Listener, format Format, ...) error
• func TopicParts(up *io.ContextualApplicationUp, layout topics.Layout) []string
• type Format

Functions

func Serve

func Serve(ctx context.Context, server io.Server, listener net.Listener, format Format, protocol string) error

Serve serves the MQTT frontend.

func TopicParts

func TopicParts(up *io.ContextualApplicationUp, layout topics.Layout) []string

TopicParts generates the topic parts for the provided uplink.

Types

type Format

type Format interface {
	topics.Layout
	formatters.Formatter
}

Format represents a topic layout and message formatter.

var JSON Format = &json{
	Layout:    topics.Default,
	Formatter: formatters.JSON,
}

JSON is a format that uses the default topic layout and JSON formatter.