Versions in this module Expand all Collapse all v0 v0.1.2 May 20, 2022 v0.1.1 May 18, 2022 Changes in this version + func DelRdValue(key string) (int64, error) + func EmqxApiPublish(emqxCfg *config.EmqxConf, params *EmqxParamsConf) + func GetClient(addr, username, password, database, precision string) client.Client + func GetMqttClient(broker_, username_, password_ string, defaultHandler mqtt.MessageHandler) mqtt.Client + func GetRdValue(key string) (string, error) + func GetRedisClient(addr, password string, db int) *redis.Client + func MqttSend(topic string, payload interface{}, qos_ byte) error + func MqttSubscribe(broker_, username_, password_, topic_ string, qos_ byte, ...) error + func SelectInflux(sn, sql string, database, prefix string) (res []client.Result, err1 error) + func SetRdValue(key string, value interface{}) error + func SetRdValueTimeout(key string, value interface{}, expiration time.Duration) error + func SubscribeKeyExpired(fc RedisKeyExpiredFunc) error + func WirteInflux(sn string, productKey string, status int64, fields map[string]interface{}, ...) (string, error) + type EmqxParamsConf struct + App string + Project int64 + User int64 + type RabbitMQ struct + Exchange string + Key string + Mqurl string + QueueName string + func NewRabbitMQ(queuename string, exchange string, key string, mqurl string) *RabbitMQ + func NewRabbitMQPubSub(exchangeName string, mqurl string) *RabbitMQ + func NewRabbitMQRouting(exchagne string, routingKey string, mqurl string) *RabbitMQ + func NewRabbitMQSimple(queueName string, mqurl string) *RabbitMQ + func NewRabbitMQTopic(exchagne string, routingKey string, mqurl string) *RabbitMQ + func (r *RabbitMQ) ConsumeSimple(fc recieveMsgFunc) + func (r *RabbitMQ) Destory() + func (r *RabbitMQ) PublishPub(message string) + func (r *RabbitMQ) PublishRouting(message string) + func (r *RabbitMQ) PublishSimple(message string) + func (r *RabbitMQ) PublishTopic(message string) + func (r *RabbitMQ) RecieveRouting() + func (r *RabbitMQ) RecieveSub(fc recieveMsgFunc) + func (r *RabbitMQ) RecieveTopic() + type RedisKeyExpiredFunc func(string)