Versions in this module Expand all Collapse all v2 v2.1.0 Oct 15, 2020 v2.0.0 May 27, 2020 Changes in this version + type Consumer struct + Errors chan error + func NewConsumer() (*Consumer, error) + func NewConsumerWithOptions(options *ConsumerOptions) (*Consumer, error) + func (c *Consumer) Register(stream string, fn ConsumerFunc) + func (c *Consumer) RegisterWithLastID(stream string, id string, fn ConsumerFunc) + func (c *Consumer) Run() + func (c *Consumer) Shutdown() + type ConsumerFunc func(*Message) error + type ConsumerOptions struct + BlockingTimeout time.Duration + BufferSize int + Concurrency int + GroupName string + Name string + ReclaimInterval time.Duration + RedisClient *redis.Client + RedisOptions *RedisOptions + VisibilityTimeout time.Duration + type Message struct + ID string + Stream string + Values map[string]interface{} + type Producer struct + func NewProducer() (*Producer, error) + func NewProducerWithOptions(options *ProducerOptions) (*Producer, error) + func (p *Producer) Enqueue(msg *Message) error + type ProducerOptions struct + ApproximateMaxLength bool + RedisClient *redis.Client + RedisOptions *RedisOptions + StreamMaxLength int64 + type RedisOptions = redis.Options Other modules containing this package github.com/robinjoseph08/redisqueue
Go to main page