core

type ClusterInfo struct {
	ClusterId             string
	RegistryServerUrl     string
	LeaderKey             string
	LeaderServer          string
	NodeNum               int
	WatchLeaderRetryLimit int
	QueryResourceInterval int
}

type CpuResources []*ResourceInfo

type ExecutorInfo struct {
	TaskConfig *TaskConfig
	Worker     *NodeInfo
}

type JobResources []*ResourceInfo

type LoadResources []*ResourceInfo

type MemoryResources []*ResourceInfo

type NodeInfo struct {
	NodeID    string
	Cluster   string
	Host      string
	Port      string
	OuterHost string
	OuterPort string
	Executors []string
	IsMaster  bool
	IsWorker  bool
	IsOnline  bool
}

type PageInfo struct {
	PageIndex int
	PageSize  int
}

type ResourceInfo struct {
	EndPoint   string
	CpuRate    int //cpu rate, refresh per 1 minute
	MemoryRate int //memory rate, refresh per 1 minute
	TaskCount  int //job count
	LoadValue  int //load value = cpu * 30 + memory * 30 + jobs * 40
}

type Result struct {
	RetCode int
	RetMsg  string
	Error   error
}

type TaskConfig struct {
	TaskID         string
	TaskType       string
	IsRun          bool
	Handler        task.TaskHandle `json:"-"`
	DueTime        int64
	Interval       int64
	Express        string
	TaskData       interface{}
	HAFlag         bool //HA flag, if set true, leader will watch it, when it offline will resubmit
	TargetType     string
	TargetConfig   interface{}
	DistributeType int
}