mqttclient

Documentation

Index

• type MQTTClient
  • func NewMQTTClient(req dtos.NewMQTTClient, lc logger.LoggingClient, ...) (MQTTClient, error)

Types

type MQTTClient

type MQTTClient interface {
	RegisterConnectCallback(dtos.ConnectHandler)
	RegisterDisconnectCallback(dtos.CallbackHandler)
	AsyncPublish(ctx context.Context, topic string, payload []byte, isSync bool)
	Close()
	GetConnectStatus() bool
}

func NewMQTTClient

func NewMQTTClient(req dtos.NewMQTTClient, lc logger.LoggingClient,
	consumeCallback func(mqtt.Client, mqtt.Message), connF dtos.ConnectHandler, disConnF dtos.CallbackHandler) (MQTTClient, error)