mqtt

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"`
}

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

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 interface {
	GetTopic() string
	GetQos() byte
	Handler(client mqtt.Client, msg mqtt.Message)
}

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