Versions in this module Expand all Collapse all v1 v1.0.8 Dec 12, 2024 v1.0.7 Nov 6, 2024 v1.0.7-rc Nov 5, 2024 v1.0.6 Oct 24, 2024 v1.0.5 Oct 24, 2024 v1.0.4 Oct 18, 2024retracted v1.0.3 Oct 16, 2024retracted v1.0.2 Aug 12, 2024 v1.0.1 Apr 24, 2024 v1.0.0 Mar 25, 2024 v0 v0.0.4 Mar 8, 2024 v0.0.3 Jan 23, 2024 v0.0.2 Jan 20, 2024 Changes in this version + type AppGroupInfo struct + AppKey string + AppName string + EnableLog bool + GroupId string + Id int64 + LogConfigId int64 + LogConfigInfo *LogConfigInfo + MaxJobs int32 + NamespaceId string + Status int32 + Version int32 + func NewAppGroupInfo() (rcvr *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 string + const BatchExecuteMode + const BroadcastExecuteMode + const GridExecuteMode + const ParallelExecuteMode + const ShardingExecuteMode + const StandaloneExecuteMode + func (mode ExecuteMode) Description() string + type LogConfigInfo struct + Config string + Id int64 + LogType string + RegionId string + UserId string + func NewLogConfigInfo() (rcvr *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 struct + TaskProgress []*TaskProgressCounter + WorkerProgress []*WorkerProgressCounter + func NewMapTaskProgress() *MapTaskProgress + func (m *MapTaskProgress) GetTaskProgress() []*TaskProgressCounter + func (m *MapTaskProgress) GetWorkerProgress() []*WorkerProgressCounter + func (m *MapTaskProgress) SetTaskProgress(taskProgress []*TaskProgressCounter) + func (m *MapTaskProgress) SetWorkerProgress(workerProgress []*WorkerProgressCounter) + type ProgressHistory struct + func NewProgressHistory() (rcvr *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 struct + RecentProgressHistory []*ProgressHistory + RunningProgress string + RunningStartTime int64 + TodayBeginTime string + TodayProgressCounter *TaskProgressCounter + YesterdayProgressCounter *TaskProgressCounter + func NewSecondProgressDetail() *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 struct + Id int64 + Parameter string + func NewShardingTask(id int64, parameter string) *ShardingTask + func (t *ShardingTask) GetId() int64 + func (t *ShardingTask) GetParameter() string + func (t *ShardingTask) SetId(id int64) + func (t *ShardingTask) SetParameter(parameter string) + type TaskInfo struct + 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 struct + Failed *atomic.Int64 + Name string + Pulled *atomic.Int64 + Running *atomic.Int64 + Success *atomic.Int64 + Total *atomic.Int64 + func NewTaskProgressCounter(name string) (c *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 struct + func NewTaskStatistics() (rcvr *TaskStatistics) + func (rcvr *TaskStatistics) GetDistinctInstanceCount() int64 + func (rcvr *TaskStatistics) GetTaskCount() int64 + func (rcvr *TaskStatistics) SetDistinctInstanceCount(distinctInstanceCount int64) + func (rcvr *TaskStatistics) SetTaskCount(taskCount int64) + type WorkerProgressCounter struct + Failed *atomic.Int64 + Pulled *atomic.Int64 + Running *atomic.Int64 + Success *atomic.Int64 + Total *atomic.Int64 + WorkerAddr string + func NewWorkerProgressCounter(workerAddr string) (c *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() v0.0.1 Oct 20, 2023 Changes in this version + var TimeTypeClassName = map[TimeType]string + var TimeTypeDesc = map[TimeType]string + type JobInstanceData struct + Data string + JobName string + func (j *JobInstanceData) SetData(data string) + func (j *JobInstanceData) SetJobName(jobName string) + func (j JobInstanceData) GetData() string + func (j JobInstanceData) GetJobName() string + type JobInstanceInfo struct + func NewJobInstanceInfo() *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.Duration + 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.Duration + 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.Duration) + 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.Duration) + 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 MapTaskXAttrs struct + ConsumerSize int32 + DispatcherSize int32 + GlobalConsumerSize int32 + PageSize int32 + QueueSize int32 + TaskAttemptInterval int32 + TaskDispatchMode string + TaskMaxAttempt int32 + func NewMapTaskXAttrs() *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 struct + type TaskDispatchMode string + const TaskDispatchModePull + const TaskDispatchModePush + func (mode TaskDispatchMode) Description() string + type TaskStatus int32 + const TaskStatusFailed + const TaskStatusInit + const TaskStatusPulled + const TaskStatusRunning + const TaskStatusSucceed + const TaskStatusUnknown + func Convert2TaskStatus(val int32) (TaskStatus, bool) + func (status TaskStatus) Descriptor() string + func (status TaskStatus) IsFinished() bool + type TimeType int32 + const TimeTypeAPI + const TimeTypeCron + const TimeTypeFixedRate + const TimeTypeNone + const TimeTypeOneTime + const TimeTypeSecondDelay + const TimeTypeTemp + func (t TimeType) AutoNext() bool + func (t TimeType) Descriptor() string + type WorkerBusyStatus int32 + const DISK_BUSY + const FREE + const HEAP5_BUSY + const LOAD5_BUSY + func (status WorkerBusyStatus) Descriptor() string + type WorkerInfo struct + func NewWorkerInfo() *WorkerInfo
Go to main page