mqtt

Documentation

Index

• Variables
• type MsgHandler
• type Sub
  • func NewSub(h MsgHandler) *Sub
  • func (s *Sub) PubUpdate(mani *manifest.SubManifest, mani_bytes []byte) error
  • func (s *Sub) PublishEvent(data []byte) error
  • func (s *Sub) PublishHeartbeat(data []byte) error
  • func (s *Sub) SetOptions()
  • func (s *Sub) StartSub()
  • func (s *Sub) SubUpdate()

Variables

var (
	Qos            = byte(1)
	ConnectTimeout = "10s"
)

Types

type MsgHandler

type MsgHandler interface {
	Handle(msg mqtt.Message)
}

type Sub

type Sub struct {
	MsgHandler
	// contains filtered or unexported fields
}

func NewSub

func NewSub(h MsgHandler) *Sub

func (*Sub) PubUpdate

func (s *Sub) PubUpdate(mani *manifest.SubManifest, mani_bytes []byte) error

* Publish update on manifest generation

func (*Sub) PublishEvent

func (s *Sub) PublishEvent(data []byte) error

func (*Sub) PublishHeartbeat

func (s *Sub) PublishHeartbeat(data []byte) error

func (*Sub) SetOptions

func (s *Sub) SetOptions()

func (*Sub) StartSub

func (s *Sub) StartSub()

func (*Sub) SubUpdate

func (s *Sub) SubUpdate()