clients

Documentation

Index

• func NewNatsClient(conf conf.NatsConf) (nc *nats.Conn, err error)
• func SetMqttSetOnConnectHandler(f func(cli mqtt.Client))
• type MiniProgram
  • func NewWxMiniProgram(ctx context.Context, conf WxMiniProgram, redisConf zeroCache.ClusterConf) *MiniProgram
• type MqttClient
  • func NewMqttClient(conf *conf.MqttConf) (mcs *MqttClient, err error)
  • func (m MqttClient) Publish(topic string, qos byte, retained bool, payload interface{}) error
  • func (m MqttClient) Subscribe(cli mqtt.Client, topic string, qos byte, callback mqtt.MessageHandler) error
• type Td
  • func NewTDengine(DataSource string) (TD *Td, err error)
• type WxMiniProgram

Functions

func NewNatsClient

func NewNatsClient(conf conf.NatsConf) (nc *nats.Conn, err error)

func SetMqttSetOnConnectHandler

func SetMqttSetOnConnectHandler(f func(cli mqtt.Client))

Types

type MiniProgram

type MiniProgram = miniprogram.MiniProgram

func NewWxMiniProgram

func NewWxMiniProgram(ctx context.Context, conf WxMiniProgram, redisConf zeroCache.ClusterConf) *MiniProgram

type MqttClient

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

func NewMqttClient

func NewMqttClient(conf *conf.MqttConf) (mcs *MqttClient, err error)

func (MqttClient) Publish

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

func (MqttClient) Subscribe

func (m MqttClient) Subscribe(cli mqtt.Client, topic string, qos byte, callback mqtt.MessageHandler) error

type Td

type Td struct {
	Dsn string
	*sql.DB
}

func NewTDengine

func NewTDengine(DataSource string) (TD *Td, err error)

type WxMiniProgram

type WxMiniProgram struct {
	Open      bool //如果开启则需要初始化为true
	AppID     string
	AppSecret string
}