schedule

Documentation

Index

• Constants
• type AddTaskOptions
• type Options
• type Schedule
  • func NewSchedule(opts *Options) *Schedule
  • func (s *Schedule) Add(opts *AddTaskOptions)
  • func (s *Schedule) Delete(name string)
  • func (s *Schedule) Get(name string) *TaskInfo
  • func (s *Schedule) List() []*TaskInfo
  • func (s *Schedule) Start(ctx context.Context)
• type TaskInfo

Constants

const (
	RetryNum  = 3 // 失败重试次数
	RetryWait = 1 // 失败重试等待时间，秒
)

Types

type AddTaskOptions

type AddTaskOptions struct {
	Name     string
	StartRun bool
	Params   []interface{}
	Task     api.Task
}

type Options

type Options struct {
	WG *sync.WaitGroup
}

type Schedule

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

func NewSchedule

func NewSchedule(opts *Options) *Schedule

func (*Schedule) Add

func (s *Schedule) Add(opts *AddTaskOptions)

func (*Schedule) Delete

func (s *Schedule) Delete(name string)

func (*Schedule) Get

func (s *Schedule) Get(name string) *TaskInfo

func (*Schedule) List

func (s *Schedule) List() []*TaskInfo

func (*Schedule) Start

func (s *Schedule) Start(ctx context.Context)

type TaskInfo

type TaskInfo struct {
	Name    string
	Task    api.Task
	Params  []interface{}
	TaskRun func(params ...interface{})
}