mqtt

package
v1.6.0 Latest Latest
Warning

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

Go to latest
Published: Oct 10, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidTopicParts = errors.New("invalid topic parts")
	ErrNotInboundTopic   = errors.New("not inbound topic")
)

Functions

func ParseInboundMessage added in v1.5.3

func ParseInboundMessage(ctx context.Context, msg mqtt.Message) (*eventpb.Event, error)

func Stop

func Stop(ctx context.Context, topic string)

func Subscribe

func Subscribe(ctx context.Context, topic string) error

Types

This section is empty.

Jump to

Keyboard shortcuts

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