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

# Functions

DefaultParser 默认的消息处理函数负载会被解析为 m,ap[string]interface{}.
No description provided by the author
No description provided by the author
SerializeWithJSON 使用JSON作为序列化反序列化的协议.
SerializeWithMsgpack 使用JSON作为序列化反序列化的协议.
No description provided by the author
No description provided by the author
WithParallelHanddler 并行执行注册的handdler.
WithID stream专用.
WithMinID stream专用.
No description provided by the author
WithMinID stream专用.
WithNoMkStream stream专用.
WithParallelHanddler 并行执行注册的handdler.
No description provided by the author
WithTopicsStartPositionMap stream消费者专用,用于设定指定复数topic消费起始位置.
WithTopicStartAt stream消费者专用,用于设定指定topic消费起始时间.
WithTopicStartPosition stream消费者专用,用于设定指定topic消费起始位置.
WithUUIDSnowflake 使用snowflake作为uuid的生成器.
WithUUIDSonyflake 使用sonyflake作为uuid的生成器.
WithUUIDv4 使用uuid4作为uuid的生成器.

# Constants

SerializeProtocol_JSON json作为序列化协议.
SerializeProtocol_MSGPACK messagepack作为序列化协议.

# Variables

No description provided by the author
No description provided by the author
No description provided by the author
ErrMapPayloadCanNotCast map数据不能被转换.
ErrNotSupportChanAsPayload chan数据不能作为payload.
ErrNotSupportSliceAsPayload 不支持slice作为负载.
ErrUnSupportSerializeProtocol 未支持的序列化协议.

# Structs

ConsumerABC 消费者的基类定义了回调函数的注册操作和执行操作.
Event 消息对象.
ListenOptions 消费端listen方法的配置.
Options broker的配置.
ProducerConsumerABC 消费者的基类定义了回调函数的注册操作和执行操作.
PublishOptions 消费端listen方法的配置.

# Interfaces

ConsumerInterface 消费者对象的接口.
ProducerInterface 生产者对象的接口.

# Type aliases

EventHanddler 处理消息的回调函数@params msg *Event Event对象.
EventParser 用于将负载字符串转化为event的函数规定eventID不为""时解析流的消息,用到topic, eventID, payload规定eventID为""时解析除流之外的消息,用到SerializeProtocol,topic, payloadstr.
AckModeType stream的Ack模式.