queue

Jan 25, 2024

Changes in this version

+ var DefaultOptions = func() Options

+ var ErrNoneHandler = errors.New(`not found handler, please register handler`)

+ type Delay interface

+ DeadList func(ctx context.Context, offset, count int64) (items []Item, err error)

+ Done func(ctx context.Context, items ...Item) (err error)

+ RegisterHandler func(handler Handler)

+ Set func(ctx context.Context, item Item) (err error)

+ SetDead func(ctx context.Context, item Item) (err error)

+ Start func() error

+ Stop func(timeout time.Duration) error

+ func NewDelay(key string, red *redis.Client, opt Options) Delay

+ func NewDelayWithGoPool(key string, red *redis.Client, pool *gopool.Pool, opt Options) Delay

+ type Handler func(items []Item)

+ type Item struct

+ At int64

+ Id string

+ Name string

+ RetryCount int64

+ func (i *Item) Member() string

+ type Options struct

+ FetchCheckSec int64

+ FetchForwardSec int64

+ FetchPerCount int64

+ MaxRetry int64

+ RetryCheckSec int64

+ RetryForwardSec int64

+ RetryPerCount int64

+ func (o *Options) FetchCheck() time.Duration

+ func (o *Options) FetchForwardBeginAt(now int64) int64

+ func (o *Options) RetryCheck() time.Duration

+ func (o *Options) RetryForwardEndAt(now int64) int64