discover

Documentation

Index

• Variables
• func HealthCheck() map[string]string
• type TaskManager
  • func NewTaskManager(cfg option.Config, store store.Storer, controllermanager *controller.Manager, ...) *TaskManager
  • func (t *TaskManager) Do()
  • func (t *TaskManager) Start() error
  • func (t *TaskManager) Stop() error

Variables

var TaskError float64

TaskError exec error task number

var TaskNum float64

TaskNum exec task number

Functions

func HealthCheck

func HealthCheck() map[string]string

HealthCheck health check

Types

type TaskManager

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

TaskManager task

func NewTaskManager

func NewTaskManager(cfg option.Config,
	store store.Storer,
	controllermanager *controller.Manager,
	garbageCollector *gc.GarbageCollector,
	startCh *channels.RingChannel) *TaskManager

NewTaskManager return *TaskManager

func (*TaskManager) Do

func (t *TaskManager) Do()

Do do

func (*TaskManager) Start

func (t *TaskManager) Start() error

Start 启动

func (*TaskManager) Stop

func (t *TaskManager) Stop() error

Stop 停止