mqtt

package module
v0.0.0-...-5535e23 Latest Latest
Warning

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

Go to latest
Published: May 13, 2023 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package mqtt to define utils function for mqtt protocol

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Consumer

type Consumer interface {
	Connect(ctx context.Context) error
	Sub(context.Context) error
	Pub(ctx context.Context, message []byte) error
	Validate(ctx context.Context) error
	Close(ctx context.Context)
}

Consumer interface

func NewConsumer

func NewConsumer(params ...brokerOptions) (Consumer, error)

NewConsumer to create a new consumer instance

Jump to

Keyboard shortcuts

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