mqttx

package module

Go to main page

Versions in this module

v1

v1.1.2

Aug 13, 2024

v1.1.1

Aug 3, 2024

Changes in this version

type MQTTxClientPool

+ func (p *MQTTxClientPool) Iterate(f func(c *MQTTxClient))

v1.1.0

Aug 2, 2024

v1.0.13

Sep 27, 2023

v1.0.12

Sep 27, 2023

v1.0.11

Sep 27, 2023

Changes in this version

+ func MqttLibDebug(enable bool, level int)

+ type MQTTLibDebug struct

+ Level int

+ func (l *MQTTLibDebug) Printf(format string, v ...interface{})

+ func (l *MQTTLibDebug) Println(v ...interface{})

v1.0.10

Aug 18, 2023

v1.0.9

Aug 18, 2023

Changes in this version

+ func FormatServerAddr(addr string) string

v1.0.8

Aug 18, 2023

Changes in this version

type MQTTxClient

+ func (m *MQTTxClient) GetOtherOptsAll() map[string]string

v1.0.7

Aug 18, 2023

Changes in this version

type MQTTxClient

+ func (m *MQTTxClient) GetOtherOptsALL() map[string]string

v1.0.6

Aug 17, 2023

Changes in this version

type MQTTxClientPool

+ func (p *MQTTxClientPool) GetClients() []*MQTTxClient

v1.0.5

Aug 17, 2023

Changes in this version

type MQTTxClient

+ func (m *MQTTxClient) ClearOtherOpts()

v1.0.4

Aug 17, 2023

Changes in this version

+ const MaxInt

+ const MaxUint

+ const MinInt

+ func SleepSecond(seconds int)

type MQTTxClient

+ OtherOpts map[string]string

+ func (m *MQTTxClient) GetOtherOpts(key string) string

+ func (m *MQTTxClient) SetOtherOpts(key, value string)

+ func (m *MQTTxClient) SetServerConnectionCount(count int)

type MQTTxClientPool

+ func NewMQTTxClientPool() *MQTTxClientPool

type MQTTxServer

+ func (m *MQTTxServer) Server() string

v1.0.3

Aug 16, 2023

Changes in this version

type MQTTxClient

+ ServerConnectionCount int

+ func (m *MQTTxClient) GetServerConnectionCount() int

+ func (m *MQTTxClient) Server() string

+ type MQTTxClientPool struct

+ Clients []*MQTTxClient

+ var ClientPool *MQTTxClientPool

+ func (p *MQTTxClientPool) Add(client *MQTTxClient)

+ func (p *MQTTxClientPool) Get(server string) *MQTTxClient

+ func (p *MQTTxClientPool) GetMinConnectionCountClient() *MQTTxClient

+ func (p *MQTTxClientPool) Len() int

+ func (p *MQTTxClientPool) Remove(server string)

+ func (p MQTTxClientPool) String() string

v1.0.2

Aug 11, 2023

v1.0.1

Aug 11, 2023

Changes in this version

+ const MQTT_BROKER_ALIYUN

+ const MQTT_BROKER_BAIDU

+ const MQTT_BROKER_EMQX

+ const MQTT_BROKER_JD

+ const MQTT_BROKER_MOSCA

+ const MQTT_BROKER_MOSQUITTO

+ const MQTT_BROKER_QCLOUD

+ const MQTT_BROKER_RABBITMQ

+ const MQTT_BROKER_VERNEMQ

v1.0.0

Aug 11, 2023

Changes in this version

+ const LevelAlert

+ const LevelCritical

+ const LevelDebug

+ const LevelEmergency

+ const LevelError

+ const LevelInformational

+ const LevelNotice

+ const LevelWarning

+ var MQTTxClientPools []*MQTTxClient

+ var MQTTxHandlerConnectionLost mqtt.ConnectionLostHandler = func(client mqtt.Client, err error)

+ var MQTTxHandlerDefault mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message)

+ var MQTTxHandlerOnConnect mqtt.OnConnectHandler = func(client mqtt.Client)

+ var MQTTxHandlerReconnecting mqtt.ReconnectHandler = func(client mqtt.Client, clientOptions *mqtt.ClientOptions)

