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, responseIdentifier string, 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, responseIdentifier string, data []byte) error

type MqttClientOptions

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