New 创建一个新的流对象@params k *clientkey.ClientKey redis客户端的键对象@params maxlen int64 流对象的最大长度@params strict bool 流是否严格控制长度.

NewConsumer 创建一个指向多个流的消费者默认一批获取一个消息,可以通过`WithStreamComsumerRecvBatchSize`设置批的大小如果使用`WithStreamComsumerGroupName`设定了group,则按组消费(默认总组监听的最新位置开始监听,收到消息后确认,消息确认策略可以通过`WithStreamComsumerAckMode`配置),否则按按单独客户端消费(默认从开始监听的时刻开始消费)需要注意单独客户端消费不会记录消费的偏移量,因此很容易丢失下次请求时的结果.解决方法是第一次使用`$`,后面则需要记录下id号从它开始@params k *clientkeybatch.ClientKeyBatch redis客户端的批键对象@params start string 监听的起始位置,可以是一个unix毫秒时间戳的字符串@params opts ...broker.Option 消费者的配置.

NewProducer 创建一个新的流生产者@params k *clientkey.ClientKey redis客户端的键对象@params opts ...broker.Option 生产者的配置.

ErrStreamConsumerAlreadyListened 流已经被监听了.

ErrStreamConsumerNotListeningYet 流未被监听.

ErrStreamNeedToPointOutGroups 流操作需要指定消费者组.

Consumer 流消费者对象.

Producer 流的生产者对象.

Stream 流对象.