startup

package

v1.5.4 Latest Latest Go to latest Published: Oct 26, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 3 more Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

ConfigReportCallBack 自身配置上报任务回调

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

NewConfigReportCallBack 创建配置上报回调

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

OnTaskEvent 任务事件回调

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

Process 执行任务

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

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

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

NewReportClientCallBack 创建上报回调

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

OnTaskEvent 任务事件回调

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

Process 执行任务

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

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

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

NewServerServiceCallBack 创建系统服务拉取回调

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

OnTaskEvent 任务事件回调

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

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