queue

Documentation

Index

• type Handler
• type Queue
  • func New(storage *Store) *Queue
  • func (q *Queue) Load(handlers map[string]Handler) *Queue
  • func (q *Queue) Pop(t Task)
  • func (q *Queue) Push(t *Task)
  • func (q *Queue) Register(tag string, h Handler)
• type Store
  • func NewStore(store *driver.Storage) *Store
  • func (e *Store) AddJob(t *Task) error
  • func (e *Store) FetchJob() []string
  • func (e *Store) FetchTask(name string) *Task
  • func (e *Store) RemoveTask(t *Task) error
• type StoreInterface
• type Task
  • func UnmarshalJson(j string) (*Task, error)
  • func (t *Task) MarshalJson() string

Types

type Handler

type Handler func(*Task) error

type Queue

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

func New

func New(storage *Store) *Queue

func (*Queue) Load

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

Load 任务内容

func (*Queue) Pop

func (q *Queue) Pop(t Task)

func (*Queue) Push

func (q *Queue) Push(t *Task)

Push 任务

func (*Queue) Register

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

Register 执行方法

type Store

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

func NewStore

func NewStore(store *driver.Storage) *Store

func (*Store) AddJob

func (e *Store) AddJob(t *Task) error

func (*Store) FetchJob

func (e *Store) FetchJob() []string

func (*Store) FetchTask

func (e *Store) FetchTask(name string) *Task

func (*Store) RemoveTask

func (e *Store) RemoveTask(t *Task) error

type StoreInterface

type StoreInterface interface {
	AddJob(string, string, string, float64) error
	FetchJob() []string                       //拉取任务队列
	FetchTask(string) string                  //获取单个执行任务。
	RemoveTask(name string, key string) error //删除任务
}

type Task

type Task struct {
	Key   string                 // system_name/job_id
	Delay int64                  // 延迟时间
	Cycle bool                   // 是否周期循环。
	Tag   string                 // Tag匹配Handler，无Tag的Task将不会被执行
	Args  map[string]interface{} // 任务参数
}

func UnmarshalJson

func UnmarshalJson(j string) (*Task, error)

func (*Task) MarshalJson

func (t *Task) MarshalJson() string