mqtt_client

Documentation

Index

• func DestroyMqttClient(c *MqttClient)
• type MqttClient
  • 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

Functions

func DestroyMqttClient

func DestroyMqttClient(c *MqttClient)

Types

type MqttClient

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

func NewMqttClient

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

func (*MqttClient) Connect

func (c *MqttClient) Connect() error

func (*MqttClient) Disconnect

func (c *MqttClient) Disconnect()

func (*MqttClient) GetRouter

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

func (*MqttClient) Response

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

type MqttClientOptions

type MqttClientOptions struct {
	UserName        string
	Password        string
	Address         string
	ClientID        string
	KeepAliveSec    int64
	PingTimeoutSec  int64
	WriteTimeoutSec int64
}