server

Documentation

Index

• type MQTTServer
  • func NewMQTTServer(path string) *MQTTServer
  • func (s *MQTTServer) Hook(topic string, ...)
  • func (s *MQTTServer) InitRouter(topic string)
  • func (s *MQTTServer) Publish(topic string, message []byte) error
  • func (s *MQTTServer) Run()

Types

type MQTTServer

type MQTTServer struct {
	Server *mqtt.Server
	Path   string
}

var MQTT_SERVER *MQTTServer

func NewMQTTServer

func NewMQTTServer(path string) *MQTTServer

func (*MQTTServer) Hook

func (s *MQTTServer) Hook(topic string, callbackFn func(cl *mqtt.Client, sub packets.Subscription, pk packets.Packet))

func (*MQTTServer) InitRouter

func (s *MQTTServer) InitRouter(topic string)

func (*MQTTServer) Publish

func (s *MQTTServer) Publish(topic string, message []byte) error

func (*MQTTServer) Run

func (s *MQTTServer) Run()