mqttclient

Documentation

Index

• type MqttClient
  • func GetMqttClient(configPath string, onConnectHandler mqtt.OnConnectHandler, l log.FieldLogger) *MqttClient
  • func (mc *MqttClient) SendMessage(ctx context.Context, topic string, message string) error
  • func (mc *MqttClient) SendRetainedMessage(ctx context.Context, topic string, message string) error
  • func (mc *MqttClient) WaitForConnection(timeout int) error

Types

type MqttClient

type MqttClient struct {
	MqttServerHost string
	MqttServerPort int
	ConfigPath     string
	Config         *viper.Viper
	Logger         log.FieldLogger
	MqttClient     interfaces.Client
}

MqttClient contains the data needed to connect the client

func GetMqttClient

func GetMqttClient(configPath string, onConnectHandler mqtt.OnConnectHandler, l log.FieldLogger) *MqttClient

GetMqttClient creates the mqttclient and returns it

func (*MqttClient) SendMessage

func (mc *MqttClient) SendMessage(ctx context.Context, topic string, message string) error

SendMessage sends the message with the given payload to topic

func (*MqttClient) SendRetainedMessage

func (mc *MqttClient) SendRetainedMessage(ctx context.Context, topic string, message string) error

SendRetainedMessage sends the message with the given payload to topic

func (*MqttClient) WaitForConnection

func (mc *MqttClient) WaitForConnection(timeout int) error

WaitForConnection to mqtt server