Categorygithub.com/Golang-Tools/redishelper/v2pubsubhelper
package
2.1.0
Repository: https://github.com/golang-tools/redishelper.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
10
Dependents
1
Files
193 SLOC

# Functions

NewConsumer 创建一个新的发布订阅器消费者对象@params cli redis.UniversalClient redis客户端对象@params opts ...optparams.Option[Options] 消费者的配置.
NewProducer 创建一个新的发布订阅器的生产者@params cli redis.UniversalClient redis客户端对象@params opts ...optparams.Option[Options] 生产者的配置.
SerializeWithJSON 使用JSON作为序列化反序列化的协议.
SerializeWithMsgpack 使用JSON作为序列化反序列化的协议.
WithClientID 中间件通用设置,设置客户端id.
WithUUIDSnowflake 使用snowflake作为uuid的生成器.
WithUUIDSonyflake 使用sonyflake作为uuid的生成器.
WithUUIDv4 使用uuid4作为uuid的生成器.

# Variables

ErrNeedToPointOutTopics 需要指名发布订阅器.
ErrPubSubAlreadyListened 发布订阅器已经被监听了.
ErrPubSubNotListeningYet 发布订阅器未被监听.

# Structs

Consumer 发布订阅器消费者对象.
No description provided by the author
Producer 发布订阅器生产者对象.