drive

Nov 23, 2020

Changes in this version

+ type ClientOption func(options *clientOptions)

+ func WithAutoCreateTopic(auto bool) ClientOption

+ func WithBrokerAddr(addr []string) ClientOption

+ func WithNameSrvAddr(addr []string) ClientOption

type RocketMqClient

+ Admin admin.Admin

+ ConsumerMap map[string]rocketmq.PushConsumer

+ Producer rocketmq.Producer

+ func (c *RocketMqClient) TopicDeleter(topic string)

Nov 19, 2020

Changes in this version

+ type RocketMqClient struct

+ MsgChanMap map[string]chan string

+ RocketMqConsumerMap map[string]rocketmq.PushConsumer

+ RocketMqProducerMap map[string]rocketmq.Producer

+ func NewRocketMqClient(host, port string) RocketMqClient

+ func (c *RocketMqClient) Publish(topic string, value interface{}, Priority uint8) error

+ func (c *RocketMqClient) Register(topic string) (<-chan string, error)

Oct 27, 2020

Changes in this version

+ const AMQPNil

Jul 11, 2020

Changes in this version

type RabbitMqClient

+ func (c *RabbitMqClient) Publish(queueName string, value interface{}, Priority uint8) error

type RedisClient

+ func (c *RedisClient) LPush(key string, value interface{}) error

Mar 16, 2020

Changes in this version

+ 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 string) RabbitMqClient

+ func (c *RabbitMqClient) Close()

+ func (c *RabbitMqClient) Get(key string) (string, error)

+ func (c *RabbitMqClient) Ping() error

+ func (c *RabbitMqClient) Set(key string, value interface{}) error

+ type Result struct

+ CreateTime time.Time

+ Res string

+ Uuid string

Sep 2, 2019

Changes in this version

+ func HideKey(key string) string

+ 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) Ping() error

+ func (c *RedisClient) RPush(key string, value interface{}) error

+ func (c *RedisClient) Set(key string, value interface{}, exTime time.Duration) error