detect

Documentation

Index

• type HealthCheckCallBack
  • func NewHealthCheckCallBack(cfg config.Configuration, supplier plugin.Supplier) (*HealthCheckCallBack, error)
  • func (c *HealthCheckCallBack) OnTaskEvent(event model.TaskEvent)
  • func (c *HealthCheckCallBack) Process(taskKey interface{}, taskValue interface{}, lastProcessTime time.Time) model.TaskResult

Types

type HealthCheckCallBack

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

HealthCheckCallBack 健康探测回调任务

func NewHealthCheckCallBack

func NewHealthCheckCallBack(cfg config.Configuration, supplier plugin.Supplier) (*HealthCheckCallBack, error)

NewHealthCheckCallBack 创建健康检查的回调

func (*HealthCheckCallBack) OnTaskEvent

func (c *HealthCheckCallBack) OnTaskEvent(event model.TaskEvent)

OnTaskEvent 任务事件回调

func (*HealthCheckCallBack) Process

func (c *HealthCheckCallBack) Process(
	taskKey interface{}, taskValue interface{}, lastProcessTime time.Time) model.TaskResult

Process 执行任务