Documentation ¶
Index ¶
- Variables
- type AppGroupInfo
- func (rcvr *AppGroupInfo) GetAppKey() string
- func (rcvr *AppGroupInfo) GetAppName() string
- func (rcvr *AppGroupInfo) GetEnableLog() bool
- func (rcvr *AppGroupInfo) GetGroupId() string
- func (rcvr *AppGroupInfo) GetId() int64
- func (rcvr *AppGroupInfo) GetLogConfigId() int64
- func (rcvr *AppGroupInfo) GetLogConfigInfo() *LogConfigInfo
- func (rcvr *AppGroupInfo) GetMaxJobs() int32
- func (rcvr *AppGroupInfo) GetNamespaceId() string
- func (rcvr *AppGroupInfo) GetStatus() int32
- func (rcvr *AppGroupInfo) GetVersion() int32
- func (rcvr *AppGroupInfo) SetAppKey(appKey string)
- func (rcvr *AppGroupInfo) SetAppName(appName string)
- func (rcvr *AppGroupInfo) SetEnableLog(enableLog bool)
- func (rcvr *AppGroupInfo) SetGroupId(groupId string)
- func (rcvr *AppGroupInfo) SetId(id int64)
- func (rcvr *AppGroupInfo) SetLogConfigId(logConfigId int64)
- func (rcvr *AppGroupInfo) SetLogConfigInfo(logConfigInfo *LogConfigInfo)
- func (rcvr *AppGroupInfo) SetMaxJobs(maxJobs int32)
- func (rcvr *AppGroupInfo) SetNamespaceId(namespaceId string)
- func (rcvr *AppGroupInfo) SetStatus(status int32)
- func (rcvr *AppGroupInfo) SetVersion(version int32)
- type ExecuteMode
- type JobInstanceData
- type JobInstanceInfo
- func (j *JobInstanceInfo) GetAliveTimestamp() int64
- func (j *JobInstanceInfo) GetAllWorkers() []string
- func (j *JobInstanceInfo) GetAppGroupId() int64
- func (j *JobInstanceInfo) GetAttempt() int32
- func (j *JobInstanceInfo) GetContent() string
- func (j *JobInstanceInfo) GetDataTime() time.Time
- func (j *JobInstanceInfo) GetExecuteMode() string
- func (j *JobInstanceInfo) GetGroupId() string
- func (j *JobInstanceInfo) GetInstanceParameters() string
- func (j *JobInstanceInfo) GetIsRetry() bool
- func (j *JobInstanceInfo) GetJobConcurrency() int32
- func (j *JobInstanceInfo) GetJobId() int64
- func (j *JobInstanceInfo) GetJobInstanceId() int64
- func (j *JobInstanceInfo) GetJobName() string
- func (j *JobInstanceInfo) GetJobType() string
- func (j *JobInstanceInfo) GetMaxAttempt() int32
- func (j *JobInstanceInfo) GetParameters() string
- func (j *JobInstanceInfo) GetPriority() int32
- func (j *JobInstanceInfo) GetRegionId() int32
- func (j *JobInstanceInfo) GetScheduleTime() time.Time
- func (j *JobInstanceInfo) GetStatus() int32
- func (j *JobInstanceInfo) GetTimeExpression() string
- func (j *JobInstanceInfo) GetTimeType() int32
- func (j *JobInstanceInfo) GetTriggerType() int32
- func (j *JobInstanceInfo) GetUpstreamData() []*JobInstanceData
- func (j *JobInstanceInfo) GetUser() string
- func (j *JobInstanceInfo) GetWfInstanceId() int64
- func (j *JobInstanceInfo) GetWorkerIdAddr() string
- func (j *JobInstanceInfo) GetWorkerInfo() *WorkerInfo
- func (j *JobInstanceInfo) GetXattrs() string
- func (j *JobInstanceInfo) SetAliveTimestamp(aliveTimestamp int64)
- func (j *JobInstanceInfo) SetAllWorkers(allWorkers []string)
- func (j *JobInstanceInfo) SetAppGroupId(appGroupId int64)
- func (j *JobInstanceInfo) SetAttempt(attempt int32)
- func (j *JobInstanceInfo) SetContent(content string)
- func (j *JobInstanceInfo) SetDataTime(dataTime time.Time)
- func (j *JobInstanceInfo) SetExecuteMode(executeMode string)
- func (j *JobInstanceInfo) SetGroupId(groupId string)
- func (j *JobInstanceInfo) SetInstanceParameters(instanceParameters string)
- func (j *JobInstanceInfo) SetIsRetry(isRetry bool)
- func (j *JobInstanceInfo) SetJobConcurrency(jobConcurrency int32)
- func (j *JobInstanceInfo) SetJobId(jobId int64)
- func (j *JobInstanceInfo) SetJobInstanceId(jobInstanceId int64)
- func (j *JobInstanceInfo) SetJobName(jobName string)
- func (j *JobInstanceInfo) SetJobType(jobType string)
- func (j *JobInstanceInfo) SetMaxAttempt(maxAttempt int32)
- func (j *JobInstanceInfo) SetParameters(parameters string)
- func (j *JobInstanceInfo) SetPriority(priority int32)
- func (j *JobInstanceInfo) SetRegionId(regionId int32)
- func (j *JobInstanceInfo) SetScheduleTime(scheduleTime time.Time)
- func (j *JobInstanceInfo) SetStatus(status int32)
- func (j *JobInstanceInfo) SetTimeExpression(timeExpression string)
- func (j *JobInstanceInfo) SetTimeType(timeType int32)
- func (j *JobInstanceInfo) SetTriggerType(triggerType int32)
- func (j *JobInstanceInfo) SetUpstreamData(upstreamData []*JobInstanceData)
- func (j *JobInstanceInfo) SetUser(user string)
- func (j *JobInstanceInfo) SetWfInstanceId(wfInstanceId int64)
- func (j *JobInstanceInfo) SetWorkerIdAddr(workerIdAddr string)
- func (j *JobInstanceInfo) SetWorkerInfo(workerInfo *WorkerInfo)
- func (j *JobInstanceInfo) SetXattrs(xattrs string)
- type LogConfigInfo
- func (rcvr *LogConfigInfo) GetConfig() string
- func (rcvr *LogConfigInfo) GetId() int64
- func (rcvr *LogConfigInfo) GetRegionId() string
- func (rcvr *LogConfigInfo) GetType() string
- func (rcvr *LogConfigInfo) GetUserId() string
- func (rcvr *LogConfigInfo) SetConfig(config string)
- func (rcvr *LogConfigInfo) SetId(id int64)
- func (rcvr *LogConfigInfo) SetRegionId(regionId string)
- func (rcvr *LogConfigInfo) SetType(logType string)
- func (rcvr *LogConfigInfo) SetUserId(userId string)
- type MapTaskProgress
- func (m *MapTaskProgress) GetTaskProgress() []*TaskProgressCounter
- func (m *MapTaskProgress) GetWorkerProgress() []*WorkerProgressCounter
- func (m *MapTaskProgress) SetTaskProgress(taskProgress []*TaskProgressCounter)
- func (m *MapTaskProgress) SetWorkerProgress(workerProgress []*WorkerProgressCounter)
- type MapTaskXAttrs
- func (m MapTaskXAttrs) GetConsumerSize() int32
- func (m MapTaskXAttrs) GetDispatcherSize() int32
- func (m MapTaskXAttrs) GetGlobalConsumerSize() int32
- func (m MapTaskXAttrs) GetPageSize() int32
- func (m MapTaskXAttrs) GetQueueSize() int32
- func (m MapTaskXAttrs) GetTaskAttemptInterval() int32
- func (m MapTaskXAttrs) GetTaskDispatchMode() string
- func (m MapTaskXAttrs) GetTaskMaxAttempt() int32
- type Metrics
- type ProgressHistory
- func (p *ProgressHistory) CostTime() int64
- func (p *ProgressHistory) EndTime() int64
- func (p *ProgressHistory) SerialNum() int64
- func (p *ProgressHistory) SetCostTime(costTime int64)
- func (p *ProgressHistory) SetEndTime(endTime int64)
- func (p *ProgressHistory) SetSerialNum(serialNum int64)
- func (p *ProgressHistory) SetStartTime(startTime int64)
- func (p *ProgressHistory) SetSuccess(success bool)
- func (p *ProgressHistory) SetTaskProgressMap(taskProgressMap map[string]*TaskProgressCounter)
- func (p *ProgressHistory) StartTime() int64
- func (p *ProgressHistory) Success() bool
- func (p *ProgressHistory) TaskProgressMap() map[string]*TaskProgressCounter
- type SecondProgressDetail
- func (s *SecondProgressDetail) GetRecentProgressHistory() []*ProgressHistory
- func (s *SecondProgressDetail) GetRunningProgress() string
- func (s *SecondProgressDetail) GetRunningStartTime() int64
- func (s *SecondProgressDetail) GetTodayBeginTime() string
- func (s *SecondProgressDetail) GetTodayProgressCounter() *TaskProgressCounter
- func (s *SecondProgressDetail) GetYesterdayProgressCounter() *TaskProgressCounter
- func (s *SecondProgressDetail) SetRecentProgressHistory(recentProgressHistory []*ProgressHistory)
- func (s *SecondProgressDetail) SetRunningProgress(runningProgress string)
- func (s *SecondProgressDetail) SetRunningStartTime(runningStartTime int64)
- func (s *SecondProgressDetail) SetTodayBeginTime(todayBeginTime string)
- func (s *SecondProgressDetail) SetTodayProgressCounter(todayProgressCounter *TaskProgressCounter)
- func (s *SecondProgressDetail) SetYesterdayProgressCounter(yesterdayProgressCounter *TaskProgressCounter)
- type ShardingTask
- type TaskDispatchMode
- type TaskInfo
- func (t *TaskInfo) JobId() int64
- func (t *TaskInfo) JobInstanceId() int64
- func (t *TaskInfo) SetJobId(jobId int64)
- func (t *TaskInfo) SetJobInstanceId(jobInstanceId int64)
- func (t *TaskInfo) SetTaskBody(taskBody []byte)
- func (t *TaskInfo) SetTaskId(taskId int64)
- func (t *TaskInfo) SetTaskName(taskName string)
- func (t *TaskInfo) TaskBody() []byte
- func (t *TaskInfo) TaskId() int64
- func (t *TaskInfo) TaskName() string
- type TaskProgressCounter
- func (c *TaskProgressCounter) DecrementFailed()
- func (c *TaskProgressCounter) DecrementRunning()
- func (c *TaskProgressCounter) DecrementSuccess()
- func (c *TaskProgressCounter) GetFailed() int64
- func (c *TaskProgressCounter) GetName() string
- func (c *TaskProgressCounter) GetPulled() int64
- func (c *TaskProgressCounter) GetRunning() int64
- func (c *TaskProgressCounter) GetSuccess() int64
- func (c *TaskProgressCounter) GetTotal() int64
- func (c *TaskProgressCounter) IncrementFailed(delta int64)
- func (c *TaskProgressCounter) IncrementOneFailed()
- func (c *TaskProgressCounter) IncrementOnePulled()
- func (c *TaskProgressCounter) IncrementOneSuccess()
- func (c *TaskProgressCounter) IncrementOneTotal()
- func (c *TaskProgressCounter) IncrementPulled(delta int64)
- func (c *TaskProgressCounter) IncrementRunning()
- func (c *TaskProgressCounter) IncrementRunning2(delta int64)
- func (c *TaskProgressCounter) IncrementSuccess(delta int64)
- func (c *TaskProgressCounter) IncrementTotal(delta int64)
- type TaskStatistics
- type TimeType
- type WorkerBusyStatus
- type WorkerInfo
- type WorkerProgressCounter
- func (c *WorkerProgressCounter) DecrementFailed()
- func (c *WorkerProgressCounter) DecrementRunning(delta int64)
- func (c *WorkerProgressCounter) DecrementSuccess()
- func (c *WorkerProgressCounter) GetFailed() int64
- func (c *WorkerProgressCounter) GetRunning() int64
- func (c *WorkerProgressCounter) GetSuccess() int64
- func (c *WorkerProgressCounter) GetTotal() int64
- func (c *WorkerProgressCounter) GetWorkerAddr() string
- func (c *WorkerProgressCounter) IncrementFailed(delta int64)
- func (c *WorkerProgressCounter) IncrementOneFailed()
- func (c *WorkerProgressCounter) IncrementPulled()
- func (c *WorkerProgressCounter) IncrementRunning()
- func (c *WorkerProgressCounter) IncrementSuccess()
- func (c *WorkerProgressCounter) IncrementTotal()
Constants ¶
This section is empty.
Variables ¶
View Source
var ( TimeTypeDesc = map[TimeType]string{ TimeTypeNone: "none", TimeTypeCron: "cron", TimeTypeFixedRate: "fixed_rate", TimeTypeSecondDelay: "second_delay", TimeTypeOneTime: "one_time", TimeTypeAPI: "api", TimeTypeTemp: "temp", } TimeTypeClassName = map[TimeType]string{ TimeTypeNone: "", TimeTypeCron: "com.alibaba.schedulerx.core.time.CronParser", TimeTypeFixedRate: "com.alibaba.schedulerx.core.time.FixedRateParser", TimeTypeSecondDelay: "com.alibaba.schedulerx.core.time.FixedDelayParser", TimeTypeOneTime: "com.alibaba.schedulerx.core.time.OneTimeParser", TimeTypeAPI: "", TimeTypeTemp: "", } )
Functions ¶
This section is empty.
Types ¶
type AppGroupInfo ¶ added in v0.0.2
type AppGroupInfo struct { Id int64 `json:"id"` GroupId string `json:"groupId"` AppName string `json:"appName"` AppKey string `json:"appKey"` MaxJobs int32 `json:"maxJobs"` Status int32 `json:"status"` NamespaceId string `json:"namespaceId"` EnableLog bool `json:"enableLog"` LogConfigId int64 `json:"logConfigId"` Version int32 `json:"version"` LogConfigInfo *LogConfigInfo `json:"logConfigInfo"` }
AppGroupInfo application group information
func NewAppGroupInfo ¶ added in v0.0.2
func NewAppGroupInfo() (rcvr *AppGroupInfo)
func (*AppGroupInfo) GetAppKey ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetAppKey() string
func (*AppGroupInfo) GetAppName ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetAppName() string
func (*AppGroupInfo) GetEnableLog ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetEnableLog() bool
func (*AppGroupInfo) GetGroupId ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetGroupId() string
func (*AppGroupInfo) GetId ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetId() int64
func (*AppGroupInfo) GetLogConfigId ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetLogConfigId() int64
func (*AppGroupInfo) GetLogConfigInfo ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetLogConfigInfo() *LogConfigInfo
func (*AppGroupInfo) GetMaxJobs ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetMaxJobs() int32
func (*AppGroupInfo) GetNamespaceId ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetNamespaceId() string
func (*AppGroupInfo) GetStatus ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetStatus() int32
func (*AppGroupInfo) GetVersion ¶ added in v0.0.2
func (rcvr *AppGroupInfo) GetVersion() int32
func (*AppGroupInfo) SetAppKey ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetAppKey(appKey string)
func (*AppGroupInfo) SetAppName ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetAppName(appName string)
func (*AppGroupInfo) SetEnableLog ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetEnableLog(enableLog bool)
func (*AppGroupInfo) SetGroupId ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetGroupId(groupId string)
func (*AppGroupInfo) SetId ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetId(id int64)
func (*AppGroupInfo) SetLogConfigId ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetLogConfigId(logConfigId int64)
func (*AppGroupInfo) SetLogConfigInfo ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetLogConfigInfo(logConfigInfo *LogConfigInfo)
func (*AppGroupInfo) SetMaxJobs ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetMaxJobs(maxJobs int32)
func (*AppGroupInfo) SetNamespaceId ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetNamespaceId(namespaceId string)
func (*AppGroupInfo) SetStatus ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetStatus(status int32)
func (*AppGroupInfo) SetVersion ¶ added in v0.0.2
func (rcvr *AppGroupInfo) SetVersion(version int32)
type ExecuteMode ¶ added in v0.0.2
type ExecuteMode string
const ( StandaloneExecuteMode ExecuteMode = "standalone" BroadcastExecuteMode ExecuteMode = "broadcast" ParallelExecuteMode ExecuteMode = "parallel" GridExecuteMode ExecuteMode = "grid" BatchExecuteMode ExecuteMode = "batch" ShardingExecuteMode ExecuteMode = "sharding" )
func (ExecuteMode) Description ¶ added in v0.0.2
func (mode ExecuteMode) Description() string
type JobInstanceData ¶
func (JobInstanceData) GetData ¶
func (j JobInstanceData) GetData() string
func (JobInstanceData) GetJobName ¶
func (j JobInstanceData) GetJobName() string
func (*JobInstanceData) SetData ¶
func (j *JobInstanceData) SetData(data string)
func (*JobInstanceData) SetJobName ¶
func (j *JobInstanceData) SetJobName(jobName string)
type JobInstanceInfo ¶
type JobInstanceInfo struct {
// contains filtered or unexported fields
}
func NewJobInstanceInfo ¶
func NewJobInstanceInfo() *JobInstanceInfo
func (*JobInstanceInfo) GetAliveTimestamp ¶
func (j *JobInstanceInfo) GetAliveTimestamp() int64
func (*JobInstanceInfo) GetAllWorkers ¶
func (j *JobInstanceInfo) GetAllWorkers() []string
func (*JobInstanceInfo) GetAppGroupId ¶
func (j *JobInstanceInfo) GetAppGroupId() int64
func (*JobInstanceInfo) GetAttempt ¶
func (j *JobInstanceInfo) GetAttempt() int32
func (*JobInstanceInfo) GetContent ¶
func (j *JobInstanceInfo) GetContent() string
func (*JobInstanceInfo) GetDataTime ¶
func (j *JobInstanceInfo) GetDataTime() time.Time
func (*JobInstanceInfo) GetExecuteMode ¶
func (j *JobInstanceInfo) GetExecuteMode() string
func (*JobInstanceInfo) GetGroupId ¶
func (j *JobInstanceInfo) GetGroupId() string
func (*JobInstanceInfo) GetInstanceParameters ¶
func (j *JobInstanceInfo) GetInstanceParameters() string
func (*JobInstanceInfo) GetIsRetry ¶
func (j *JobInstanceInfo) GetIsRetry() bool
func (*JobInstanceInfo) GetJobConcurrency ¶
func (j *JobInstanceInfo) GetJobConcurrency() int32
func (*JobInstanceInfo) GetJobId ¶
func (j *JobInstanceInfo) GetJobId() int64
func (*JobInstanceInfo) GetJobInstanceId ¶
func (j *JobInstanceInfo) GetJobInstanceId() int64
func (*JobInstanceInfo) GetJobName ¶
func (j *JobInstanceInfo) GetJobName() string
func (*JobInstanceInfo) GetJobType ¶
func (j *JobInstanceInfo) GetJobType() string
func (*JobInstanceInfo) GetMaxAttempt ¶
func (j *JobInstanceInfo) GetMaxAttempt() int32
func (*JobInstanceInfo) GetParameters ¶
func (j *JobInstanceInfo) GetParameters() string
func (*JobInstanceInfo) GetPriority ¶
func (j *JobInstanceInfo) GetPriority() int32
func (*JobInstanceInfo) GetRegionId ¶
func (j *JobInstanceInfo) GetRegionId() int32
func (*JobInstanceInfo) GetScheduleTime ¶
func (j *JobInstanceInfo) GetScheduleTime() time.Time
func (*JobInstanceInfo) GetStatus ¶
func (j *JobInstanceInfo) GetStatus() int32
func (*JobInstanceInfo) GetTimeExpression ¶
func (j *JobInstanceInfo) GetTimeExpression() string
func (*JobInstanceInfo) GetTimeType ¶
func (j *JobInstanceInfo) GetTimeType() int32
func (*JobInstanceInfo) GetTriggerType ¶
func (j *JobInstanceInfo) GetTriggerType() int32
func (*JobInstanceInfo) GetUpstreamData ¶
func (j *JobInstanceInfo) GetUpstreamData() []*JobInstanceData
func (*JobInstanceInfo) GetUser ¶
func (j *JobInstanceInfo) GetUser() string
func (*JobInstanceInfo) GetWfInstanceId ¶
func (j *JobInstanceInfo) GetWfInstanceId() int64
func (*JobInstanceInfo) GetWorkerIdAddr ¶
func (j *JobInstanceInfo) GetWorkerIdAddr() string
func (*JobInstanceInfo) GetWorkerInfo ¶
func (j *JobInstanceInfo) GetWorkerInfo() *WorkerInfo
func (*JobInstanceInfo) GetXattrs ¶
func (j *JobInstanceInfo) GetXattrs() string
func (*JobInstanceInfo) SetAliveTimestamp ¶
func (j *JobInstanceInfo) SetAliveTimestamp(aliveTimestamp int64)
func (*JobInstanceInfo) SetAllWorkers ¶
func (j *JobInstanceInfo) SetAllWorkers(allWorkers []string)
func (*JobInstanceInfo) SetAppGroupId ¶
func (j *JobInstanceInfo) SetAppGroupId(appGroupId int64)
func (*JobInstanceInfo) SetAttempt ¶
func (j *JobInstanceInfo) SetAttempt(attempt int32)
func (*JobInstanceInfo) SetContent ¶
func (j *JobInstanceInfo) SetContent(content string)
func (*JobInstanceInfo) SetDataTime ¶
func (j *JobInstanceInfo) SetDataTime(dataTime time.Time)
func (*JobInstanceInfo) SetExecuteMode ¶
func (j *JobInstanceInfo) SetExecuteMode(executeMode string)
func (*JobInstanceInfo) SetGroupId ¶
func (j *JobInstanceInfo) SetGroupId(groupId string)
func (*JobInstanceInfo) SetInstanceParameters ¶
func (j *JobInstanceInfo) SetInstanceParameters(instanceParameters string)
func (*JobInstanceInfo) SetIsRetry ¶
func (j *JobInstanceInfo) SetIsRetry(isRetry bool)
func (*JobInstanceInfo) SetJobConcurrency ¶
func (j *JobInstanceInfo) SetJobConcurrency(jobConcurrency int32)
func (*JobInstanceInfo) SetJobId ¶
func (j *JobInstanceInfo) SetJobId(jobId int64)
func (*JobInstanceInfo) SetJobInstanceId ¶
func (j *JobInstanceInfo) SetJobInstanceId(jobInstanceId int64)
func (*JobInstanceInfo) SetJobName ¶
func (j *JobInstanceInfo) SetJobName(jobName string)
func (*JobInstanceInfo) SetJobType ¶
func (j *JobInstanceInfo) SetJobType(jobType string)
func (*JobInstanceInfo) SetMaxAttempt ¶
func (j *JobInstanceInfo) SetMaxAttempt(maxAttempt int32)
func (*JobInstanceInfo) SetParameters ¶
func (j *JobInstanceInfo) SetParameters(parameters string)
func (*JobInstanceInfo) SetPriority ¶
func (j *JobInstanceInfo) SetPriority(priority int32)
func (*JobInstanceInfo) SetRegionId ¶
func (j *JobInstanceInfo) SetRegionId(regionId int32)
func (*JobInstanceInfo) SetScheduleTime ¶
func (j *JobInstanceInfo) SetScheduleTime(scheduleTime time.Time)
func (*JobInstanceInfo) SetStatus ¶
func (j *JobInstanceInfo) SetStatus(status int32)
func (*JobInstanceInfo) SetTimeExpression ¶
func (j *JobInstanceInfo) SetTimeExpression(timeExpression string)
func (*JobInstanceInfo) SetTimeType ¶
func (j *JobInstanceInfo) SetTimeType(timeType int32)
func (*JobInstanceInfo) SetTriggerType ¶
func (j *JobInstanceInfo) SetTriggerType(triggerType int32)
func (*JobInstanceInfo) SetUpstreamData ¶
func (j *JobInstanceInfo) SetUpstreamData(upstreamData []*JobInstanceData)
func (*JobInstanceInfo) SetUser ¶
func (j *JobInstanceInfo) SetUser(user string)
func (*JobInstanceInfo) SetWfInstanceId ¶
func (j *JobInstanceInfo) SetWfInstanceId(wfInstanceId int64)
func (*JobInstanceInfo) SetWorkerIdAddr ¶
func (j *JobInstanceInfo) SetWorkerIdAddr(workerIdAddr string)
func (*JobInstanceInfo) SetWorkerInfo ¶
func (j *JobInstanceInfo) SetWorkerInfo(workerInfo *WorkerInfo)
func (*JobInstanceInfo) SetXattrs ¶
func (j *JobInstanceInfo) SetXattrs(xattrs string)
type LogConfigInfo ¶ added in v0.0.2
type LogConfigInfo struct { Id int64 `json:"id"` LogType string `json:"logType"` Config string `json:"config"` UserId string `json:"userId"` RegionId string `json:"regionId"` }
func NewLogConfigInfo ¶ added in v0.0.2
func NewLogConfigInfo() (rcvr *LogConfigInfo)
func (*LogConfigInfo) GetConfig ¶ added in v0.0.2
func (rcvr *LogConfigInfo) GetConfig() string
func (*LogConfigInfo) GetId ¶ added in v0.0.2
func (rcvr *LogConfigInfo) GetId() int64
func (*LogConfigInfo) GetRegionId ¶ added in v0.0.2
func (rcvr *LogConfigInfo) GetRegionId() string
func (*LogConfigInfo) GetType ¶ added in v0.0.2
func (rcvr *LogConfigInfo) GetType() string
func (*LogConfigInfo) GetUserId ¶ added in v0.0.2
func (rcvr *LogConfigInfo) GetUserId() string
func (*LogConfigInfo) SetConfig ¶ added in v0.0.2
func (rcvr *LogConfigInfo) SetConfig(config string)
func (*LogConfigInfo) SetId ¶ added in v0.0.2
func (rcvr *LogConfigInfo) SetId(id int64)
func (*LogConfigInfo) SetRegionId ¶ added in v0.0.2
func (rcvr *LogConfigInfo) SetRegionId(regionId string)
func (*LogConfigInfo) SetType ¶ added in v0.0.2
func (rcvr *LogConfigInfo) SetType(logType string)
func (*LogConfigInfo) SetUserId ¶ added in v0.0.2
func (rcvr *LogConfigInfo) SetUserId(userId string)
type MapTaskProgress ¶ added in v0.0.2
type MapTaskProgress struct { TaskProgress []*TaskProgressCounter `json:"taskProgress"` WorkerProgress []*WorkerProgressCounter `json:"workerProgress"` }
func NewMapTaskProgress ¶ added in v0.0.2
func NewMapTaskProgress() *MapTaskProgress
func (*MapTaskProgress) GetTaskProgress ¶ added in v0.0.2
func (m *MapTaskProgress) GetTaskProgress() []*TaskProgressCounter
func (*MapTaskProgress) GetWorkerProgress ¶ added in v0.0.2
func (m *MapTaskProgress) GetWorkerProgress() []*WorkerProgressCounter
func (*MapTaskProgress) SetTaskProgress ¶ added in v0.0.2
func (m *MapTaskProgress) SetTaskProgress(taskProgress []*TaskProgressCounter)
func (*MapTaskProgress) SetWorkerProgress ¶ added in v0.0.2
func (m *MapTaskProgress) SetWorkerProgress(workerProgress []*WorkerProgressCounter)
type MapTaskXAttrs ¶
type MapTaskXAttrs struct { // ConsumerSize is the maximum number of threads triggered for execution on a single machine during a single run, default value is 5 ConsumerSize int32 `json:"consumerSize"` // DispatcherSize is the number of threads used for distributing child tasks,default value is 5 DispatcherSize int32 `json:"dispatcherSize"` // TaskMaxAttempt is the number of retries for a Failed child task TaskMaxAttempt int32 `json:"taskMaxAttempt"` // TaskAttemptInterval is the interval between retries for a Failed child task TaskAttemptInterval int32 `json:"taskAttemptInterval"` // Child task distribution mode (push/pull) TaskDispatchMode string `json:"taskDispatchMode"` //==== Exclusive to pull model ====== // PageSize is the number of child tasks Pulled per single machine per request,default value is 5 PageSize int32 `json:"pageSize"` // QueueSize is the cache size for the child task queue on a single machine,default value is 10 QueueSize int32 `json:"queueSize"` // GlobalConsumerSize is the global concurrent consumption of child tasks GlobalConsumerSize int32 `json:"globalConsumerSize"` }
func NewMapTaskXAttrs ¶
func NewMapTaskXAttrs() *MapTaskXAttrs
func (MapTaskXAttrs) GetConsumerSize ¶
func (m MapTaskXAttrs) GetConsumerSize() int32
func (MapTaskXAttrs) GetDispatcherSize ¶
func (m MapTaskXAttrs) GetDispatcherSize() int32
func (MapTaskXAttrs) GetGlobalConsumerSize ¶
func (m MapTaskXAttrs) GetGlobalConsumerSize() int32
func (MapTaskXAttrs) GetPageSize ¶
func (m MapTaskXAttrs) GetPageSize() int32
func (MapTaskXAttrs) GetQueueSize ¶
func (m MapTaskXAttrs) GetQueueSize() int32
func (MapTaskXAttrs) GetTaskAttemptInterval ¶
func (m MapTaskXAttrs) GetTaskAttemptInterval() int32
func (MapTaskXAttrs) GetTaskDispatchMode ¶
func (m MapTaskXAttrs) GetTaskDispatchMode() string
func (MapTaskXAttrs) GetTaskMaxAttempt ¶
func (m MapTaskXAttrs) GetTaskMaxAttempt() int32
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
Metrics VM runtime details for check
type ProgressHistory ¶ added in v0.0.2
type ProgressHistory struct {
// contains filtered or unexported fields
}
func NewProgressHistory ¶ added in v0.0.2
func NewProgressHistory() (rcvr *ProgressHistory)
func (*ProgressHistory) CostTime ¶ added in v0.0.2
func (p *ProgressHistory) CostTime() int64
func (*ProgressHistory) EndTime ¶ added in v0.0.2
func (p *ProgressHistory) EndTime() int64
func (*ProgressHistory) SerialNum ¶ added in v0.0.2
func (p *ProgressHistory) SerialNum() int64
func (*ProgressHistory) SetCostTime ¶ added in v0.0.2
func (p *ProgressHistory) SetCostTime(costTime int64)
func (*ProgressHistory) SetEndTime ¶ added in v0.0.2
func (p *ProgressHistory) SetEndTime(endTime int64)
func (*ProgressHistory) SetSerialNum ¶ added in v0.0.2
func (p *ProgressHistory) SetSerialNum(serialNum int64)
func (*ProgressHistory) SetStartTime ¶ added in v0.0.2
func (p *ProgressHistory) SetStartTime(startTime int64)
func (*ProgressHistory) SetSuccess ¶ added in v0.0.2
func (p *ProgressHistory) SetSuccess(success bool)
func (*ProgressHistory) SetTaskProgressMap ¶ added in v0.0.2
func (p *ProgressHistory) SetTaskProgressMap(taskProgressMap map[string]*TaskProgressCounter)
func (*ProgressHistory) StartTime ¶ added in v0.0.2
func (p *ProgressHistory) StartTime() int64
func (*ProgressHistory) Success ¶ added in v0.0.2
func (p *ProgressHistory) Success() bool
func (*ProgressHistory) TaskProgressMap ¶ added in v0.0.2
func (p *ProgressHistory) TaskProgressMap() map[string]*TaskProgressCounter
type SecondProgressDetail ¶ added in v0.0.2
type SecondProgressDetail struct { TodayBeginTime string `json:"todayBeginTime"` TodayProgressCounter *TaskProgressCounter `json:"todayProgressCounter"` YesterdayProgressCounter *TaskProgressCounter `json:"yesterdayProgressCounter"` RecentProgressHistory []*ProgressHistory `json:"recentProgressHistory"` RunningProgress string `json:"runningProgress"` RunningStartTime int64 `json:"runningStartTime"` }
func NewSecondProgressDetail ¶ added in v0.0.2
func NewSecondProgressDetail() *SecondProgressDetail
func (*SecondProgressDetail) GetRecentProgressHistory ¶ added in v0.0.2
func (s *SecondProgressDetail) GetRecentProgressHistory() []*ProgressHistory
func (*SecondProgressDetail) GetRunningProgress ¶ added in v0.0.2
func (s *SecondProgressDetail) GetRunningProgress() string
func (*SecondProgressDetail) GetRunningStartTime ¶ added in v0.0.2
func (s *SecondProgressDetail) GetRunningStartTime() int64
func (*SecondProgressDetail) GetTodayBeginTime ¶ added in v0.0.2
func (s *SecondProgressDetail) GetTodayBeginTime() string
func (*SecondProgressDetail) GetTodayProgressCounter ¶ added in v0.0.2
func (s *SecondProgressDetail) GetTodayProgressCounter() *TaskProgressCounter
func (*SecondProgressDetail) GetYesterdayProgressCounter ¶ added in v0.0.2
func (s *SecondProgressDetail) GetYesterdayProgressCounter() *TaskProgressCounter
func (*SecondProgressDetail) SetRecentProgressHistory ¶ added in v0.0.2
func (s *SecondProgressDetail) SetRecentProgressHistory(recentProgressHistory []*ProgressHistory)
func (*SecondProgressDetail) SetRunningProgress ¶ added in v0.0.2
func (s *SecondProgressDetail) SetRunningProgress(runningProgress string)
func (*SecondProgressDetail) SetRunningStartTime ¶ added in v0.0.2
func (s *SecondProgressDetail) SetRunningStartTime(runningStartTime int64)
func (*SecondProgressDetail) SetTodayBeginTime ¶ added in v0.0.2
func (s *SecondProgressDetail) SetTodayBeginTime(todayBeginTime string)
func (*SecondProgressDetail) SetTodayProgressCounter ¶ added in v0.0.2
func (s *SecondProgressDetail) SetTodayProgressCounter(todayProgressCounter *TaskProgressCounter)
func (*SecondProgressDetail) SetYesterdayProgressCounter ¶ added in v0.0.2
func (s *SecondProgressDetail) SetYesterdayProgressCounter(yesterdayProgressCounter *TaskProgressCounter)
type ShardingTask ¶ added in v0.0.2
func NewShardingTask ¶ added in v0.0.2
func NewShardingTask(id int64, parameter string) *ShardingTask
func (*ShardingTask) GetId ¶ added in v0.0.2
func (t *ShardingTask) GetId() int64
func (*ShardingTask) GetParameter ¶ added in v0.0.2
func (t *ShardingTask) GetParameter() string
func (*ShardingTask) SetId ¶ added in v0.0.2
func (t *ShardingTask) SetId(id int64)
func (*ShardingTask) SetParameter ¶ added in v0.0.2
func (t *ShardingTask) SetParameter(parameter string)
type TaskDispatchMode ¶
type TaskDispatchMode string
TaskDispatchMode is the task execution mode
const ( TaskDispatchModePush TaskDispatchMode = "push" TaskDispatchModePull TaskDispatchMode = "pull" )
func (TaskDispatchMode) Description ¶
func (mode TaskDispatchMode) Description() string
type TaskInfo ¶ added in v0.0.2
type TaskInfo struct {
// contains filtered or unexported fields
}
func (*TaskInfo) JobInstanceId ¶ added in v0.0.2
func (*TaskInfo) SetJobInstanceId ¶ added in v0.0.2
func (*TaskInfo) SetTaskBody ¶ added in v0.0.2
func (*TaskInfo) SetTaskName ¶ added in v0.0.2
type TaskProgressCounter ¶ added in v0.0.2
type TaskProgressCounter struct { Name string `json:"name"` Total *atomic.Int64 `json:"total"` Pulled *atomic.Int64 `json:"pulled"` Running *atomic.Int64 `json:"running"` Success *atomic.Int64 `json:"success"` Failed *atomic.Int64 `json:"failed"` }
func NewTaskProgressCounter ¶ added in v0.0.2
func NewTaskProgressCounter(name string) (c *TaskProgressCounter)
func (*TaskProgressCounter) DecrementFailed ¶ added in v0.0.2
func (c *TaskProgressCounter) DecrementFailed()
func (*TaskProgressCounter) DecrementRunning ¶ added in v0.0.2
func (c *TaskProgressCounter) DecrementRunning()
func (*TaskProgressCounter) DecrementSuccess ¶ added in v0.0.2
func (c *TaskProgressCounter) DecrementSuccess()
func (*TaskProgressCounter) GetFailed ¶ added in v0.0.2
func (c *TaskProgressCounter) GetFailed() int64
func (*TaskProgressCounter) GetName ¶ added in v0.0.2
func (c *TaskProgressCounter) GetName() string
func (*TaskProgressCounter) GetPulled ¶ added in v0.0.2
func (c *TaskProgressCounter) GetPulled() int64
func (*TaskProgressCounter) GetRunning ¶ added in v0.0.2
func (c *TaskProgressCounter) GetRunning() int64
func (*TaskProgressCounter) GetSuccess ¶ added in v0.0.2
func (c *TaskProgressCounter) GetSuccess() int64
func (*TaskProgressCounter) GetTotal ¶ added in v0.0.2
func (c *TaskProgressCounter) GetTotal() int64
func (*TaskProgressCounter) IncrementFailed ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementFailed(delta int64)
func (*TaskProgressCounter) IncrementOneFailed ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementOneFailed()
func (*TaskProgressCounter) IncrementOnePulled ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementOnePulled()
func (*TaskProgressCounter) IncrementOneSuccess ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementOneSuccess()
func (*TaskProgressCounter) IncrementOneTotal ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementOneTotal()
func (*TaskProgressCounter) IncrementPulled ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementPulled(delta int64)
func (*TaskProgressCounter) IncrementRunning ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementRunning()
func (*TaskProgressCounter) IncrementRunning2 ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementRunning2(delta int64)
func (*TaskProgressCounter) IncrementSuccess ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementSuccess(delta int64)
func (*TaskProgressCounter) IncrementTotal ¶ added in v0.0.2
func (c *TaskProgressCounter) IncrementTotal(delta int64)
type TaskStatistics ¶ added in v0.0.2
type TaskStatistics struct {
// contains filtered or unexported fields
}
func NewTaskStatistics ¶ added in v0.0.2
func NewTaskStatistics() (rcvr *TaskStatistics)
func (*TaskStatistics) GetDistinctInstanceCount ¶ added in v0.0.2
func (rcvr *TaskStatistics) GetDistinctInstanceCount() int64
func (*TaskStatistics) GetTaskCount ¶ added in v0.0.2
func (rcvr *TaskStatistics) GetTaskCount() int64
func (*TaskStatistics) SetDistinctInstanceCount ¶ added in v0.0.2
func (rcvr *TaskStatistics) SetDistinctInstanceCount(distinctInstanceCount int64)
func (*TaskStatistics) SetTaskCount ¶ added in v0.0.2
func (rcvr *TaskStatistics) SetTaskCount(taskCount int64)
type WorkerBusyStatus ¶
type WorkerBusyStatus int32
const ( FREE WorkerBusyStatus = 0 LOAD5_BUSY WorkerBusyStatus = 1 HEAP5_BUSY WorkerBusyStatus = 2 DISK_BUSY WorkerBusyStatus = 3 )
func (WorkerBusyStatus) Descriptor ¶
func (status WorkerBusyStatus) Descriptor() string
type WorkerInfo ¶
type WorkerInfo struct {
// contains filtered or unexported fields
}
func NewWorkerInfo ¶
func NewWorkerInfo() *WorkerInfo
type WorkerProgressCounter ¶ added in v0.0.2
type WorkerProgressCounter struct { WorkerAddr string `json:"workerAddr"` Total *atomic.Int64 `json:"total"` Pulled *atomic.Int64 `json:"pulled"` Running *atomic.Int64 `json:"running"` Success *atomic.Int64 `json:"success"` Failed *atomic.Int64 `json:"failed"` }
func NewWorkerProgressCounter ¶ added in v0.0.2
func NewWorkerProgressCounter(workerAddr string) (c *WorkerProgressCounter)
func (*WorkerProgressCounter) DecrementFailed ¶ added in v0.0.2
func (c *WorkerProgressCounter) DecrementFailed()
func (*WorkerProgressCounter) DecrementRunning ¶ added in v0.0.2
func (c *WorkerProgressCounter) DecrementRunning(delta int64)
func (*WorkerProgressCounter) DecrementSuccess ¶ added in v0.0.2
func (c *WorkerProgressCounter) DecrementSuccess()
func (*WorkerProgressCounter) GetFailed ¶ added in v0.0.2
func (c *WorkerProgressCounter) GetFailed() int64
func (*WorkerProgressCounter) GetRunning ¶ added in v0.0.2
func (c *WorkerProgressCounter) GetRunning() int64
func (*WorkerProgressCounter) GetSuccess ¶ added in v0.0.2
func (c *WorkerProgressCounter) GetSuccess() int64
func (*WorkerProgressCounter) GetTotal ¶ added in v0.0.2
func (c *WorkerProgressCounter) GetTotal() int64
func (*WorkerProgressCounter) GetWorkerAddr ¶ added in v0.0.2
func (c *WorkerProgressCounter) GetWorkerAddr() string
func (*WorkerProgressCounter) IncrementFailed ¶ added in v0.0.2
func (c *WorkerProgressCounter) IncrementFailed(delta int64)
func (*WorkerProgressCounter) IncrementOneFailed ¶ added in v0.0.2
func (c *WorkerProgressCounter) IncrementOneFailed()
func (*WorkerProgressCounter) IncrementPulled ¶ added in v0.0.2
func (c *WorkerProgressCounter) IncrementPulled()
func (*WorkerProgressCounter) IncrementRunning ¶ added in v0.0.2
func (c *WorkerProgressCounter) IncrementRunning()
func (*WorkerProgressCounter) IncrementSuccess ¶ added in v0.0.2
func (c *WorkerProgressCounter) IncrementSuccess()
func (*WorkerProgressCounter) IncrementTotal ¶ added in v0.0.2
func (c *WorkerProgressCounter) IncrementTotal()
Source Files ¶
- app_group_info.go
- execute_mode.go
- job_instance_data.go
- job_instance_info.go
- log_config_info.go
- map_task_progress.go
- map_task_xattrs.go
- metrics.go
- progress_history.go
- second_progress_detail.go
- sharding_task.go
- task_dispatch_mode.go
- task_info.go
- task_progress_counter.go
- task_statistics.go
- time_type.go
- worker_info.go
- worker_progress_counter.go
Click to show internal directories.
Click to hide internal directories.