processor

Apr 4, 2017

Changes in this version

+ var ErrNotSupported = errors.New("processor: not supported")

+ type Delayer interface

+ Delay func() time.Duration

+ type Processor struct

+ func New(q Queuer, opt *msgqueue.Options) *Processor

+ func Start(q Queuer, opt *msgqueue.Options) *Processor

+ func (p *Processor) Add(msg *msgqueue.Message) error

+ func (p *Processor) AddDelay(msg *msgqueue.Message, delay time.Duration) error

+ func (p *Processor) Process(msg *msgqueue.Message) error

+ func (p *Processor) ProcessAll() error

+ func (p *Processor) ProcessOne() error

+ func (p *Processor) Purge() error

+ func (p *Processor) Start() error

+ func (p *Processor) Stats() *Stats

+ func (p *Processor) Stop() error

+ func (p *Processor) StopTimeout(timeout time.Duration) error

+ func (p *Processor) String() string

+ type Queuer interface

+ Add func(msg *msgqueue.Message) error

+ Call func(args ...interface{}) error

+ CallOnce func(dur time.Duration, args ...interface{}) error

+ Close func() error

+ CloseTimeout func(time.Duration) error

+ Delete func(msg *msgqueue.Message) error

+ DeleteBatch func(msg []*msgqueue.Message) error

+ Name func() string

+ Processor func() *Processor

+ Purge func() error

+ Release func(*msgqueue.Message, time.Duration) error

+ ReserveN func(n int) ([]msgqueue.Message, error)

+ type Stats struct

+ AvgDuration time.Duration

+ Deleting uint32

+ Fails uint32

+ InFlight uint32

+ Processed uint32

+ Retries uint32