Versions in this module Expand all Collapse all v1 v1.1.0 Jul 24, 2021 v1.0.0 May 10, 2021 Changes in this version + var ErrInvalidProvider = errors.New("config: invalid queue provider") + func ConsumFailInc(name string) + func ConsumSuccessInc(name string) + func Consumers() map[string]Consumer + func InFailInc(name string) + func InSuccessInc(name string) + func MetricTurnon() + func ProcessTimeHist(name string, previous time.Time) + func RegisterConsumer(name string, f Consumer) + type Base struct + Debug bool + Enqueue func([]byte) error + Opts Options + func NewBase(opts Options) *Base + func (b *Base) Backoff() + func (b *Base) BackoffReset() + func (b *Base) Do(job Jober, fn Consumer, cbs ...func(error)) (err error) + func (b *Base) GetConsumer(name string) (Consumer, error) + func (b *Base) In(job Jober) (err error) + func (b *Base) Parse(payload string) (j Jober, err error) + func (b *Base) RegisterConsumer(name string, f Consumer) + func (b *Base) Run() + func (b *Base) SemAcquire(n int) + func (b *Base) SemRelease(n int) + type Consumer func(job Jober) error + type Job struct + MaxTries int + Name string + Payload []byte + Timeout time.Duration + func (j *Job) GetMaxTries() int + func (j *Job) GetName() string + func (j *Job) GetPayload() []byte + func (j *Job) PackPayload() (packed []byte, err error) + func (j *Job) Serialize() (data []byte, err error) + func (j *Job) UnpackPayload(v interface{}) error + func (j *Job) Unserialize() (Job, error) + type Jober interface + GetMaxTries func() int + GetName func() string + GetPayload func() []byte + PackPayload func() ([]byte, error) + Serialize func() ([]byte, error) + UnpackPayload func(interface{}) error + Unserialize func() (Job, error) + type Options struct + Consume bool + Debug bool + Driver string + Logger *logrus.Logger + Metric bool + Name string + Parallel int + WaitTimeOut time.Duration + func (opts *Options) Init() + type Queuer interface + Do func(job Jober, fn Consumer, cbs ...func(error)) (err error) + In func(job Jober) (err error) + Parse func(payload string) (j Jober, err error) + RegisterConsumer func(name string, f Consumer) + Run func()
Go to main page