queue

Documentation

Index

• Variables
• type Option
  • func WithInterval(s int64) Option
  • func WithLogger(s logger.Logger) Option
  • func WithStep(s int64) Option
• type Options
  • func DefaultOptions() Options
• type Queue
  • func New(store store.Store, opts ...Option) *Queue
  • func (q *Queue) Load(handlers map[string]task.Handler) *Queue
  • func (q *Queue) Pop(t *task.Task) error
  • func (q *Queue) Push(t *task.Task) error
  • func (q *Queue) Register(tag string, h task.Handler)

Variables

var (
	ErrFailGetTask = "任务队列获取失败%+v"
)

Types

type Option

type Option func(o *Options)

Option Option

func WithInterval

func WithInterval(s int64) Option

func WithLogger

func WithLogger(s logger.Logger) Option

func WithStep

func WithStep(s int64) Option

type Options

type Options struct {
	// contains filtered or unexported fields
}

func DefaultOptions

func DefaultOptions() Options

DefaultOptions default options

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

func New

func New(store store.Store, opts ...Option) *Queue

func (*Queue) Load

func (q *Queue) Load(handlers map[string]task.Handler) *Queue

Load 任务内容

func (*Queue) Pop

func (q *Queue) Pop(t *task.Task) error

func (*Queue) Push

func (q *Queue) Push(t *task.Task) error

func (*Queue) Register

func (q *Queue) Register(tag string, h task.Handler)

Register 执行方法