ami

Mar 9, 2019

Changes in this version

type ConsumerOptions

+ ErrorNotifier ErrorNotifier

+ type ErrorNotifier interface

+ AmiError func(error)

type ProducerOptions

+ ErrorNotifier ErrorNotifier

Oct 28, 2018

Changes in this version

+ type Consumer struct

+ func NewConsumer(opt ConsumerOptions, ropt *redis.ClusterOptions) (*Consumer, error)

+ func (c *Consumer) Ack(m Message)

+ func (c *Consumer) Close()

+ func (c *Consumer) Start() chan Message

+ func (c *Consumer) Stop()

+ type ConsumerOptions struct

+ Block time.Duration

+ Consumer string

+ Name string

+ PendingBufferSize int64

+ PipeBufferSize int64

+ PipePeriod time.Duration

+ PrefetchCount int64

+ ShardsCount int8

+ type Producer struct

+ func NewProducer(opt ProducerOptions, ropt *redis.ClusterOptions) (*Producer, error)

+ func (p *Producer) Close()

+ func (p *Producer) Send(m string)

+ type ProducerOptions struct

+ Name string

+ PendingBufferSize int64

+ PipeBufferSize int64

+ PipePeriod time.Duration

+ ShardsCount int8

Oct 27, 2018

Changes in this version

type Qu

+ func (q *Qu) CloseConsumer()

+ func (q *Qu) CloseProducer()

Oct 27, 2018

Changes in this version

type Options

+ PipeBufferSize int64

+ PipePeriod time.Duration

Oct 27, 2018

Changes in this version

+ type Message struct

+ Body string

+ Group string

+ ID string

+ Stream string

+ type Options struct

+ Block time.Duration

+ Consumer string

+ Name string

+ PendingBufferSize int64

+ PrefetchCount int64

+ ShardsCount int8

+ type Qu struct

+ func NewQu(opt Options, ropt *redis.ClusterOptions) (*Qu, error)

+ func (q *Qu) Ack(m Message)

+ func (q *Qu) Close()

+ func (q *Qu) Consume() chan Message

+ func (q *Qu) Send(m string)