queue

Documentation

Index

• type Option
  • func Interval(s int64) Option
  • func Logger(s logger.Logger) Option
  • func Step(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)

Types

type Option

type Option func(o *Options)

Option Option

func Interval

func Interval(s int64) Option

func Logger

func Logger(s logger.Logger) Option

func Step

func Step(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 执行方法