package
1.1.8
Repository: https://github.com/pengcainiao/zero.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
IsUniqueMessageInSeconds 验证消息ID在一段时间内是否唯一,当前逻辑存在消息消费不准确的情况,使用 IsUniqueMessage 代替,3小时内确保唯一Deprecated.
IsUniqueRdsKey 识别消息是否唯一.
NewNsqLookup 创建nsqd实例.
UnmarshalNsqMessage 将NSQ的消息转换为指定的对象.

# Constants

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
低优先级,一般限制处理速率.
正常优先级,使用不同的字符串进行标记并进行统一处理.

# Structs

MessageHeader 消息头.
No description provided by the author
No description provided by the author
Topic非顺序的topic, 由于支持同一个partition进行多个并发消费, 因此无需过多的partitions, 只需保证写入性能满足需求即可,另外为了保持和原版nsq兼容, 每个节点只能有一个分区, 因此分区数*副本数不能大于节点总数.

# Interfaces

No description provided by the author

# Type aliases

No description provided by the author
No description provided by the author