Versions in this module Expand all Collapse all v2 v2.3.0 Dec 25, 2021 Changes in this version + const AMQPNil + func HideKey(key string) string + type ClientOption func(options *clientOptions) + func WithAutoCreateTopic(auto bool) ClientOption + func WithBrokerAddr(addr []string) ClientOption + func WithNameSrvAddr(addr []string) ClientOption + type MemCacheClient struct + func NewMemCacheClient(host, port string, poolSize int) MemCacheClient + func (c *MemCacheClient) Close() + func (c *MemCacheClient) Flush() error + func (c *MemCacheClient) Get(key string) (string, error) + func (c *MemCacheClient) Ping() error + func (c *MemCacheClient) Set(key string, value interface{}, exTime int) error + type MongoClient struct + func NewMongoClient(host, port, user, password, db, collection string) MongoClient + func (c *MongoClient) Close() + func (c *MongoClient) Get(key string) (string, error) + func (c *MongoClient) Ping() error + func (c *MongoClient) Set(key string, value interface{}, exTime int) error + type RabbitMqClient struct + func NewRabbitMqClient(host, port, user, password, vhost string) RabbitMqClient + func (c *RabbitMqClient) Close() + func (c *RabbitMqClient) Get(queueName string) (string, error) + func (c *RabbitMqClient) Ping() error + func (c *RabbitMqClient) Publish(queueName string, value interface{}, Priority uint8) error + type RedisClient struct + func NewRedisClient(host string, port string, password string, db int, poolSize int) RedisClient + func (c *RedisClient) BLPop(key string, timeout time.Duration) *redis.StringSliceCmd + func (c *RedisClient) Close() + func (c *RedisClient) Do(args ...interface{}) *redis.Cmd + func (c *RedisClient) Exists(key string) (bool, error) + func (c *RedisClient) Flush() error + func (c *RedisClient) Get(key string) *redis.StringCmd + func (c *RedisClient) LPush(key string, value interface{}) error + func (c *RedisClient) Ping() error + func (c *RedisClient) RPush(key string, value interface{}) error + func (c *RedisClient) Set(key string, value interface{}, exTime time.Duration) error + type Result struct + CreateTime time.Time + Res string + Uuid string + type RocketMqClient struct + Admin admin.Admin + ConsumerMap map[string]rocketmq.PushConsumer + MsgChanMap map[string]chan string + Producer rocketmq.Producer + func NewRocketMqClient(opts ...ClientOption) RocketMqClient + func (c *RocketMqClient) Publish(topic string, value interface{}, Priority uint8) error + func (c *RocketMqClient) Register(topic string) (<-chan string, error) + func (c *RocketMqClient) TopicDeleter(topic string)