mqtt

Documentation

Overview

Package mqtt contains MQTT-related utilities.

Index

• func Logger(i log.Interface) mqttlog.Interface
• func RunListener(ctx context.Context, lis mqttnet.Listener, ts task.Starter, ...) error
• func RunSession(ctx context.Context, cancel func(error), ts task.Starter, ...)

Functions

func Logger

func Logger(i log.Interface) mqttlog.Interface

Logger wraps a log.Interface to the Mystique logger interface.

func RunListener

func RunListener(
	ctx context.Context,
	lis mqttnet.Listener,
	ts task.Starter,
	createResource func(string) ratelimit.Resource,
	rateLimiter ratelimit.Interface,
	setupConnection func(context.Context, mqttnet.Conn) error,
) error

RunListener runs the MQTT accept connection loop.

func RunSession

func RunSession(
	ctx context.Context,
	cancel func(error),
	ts task.Starter,
	session session.Session,
	mqttConn mqttnet.Conn,
	wg *sync.WaitGroup,
)

RunSession reads the control packets from the provided session and sends them to the connection.