common

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

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 

type JobInstanceData struct {
	JobName string
	Data    string
}

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.Duration

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.Duration

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.Duration)

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.Duration)

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 

type ShardingTask struct {
	Id        int64  `json:"id"`
	Parameter string `json:"parameter"`
}

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) JobId added in v0.0.2 

func (t *TaskInfo) JobId() int64

func (*TaskInfo) JobInstanceId added in v0.0.2 

func (t *TaskInfo) JobInstanceId() int64

func (*TaskInfo) SetJobId added in v0.0.2 

func (t *TaskInfo) SetJobId(jobId int64)

func (*TaskInfo) SetJobInstanceId added in v0.0.2 

func (t *TaskInfo) SetJobInstanceId(jobInstanceId int64)

func (*TaskInfo) SetTaskBody added in v0.0.2 

func (t *TaskInfo) SetTaskBody(taskBody []byte)

func (*TaskInfo) SetTaskId added in v0.0.2 

func (t *TaskInfo) SetTaskId(taskId int64)

func (*TaskInfo) SetTaskName added in v0.0.2 

func (t *TaskInfo) SetTaskName(taskName string)

func (*TaskInfo) TaskBody added in v0.0.2 

func (t *TaskInfo) TaskBody() []byte

func (*TaskInfo) TaskId added in v0.0.2 

func (t *TaskInfo) TaskId() int64

func (*TaskInfo) TaskName added in v0.0.2 

func (t *TaskInfo) TaskName() string

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 TimeType 

type TimeType int32
const (
	TimeTypeNone        TimeType = -1
	TimeTypeCron        TimeType = 1
	TimeTypeFixedRate   TimeType = 3
	TimeTypeSecondDelay TimeType = 4
	TimeTypeOneTime     TimeType = 5

	TimeTypeAPI  TimeType = 100
	TimeTypeTemp TimeType = 101
)

func (TimeType) AutoNext 

func (t TimeType) AutoNext() bool

func (TimeType) Descriptor 

func (t TimeType) Descriptor() string

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.