# Functions

New 创建一个新的数据库客户端代理.
NewNameSpaceKey 创建一个带命名空间的key.
NewPubSubTopic 新建一个PubSub主题.
NewQueue 新建一个PubSub主题.
NewStreamTopic 新建一个流主题.

# Variables

Done 锁的结束信号.
ErrCountMustBePositive 个数参数必须为正数.
ErrElementNotExist 个数参数必须为正数.
ErrGroupNotInTopic 消费组不在topic上.
ErrHelperAlreadyInited 代理已经初始化错误.
ErrHelperNotInited 代理未初始化错误.
ErrIsAlreadySubscribed 消费者已经订阅了数据.
ErrIsAlreadyUnSubscribed 消费者已经取消订阅了数据.
ErrKeyNotExist 键不存在.
ErrLockAlreadySet 分布式锁已经设置.
ErrLockWaitTimeout 等待解锁超时.
ErrPubSubNotSubscribe Pubsub模式订阅者未订阅.
ErrQueueGetNotMatch Pubsub模式订阅者未订阅.
ErrRankError 排名信息有问题.
ErrStreamConsumerNotBlocked 消费者不是用阻塞模式监听.
Helper 默认的pg代理对象.

# Structs

NameSpcaeKey 带命名空间的键.
PubSubTopic 流主题.
Queue 消息队列.
QueueMessage 从队列中获取的消息.
StreamTopic 流主题.