clients

Documentation

Index

• Variables
• func NewMqttClient(conf *conf.MqttConf) (mc mqtt.Client, err error)
• func NewNatsClient(conf conf.NatsConf) (nc *nats.Conn, err error)
• type MiniProgram
  • func NewWxMiniProgram(ctx context.Context, conf WxMiniProgram, redisConf zeroCache.ClusterConf) *MiniProgram
• type Td
  • func NewTDengine(DataSource string) (TD *Td, err error)
• type WxMiniProgram

Variables

var (

	// MqttSetOnConnectHandler 如果会话断开可以通过该回调函数来重新订阅消息
	//不使用mqtt的clean session是因为会话保持期间共享订阅也会给离线的客户端,这会导致在线的客户端丢失消息
	MqttSetOnConnectHandler func()
)

Functions

func NewMqttClient

func NewMqttClient(conf *conf.MqttConf) (mc mqtt.Client, err error)

func NewNatsClient

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

Types

type MiniProgram

type MiniProgram = miniprogram.MiniProgram

func NewWxMiniProgram

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

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
}