mqttclient

Documentation

Index

• type MqttConf
• type MqttWrapperClient
  • func InitMqtt(c *MqttConf) (*MqttWrapperClient, error)
  • func (m *MqttWrapperClient) Close()
  • func (m *MqttWrapperClient) Publish(topic string, payload []byte) error
  • func (m *MqttWrapperClient) Subscribe(ctx context.Context, topic string, h mqtt.MessageHandler) (err error)

Types

type MqttConf

type MqttConf struct {
	Addr     string
	ClientId string
	UserName string
	Password string
}

type MqttWrapperClient

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

func InitMqtt

func InitMqtt(c *MqttConf) (*MqttWrapperClient, error)

func (*MqttWrapperClient) Close

func (m *MqttWrapperClient) Close()

func (*MqttWrapperClient) Publish

func (m *MqttWrapperClient) Publish(topic string, payload []byte) error

func (*MqttWrapperClient) Subscribe

func (m *MqttWrapperClient) Subscribe(ctx context.Context, topic string, h mqtt.MessageHandler) (err error)