model

package
v0.0.0-...-b025b39 Latest Latest
Warning

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

Go to latest
Published: Mar 1, 2023 License: GPL-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

View Source
const (
	HANDLE_COCE_SUCCESS = 200
	HANDLE_COCE_FAIL    = 500
	HANDLE_COCE_TIMEOUT = 502
)
View Source
const (
	SUCCESS_CODE = 200
	FAIL_CODE    = 500
)

Variables

This section is empty.

Functions

This section is empty.

Types

type HandleCallbackParam

type HandleCallbackParam struct {
	LogId      int64 `json:"logId"`
	LogDateTim int64 `json:"logDateTim"`

	HandleCode int32  `json:"handleCode"`
	HandleMsg  string `json:"handleMsg"`
}

执行器回传给调度器数据,主要是运行结果

func (HandleCallbackParam) String

func (t HandleCallbackParam) String() string

type IdleBeatParam

type IdleBeatParam struct {
	JobId int32 `json:"jobId"`
}

func (IdleBeatParam) String

func (t IdleBeatParam) String() string

type KillParam

type KillParam struct {
	JobId int32 `json:"jobId"`
}

func (KillParam) String

func (t KillParam) String() string

type LogParam

type LogParam struct {
	LogDateTim  int64 `json:"logDateTim"`
	LogId       int64 `json:"logId"`
	FromLineNum int32 `json:"fromLineNum"`
}

func (LogParam) String

func (t LogParam) String() string

type LogResult

type LogResult struct {
	FromLineNum int32  `json:"fromLineNum"`
	ToLineNum   int32  `json:"toLineNum"`
	LogContent  string `json:"logContent"`
	IsEnd       bool   `json:"isEnd"`
}

func (LogResult) String

func (t LogResult) String() string

type RegistryParam

type RegistryParam struct {
	RegistryGroup string `json:"registryGroup"`
	RegistryKey   string `json:"registryKey"`
	RegistryValue string `json:"registryValue"`
}

func (RegistryParam) String

func (t RegistryParam) String() string

type ReturnT

type ReturnT struct {
	Code    int32       `json:"code"`
	Msg     string      `json:"msg"`
	Content interface{} `json:"content"`
}

func NewReturnT

func NewReturnT(code int32, msg string, content interface{}) ReturnT

func (ReturnT) String

func (t ReturnT) String() string

type TriggerParam

type TriggerParam struct {
	JobId int32 `json:"jobId"`

	ExecutorHandler       string `json:"executorHandler"`
	ExecutorParams        string `json:"executorParams"`
	ExecutorBlockStrategy string `json:"executorBlockStrategy"`
	ExecutorTimeout       int    `json:"executorTimeout"` //秒

	LogId       int64 `json:"logId"`
	LogDateTime int64 `json:"logDateTime"`

	GlueType       string `json:"glueType"`
	GlueSource     string `json:"glueSource"`
	GlueUpdatetime int64  `json:"glueUpdatetime"`

	BroadcastIndex int32 `json:"broadcastIndex"`
	BroadcastTotal int32 `json:"broadcastTotal"`
}

func (TriggerParam) String

func (t TriggerParam) String() string

Jump to

Keyboard shortcuts

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