Documentation
¶
Index ¶
- Variables
- type MQTTConfig
- type Mqtt
- func (m *Mqtt) DefaultCloseCallBack(client mqtt.Client, err error)
- func (m *Mqtt) DefaultConnectCallBack(client mqtt.Client)
- func (m *Mqtt) DefaultReConnectsCallBack(client mqtt.Client, err error)
- func (m *Mqtt) DefaultReceiveCallBack(client mqtt.Client, msg mqtt.Message)
- func (m *Mqtt) Start(ctx context.Context) error
- func (m *Mqtt) Stop(ctx context.Context) error
- func (m *Mqtt) Subscribe(topic string, qos int, callback mqtt.MessageHandler) error
- func (m *Mqtt) Unsubscribe(topic string) error
- type PayloadFunc
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultRequestTimeout = time.Second * 20
View Source
var GoutNoTLS = gout.NewWithOpt(gout.WithInsecureSkipVerify(), gout.WithTimeout(DefaultRequestTimeout))
Functions ¶
This section is empty.
Types ¶
type MQTTConfig ¶
type Mqtt ¶
func NewMqttClient ¶
func NewMqttClient(server *MQTTConfig, logger log.Logger) *Mqtt
func (*Mqtt) DefaultCloseCallBack ¶
func (*Mqtt) DefaultConnectCallBack ¶
func (*Mqtt) DefaultReConnectsCallBack ¶
func (*Mqtt) DefaultReceiveCallBack ¶
func (*Mqtt) Unsubscribe ¶
type PayloadFunc ¶
type PayloadFunc struct {
Qos int
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.