startup

Documentation

Index

• type ConfigReportCallBack
  • func NewConfigReportCallBack(engine model.Engine, globalCtx model.ValueContext) *ConfigReportCallBack
  • func (c *ConfigReportCallBack) OnTaskEvent(event model.TaskEvent)
  • func (c *ConfigReportCallBack) Process(taskKey interface{}, taskValue interface{}, lastProcessTime time.Time) model.TaskResult
• type ReportClientCallBack
  • func NewReportClientCallBack(cfg config.Configuration, supplier plugin.Supplier, ...) (*ReportClientCallBack, error)
  • func (r *ReportClientCallBack) OnTaskEvent(event model.TaskEvent)
  • func (r *ReportClientCallBack) Process(taskKey interface{}, taskValue interface{}, lastProcessTime time.Time) model.TaskResult
• type ServerServiceCallBack
  • func NewServerServiceCallBack(cfg config.Configuration, supplier plugin.Supplier, engine model.Engine) (*ServerServiceCallBack, error)
  • func (s *ServerServiceCallBack) OnTaskEvent(event model.TaskEvent)
  • func (s *ServerServiceCallBack) Process(taskKey interface{}, taskValue interface{}, lastProcessTime time.Time) model.TaskResult

Types

type ConfigReportCallBack

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

自身配置上报任务回调

func NewConfigReportCallBack

func NewConfigReportCallBack(engine model.Engine, globalCtx model.ValueContext) *ConfigReportCallBack

创建配置上报回调

func (*ConfigReportCallBack) OnTaskEvent

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

OnTaskEvent 任务事件回调

func (*ConfigReportCallBack) Process

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

执行任务

type ReportClientCallBack

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

上报客户端状态任务回调

func NewReportClientCallBack

func NewReportClientCallBack(
	cfg config.Configuration, supplier plugin.Supplier, globalCtx model.ValueContext) (*ReportClientCallBack, error)

创建上报回调

func (*ReportClientCallBack) OnTaskEvent

func (r *ReportClientCallBack) OnTaskEvent(event model.TaskEvent)

OnTaskEvent 任务事件回调

func (*ReportClientCallBack) Process

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

执行任务

type ServerServiceCallBack

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

初始化系统服务的回调函数

func NewServerServiceCallBack

func NewServerServiceCallBack(
	cfg config.Configuration, supplier plugin.Supplier, engine model.Engine) (*ServerServiceCallBack, error)

创建系统服务拉取回调

func (*ServerServiceCallBack) OnTaskEvent

func (s *ServerServiceCallBack) OnTaskEvent(event model.TaskEvent)

OnTaskEvent 任务事件回调

func (*ServerServiceCallBack) Process

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

执行系统服务初始化任务