+ func CallbackConnectionLostHandlerSet(handler mqtt.ConnectionLostHandler)

+ func CallbackDefaultHandlerSet(handler mqtt.MessageHandler)

+ func CallbackOnConnectHandlerSet(handler mqtt.OnConnectHandler)

+ func CallbackReconnectingHandlerSet(handler mqtt.ReconnectHandler)

+ func Connect(servers []MQTTxServer, defaultPublishHandler mqtt.MessageHandler, ...) error

+ func Debug(enable bool)

+ func NewTLSConfig(cafile, clientCertFile, clientKeyFile string) (*tls.Config, error)

+ func SetUserDebug(f TraceFunc)

+ func TraceDebug(format string, v ...interface{})

+ func TraceError(format string, v ...interface{})

+ func TraceInfo(format string, v ...interface{})

+ type Cert struct

+ Cafile string

+ ClientCertFile string

+ ClientKeyFile string

+ func (c *Cert) IsValid() bool

+ func (c Cert) String() string

+ type MQTTxClient struct

+ Cert Cert

+ Client mqtt.Client

+ ClientID string

+ Domain string

+ IP string

+ Opts *mqtt.ClientOptions

+ Password string

+ Port string

+ Scheme string

+ Username string

+ Vendor string

+ func NewMQTTxClient(server MQTTxServer) (*MQTTxClient, error)

+ func (m *MQTTxClient) Connect(defaultPublishHandler mqtt.MessageHandler, ...) error

+ func (m *MQTTxClient) Disconnect() error

+ func (m *MQTTxClient) GetCert() Cert

+ func (m *MQTTxClient) GetClientID() string

+ func (m *MQTTxClient) GetDomain() string

+ func (m *MQTTxClient) GetIP() string

+ func (m *MQTTxClient) GetPassword() string

+ func (m *MQTTxClient) GetPort() string

+ func (m *MQTTxClient) GetScheme() string

+ func (m *MQTTxClient) GetUsername() string

+ func (m *MQTTxClient) GetVendor() string

+ func (m *MQTTxClient) Publish(topic string, qos byte, retained bool, payload interface{}) error

+ func (m *MQTTxClient) SetCert(cert Cert)

+ func (m *MQTTxClient) SetClientID(clientID string)

+ func (m *MQTTxClient) SetDomain(domain string)

+ func (m *MQTTxClient) SetIP(ip string)

+ func (m *MQTTxClient) SetPassword(password string)

+ func (m *MQTTxClient) SetPort(port string)

+ func (m *MQTTxClient) SetScheme(scheme string)

+ func (m *MQTTxClient) SetUsername(username string)

+ func (m *MQTTxClient) SetVendor(vendor string)

+ func (m *MQTTxClient) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) error

+ func (m MQTTxClient) String() string

+ type MQTTxServer struct

+ Cert Cert

+ ClientID string

+ Domain string

+ IP string

+ Password string

+ Port string

+ Scheme string

+ Username string

+ Vendor string

+ func (m *MQTTxServer) GetCert() Cert

+ func (m *MQTTxServer) GetClientID() string

+ func (m *MQTTxServer) GetDomain() string

+ func (m *MQTTxServer) GetIP() string

+ func (m *MQTTxServer) GetPassword() string

+ func (m *MQTTxServer) GetPort() string

+ func (m *MQTTxServer) GetScheme() string

+ func (m *MQTTxServer) GetUsername() string

+ func (m *MQTTxServer) GetVendor() string

+ func (m *MQTTxServer) SetCert(cert Cert)

+ func (m *MQTTxServer) SetClientID(clientID string)

+ func (m *MQTTxServer) SetDomain(domain string)

+ func (m *MQTTxServer) SetIP(ip string)

+ func (m *MQTTxServer) SetPassword(password string)

+ func (m *MQTTxServer) SetPort(port string)

+ func (m *MQTTxServer) SetScheme(scheme string)

+ func (m *MQTTxServer) SetUsername(username string)

+ func (m *MQTTxServer) SetVendor(vendor string)

+ func (m *MQTTxServer) String() string

+ type TraceFunc func(format string, level int, v ...interface{})

+ var UserTrace TraceFunc = nil

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL