mqtt_client

Nov 29, 2023

Changes in this version

type MqttClientOptions

+ SubscribeBufferSize int

Nov 29, 2023

Changes in this version

type MqttClientOptions

+ SubscribeRoutineCount int

Nov 21, 2023

Changes in this version

+ func DestroyMqttClient(c *MqttClient)

+ type MqttClient struct

+ func NewMqttClient(opts *MqttClientOptions) (*MqttClient, error)

+ func (c *MqttClient) Connect() error

+ func (c *MqttClient) Disconnect()

+ func (c *MqttClient) GetRouter(group string, handlers []router.Handler) *router.Router

+ func (c *MqttClient) Response(item *router.Item, data []byte) error

+ type MqttClientOptions struct

+ Address string

+ ClientID string

+ KeepAliveSec int64

+ Password string

+ PingTimeoutSec int64

+ UserName string

+ WriteTimeoutSec int64