mqtt

Documentation

Index

• Constants
• type MsgSource
  • func NewMsgSourceFromURL(serverURL string) (s *MsgSource, err error)
  • func (s *MsgSource) Connect() error
  • func (s *MsgSource) ProcessMessages(sink vis.MessageSink) error
  • func (s *MsgSource) RecvMessages(msgs []vis.Msg)

Constants

const (
	// MessagesTopic is the topic name for update messages
	MessagesTopic = "msgs"
	// EventsTopic is the topic name for events
	EventsTopic = "events"
)

Types

type MsgSource

type MsgSource struct {
	Server   *url.URL
	Prefix   string
	ClientID string
	Client   paho.Client
	// contains filtered or unexported fields
}

MsgSource processes messages from MQTT bus

func NewMsgSourceFromURL

func NewMsgSourceFromURL(serverURL string) (s *MsgSource, err error)

NewMsgSourceFromURL creates a MsgSource by parsing a URL

func (*MsgSource) Connect

func (s *MsgSource) Connect() error

Connect connects to MQTT

func (*MsgSource) ProcessMessages

func (s *MsgSource) ProcessMessages(sink vis.MessageSink) error

ProcessMessages implements vis.MsgSource

func (*MsgSource) RecvMessages

func (s *MsgSource) RecvMessages(msgs []vis.Msg)

RecvMessages implements vis.MessageSink