mqtt

Documentation

Index

• type MqttConf
  • func (mm *MqttConf) NewMqttServ(serviceID string, l log.Logger) (MqttServ, error)
  • func (mm *MqttConf) NewMqttServWithFileStore(serviceID, clientID string, l log.Logger) (MqttServ, error)
• type MqttDI
• type MqttServ
• type MqttSubSerInter
• type MqttSubSerMap
  • func (mssl *MqttSubSerMap) Add(mss MqttSubSerInter)
  • func (mssl MqttSubSerMap) GetSubscribeMap() map[string]byte
  • func (mssl MqttSubSerMap) Handler(client mqtt.Client, message mqtt.Message)

Types

type MqttConf

type MqttConf struct {
	TCP           string `yaml:"tcp"`
	CaFile        string `yaml:"ca"`
	ClientCrt     string `yaml:"crt"`
	ClientKey     string `yaml:"key"`
	UserName      string `yaml:"user"`
	Password      string `yaml:"password"`
	FileStorePath string `yaml:"fileStorePath"`
}

func (*MqttConf) NewMqttServ

func (mm *MqttConf) NewMqttServ(serviceID string, l log.Logger) (MqttServ, error)

func (*MqttConf) NewMqttServWithFileStore

func (mm *MqttConf) NewMqttServWithFileStore(serviceID, clientID string, l log.Logger) (MqttServ, error)

type MqttDI

type MqttDI interface {
	NewMqttServ(serviceID string, l log.Logger) (MqttServ, error)
	NewMqttServWithFileStore(serviceID, clientID string, l log.Logger) (MqttServ, error)
}

type MqttServ

type MqttServ interface {
	PublishByte(topics []string, data []byte, retain bool) error
	Publish(topics []string, message map[string]interface{}, retain bool) error
	Subcribe(mssm MqttSubSerInter) error
	SubscribeMultiple(mssm MqttSubSerMap) error
	Disconnect()
	// contains filtered or unexported methods
}

type MqttSubSerInter

type MqttSubSerInter interface {
	GetTopic() string
	GetQos() byte
	Handler(client mqtt.Client, msg mqtt.Message)
}

type MqttSubSerMap

type MqttSubSerMap struct {
	// contains filtered or unexported fields
}

func (*MqttSubSerMap) Add

func (mssl *MqttSubSerMap) Add(mss MqttSubSerInter)

func (MqttSubSerMap) GetSubscribeMap

func (mssl MqttSubSerMap) GetSubscribeMap() map[string]byte

func (MqttSubSerMap) Handler

func (mssl MqttSubSerMap) Handler(client mqtt.Client, message mqtt.Message)