startup

package
v1.5.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 17, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 3 more Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigReportCallBack

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

ConfigReportCallBack 自身配置上报任务回调

func NewConfigReportCallBack

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

NewConfigReportCallBack 创建配置上报回调

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

Process 执行任务

type ReportClientCallBack

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

ReportClientCallBack 上报客户端状态任务回调

func NewReportClientCallBack

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

NewReportClientCallBack 创建上报回调

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

Process 执行任务

type ServerServiceCallBack

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

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

func NewServerServiceCallBack

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

NewServerServiceCallBack 创建系统服务拉取回调

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

Process 执行系统服务初始化任务

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL