model

Documentation

Index

• Constants
• type HandleCallbackParam
  • func (t HandleCallbackParam) String() string
• type IdleBeatParam
  • func (t IdleBeatParam) String() string
• type KillParam
  • func (t KillParam) String() string
• type LogParam
  • func (t LogParam) String() string
• type LogResult
  • func (t LogResult) String() string
• type RegistryParam
  • func (t RegistryParam) String() string
• type ReturnT
  • func NewReturnT(code int32, msg string, content interface{}) ReturnT
  • func (t ReturnT) String() string
• type TriggerParam
  • func (t TriggerParam) String() string

Constants

const (
	HANDLE_COCE_SUCCESS = 200
	HANDLE_COCE_FAIL    = 500
	HANDLE_COCE_TIMEOUT = 502
)

const (
	SUCCESS_CODE = 200
	FAIL_CODE    = 500
)

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