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

# Packages

No description provided by the author
No description provided by the author
Package pubsub 发布订阅器对象非常适合作为简单的广播模式的中间件.
Package queue 队列对象非常适合作为简单的生产者消费者模式的中间件.
Package stream 流及相关对象的包.

# Functions

SerializeWithJSON 使用JSON作为序列化反序列化的协议.
SerializeWithMsgpack 使用JSON作为序列化反序列化的协议.
WithBlockTime 设置客户端阻塞等待消息的时长.
WithClientID 设置.
WithStreamComsumerAckMode stream消费者专用,用于设定同步校验规则.
WithStreamComsumerGroupName stream消费者专用,用于设定客户端组.
WithStreamComsumerRecvBatchSize stream消费者专用,用于设定一次获取的消息批长度.
WithStreamComsumerAckMode stream消费者专用,用于设定同步校验规则.
WithStreamComsumerAckMode stream消费者专用,用于设定同步校验规则.
WithUUIDSonyflake 使用sonyflake作为uuid的生成器.
WithUUIDv4 使用uuid4作为uuid的生成器.

# Constants

AckModeAckWhenDone 处理完后确认.
AckModeAckWhenGet 获取到后确认.
AckModeNoAck 不做确认,消费者需要自己实现ack操作,最好别这么用.

# Variables

No description provided by the author
ErrUnSupportSerializeProtocol 未支持的序列化协议.

# Structs

Options broker的配置.

# Interfaces

Option configures how we set up the connection.

# Type aliases

AckModeType stream的Ack模式.