Categorygithub.com/Golang-Tools/redishelperbrokerpubsub
package
0.0.8
Repository: https://github.com/golang-tools/redishelper.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
17
Dependents
0
Files
189 SLOC

# Functions

NewConsumer 创建一个新的发布订阅器消费者对象@params k *clientkeybatch.ClientKeyBatch redis客户端的批键对象@params opts ...broker.Option 消费者的配置.
NewProducer 创建一个新的发布订阅器的生产者@params k *clientkey.ClientKey redis客户端的键对象@params opts ...broker.Option 生产者的配置.

# Variables

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

# Structs

Consumer 发布订阅器消费者对象.
Producer 发布订阅器生产者对象.