pkg.gl

package

2.1.0

Documentation: pkg.go.dev

# Functions

NewConsumer 创建一个新的队列消费者对象@params cli redis.UniversalClient redis客户端对象@params opts ...optparams.Option[Options] 消费者的配置.

NewProducer 创建一个新的队列生产者对象@params k *clientkey.ClientKey redis客户端的键对象@params opts ...optparams.Option[Options] 生产者的配置.

SerializeWithJSON 使用JSON作为序列化反序列化的协议.

SerializeWithMsgpack 使用JSON作为序列化反序列化的协议.

WithBlockTime 设置客户端阻塞等待消息的时长.

WithClientID 中间件通用设置,设置客户端id.

WithUUIDSnowflake 使用snowflake作为uuid的生成器.

WithUUIDSonyflake 使用sonyflake作为uuid的生成器.

WithUUIDv4 使用uuid4作为uuid的生成器.

ErrQueueAlreadyListened 队列已经被监听了.

ErrQueueNotListeningYet 队列未被监听.

ErrQueueResNotTwo 从队列中得到的消息结果不为2位.

Consumer 队列消费者对象.

No description provided by the author

Producer 队列的生产者对象.