queue

type Delay interface {
	Set(ctx context.Context, item Item) (err error)
	SetDead(ctx context.Context, item Item) (err error)
	Done(ctx context.Context, items ...Item) (err error)
	DeadList(ctx context.Context, offset, count int64) (items []Item, err error)
	RegisterHandler(handler Handler)
	Start() error
	Stop(timeout time.Duration) error
}

type Handler func(items []Item)

type Item struct {
	Id         string `json:"i"`
	Name       string `json:"n"`
	At         int64  `json:"a"`
	RetryCount int64  `json:"rc"`
}

type Options struct {
	MaxRetry        int64 `json:"maxRetry" yaml:"maxRetry"`
	FetchCheckSec   int64 `json:"fetchCheckSec" yaml:"fetchCheckSec"`
	FetchPerCount   int64 `json:"fetchPerCount" yaml:"fetchPerCount"`
	FetchForwardSec int64 `json:"fetchForwardSec" yaml:"fetchForwardSec"`
	RetryCheckSec   int64 `json:"retryCheckSec" yaml:"retryCheckSec"`
	RetryPerCount   int64 `json:"retryPerCount" yaml:"retryPerCount"`
	RetryForwardSec int64 `json:"retryForwardSec" yaml:"retryForwardSec"`
}