mqtt

Documentation

Index

• Variables
• func ParseInboundMessage(ctx context.Context, msg mqtt.Message) (*eventpb.Event, error)
• func Stop(ctx context.Context, topic string)
• func Subscribe(ctx context.Context, topic string) error

Variables

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

Functions

func ParseInboundMessage

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