Documentation ¶
Index ¶
Constants ¶
View Source
const ( ModeAuto int32 = iota ModeManual )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlertChannel ¶
type CallResult ¶
func (*CallResult) Success ¶
func (r *CallResult) Success() bool
type Caller ¶
type Caller interface { // Call dispatches task to remote runner. Call(addrs []string, t *Job) *CallResult }
Caller format: http://abc, simple://
type DirectResolver ¶
type DirectResolver struct { }
type EmailChannel ¶
type EmailChannel struct { }
type HTTPCaller ¶
type HTTPCaller struct { }
func (HTTPCaller) Call ¶
func (c HTTPCaller) Call(addrs []string, j *Job) (r *CallResult)
type Job ¶
type NacosResolver ¶
type NacosResolver struct { }
type Resolver ¶
func NewDirectResolver ¶
func NewDirectResolver() Resolver
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler dispatch task to executors to run by plan.
func NewScheduler ¶
type SmsChannel ¶
type SmsChannel struct { }
type TaskFetcher ¶
type TaskFetcher struct {
// contains filtered or unexported fields
}
func NewTaskFetcher ¶
func NewTaskFetcher(ts store.TaskStore, logger log.Logger) *TaskFetcher
func (*TaskFetcher) Start ¶
func (f *TaskFetcher) Start(c chan<- *TaskHeap)
func (*TaskFetcher) Stop ¶
func (f *TaskFetcher) Stop()
type TaskHeap ¶
type TaskHeap struct {
// contains filtered or unexported fields
}
A TaskHeap implements minimum heap and holds tasks.
func NewTaskHeap ¶
type TaskItem ¶
type TaskItem struct {
// contains filtered or unexported fields
}
An TaskItem is something we manage in a priority queue.
Click to show internal directories.
Click to hide internal directories.