Documentation ¶
Index ¶
- type JobContext
- func (j *JobContext) AllWorkerAddrs() []string
- func (j *JobContext) Attempt() int32
- func (j *JobContext) Content() string
- func (j *JobContext) DataTime() time.Duration
- func (j *JobContext) ExecuteMode() string
- func (j *JobContext) GroupId() string
- func (j *JobContext) InstanceMasterActorPath() string
- func (j *JobContext) InstanceParameters() string
- func (j *JobContext) JobId() int64
- func (j *JobContext) JobInstanceId() int64
- func (j *JobContext) JobName() string
- func (j *JobContext) JobParameters() string
- func (j *JobContext) JobType() string
- func (j *JobContext) MaxAttempt() int32
- func (j *JobContext) ScheduleTime() time.Duration
- func (j *JobContext) SerialNum() int64
- func (j *JobContext) SetAllWorkerAddrs(allWorkerAddrs []string)
- func (j *JobContext) SetAttempt(attempt int32)
- func (j *JobContext) SetContent(content string)
- func (j *JobContext) SetDataTime(dataTime time.Duration)
- func (j *JobContext) SetExecuteMode(executeMode string)
- func (j *JobContext) SetGroupId(groupId string)
- func (j *JobContext) SetInstanceMasterActorPath(instanceMasterActorPath string)
- func (j *JobContext) SetInstanceParameters(instanceParameters string)
- func (j *JobContext) SetJobId(jobId int64)
- func (j *JobContext) SetJobInstanceId(jobInstanceId int64)
- func (j *JobContext) SetJobName(jobName string)
- func (j *JobContext) SetJobParameters(jobParameters string)
- func (j *JobContext) SetJobType(jobType string)
- func (j *JobContext) SetMaxAttempt(maxAttempt int32)
- func (j *JobContext) SetScheduleTime(scheduleTime time.Duration)
- func (j *JobContext) SetSerialNum(serialNum int64)
- func (j *JobContext) SetShardingId(shardingId int64)
- func (j *JobContext) SetShardingNum(shardingNum int32)
- func (j *JobContext) SetShardingParameter(shardingParameter string)
- func (j *JobContext) SetTask(task []byte)
- func (j *JobContext) SetTaskAttempt(taskAttempt int32)
- func (j *JobContext) SetTaskAttemptInterval(taskAttemptInterval int32)
- func (j *JobContext) SetTaskId(taskId int64)
- func (j *JobContext) SetTaskMaxAttempt(taskMaxAttempt int32)
- func (j *JobContext) SetTaskName(taskName string)
- func (j *JobContext) SetTaskResults(taskResults map[int64]string)
- func (j *JobContext) SetTaskStatuses(taskStatuses map[int64]taskstatus.TaskStatus)
- func (j *JobContext) SetTimeExpression(timeExpression string)
- func (j *JobContext) SetTimeType(timeType int32)
- func (j *JobContext) SetUpstreamData(upstreamData []*common.JobInstanceData)
- func (j *JobContext) SetUser(user string)
- func (j *JobContext) SetWfInstanceId(wfInstanceId int64)
- func (j *JobContext) SetWorkerAddr(workerAddr string)
- func (j *JobContext) ShardingId() int64
- func (j *JobContext) ShardingNum() int32
- func (j *JobContext) ShardingParameter() string
- func (j *JobContext) Task() []byte
- func (j *JobContext) TaskAttempt() int32
- func (j *JobContext) TaskAttemptInterval() int32
- func (j *JobContext) TaskId() int64
- func (j *JobContext) TaskMaxAttempt() int32
- func (j *JobContext) TaskName() string
- func (j *JobContext) TaskResults() map[int64]string
- func (j *JobContext) TaskStatuses() map[int64]taskstatus.TaskStatus
- func (j *JobContext) TimeExpression() string
- func (j *JobContext) TimeType() int32
- func (j *JobContext) UpstreamData() []*common.JobInstanceData
- func (j *JobContext) User() string
- func (j *JobContext) WfInstanceId() int64
- func (j *JobContext) WorkerAddr() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobContext ¶
func (*JobContext) AllWorkerAddrs ¶
func (j *JobContext) AllWorkerAddrs() []string
func (*JobContext) Attempt ¶
func (j *JobContext) Attempt() int32
func (*JobContext) Content ¶
func (j *JobContext) Content() string
func (*JobContext) DataTime ¶
func (j *JobContext) DataTime() time.Duration
func (*JobContext) ExecuteMode ¶
func (j *JobContext) ExecuteMode() string
func (*JobContext) GroupId ¶
func (j *JobContext) GroupId() string
func (*JobContext) InstanceMasterActorPath ¶
func (j *JobContext) InstanceMasterActorPath() string
func (*JobContext) InstanceParameters ¶
func (j *JobContext) InstanceParameters() string
func (*JobContext) JobId ¶
func (j *JobContext) JobId() int64
func (*JobContext) JobInstanceId ¶
func (j *JobContext) JobInstanceId() int64
func (*JobContext) JobName ¶
func (j *JobContext) JobName() string
func (*JobContext) JobParameters ¶
func (j *JobContext) JobParameters() string
func (*JobContext) JobType ¶
func (j *JobContext) JobType() string
func (*JobContext) MaxAttempt ¶
func (j *JobContext) MaxAttempt() int32
func (*JobContext) ScheduleTime ¶
func (j *JobContext) ScheduleTime() time.Duration
func (*JobContext) SerialNum ¶
func (j *JobContext) SerialNum() int64
func (*JobContext) SetAllWorkerAddrs ¶
func (j *JobContext) SetAllWorkerAddrs(allWorkerAddrs []string)
func (*JobContext) SetAttempt ¶
func (j *JobContext) SetAttempt(attempt int32)
func (*JobContext) SetContent ¶
func (j *JobContext) SetContent(content string)
func (*JobContext) SetDataTime ¶
func (j *JobContext) SetDataTime(dataTime time.Duration)
func (*JobContext) SetExecuteMode ¶
func (j *JobContext) SetExecuteMode(executeMode string)
func (*JobContext) SetGroupId ¶
func (j *JobContext) SetGroupId(groupId string)
func (*JobContext) SetInstanceMasterActorPath ¶
func (j *JobContext) SetInstanceMasterActorPath(instanceMasterActorPath string)
func (*JobContext) SetInstanceParameters ¶
func (j *JobContext) SetInstanceParameters(instanceParameters string)
func (*JobContext) SetJobId ¶
func (j *JobContext) SetJobId(jobId int64)
func (*JobContext) SetJobInstanceId ¶
func (j *JobContext) SetJobInstanceId(jobInstanceId int64)
func (*JobContext) SetJobName ¶
func (j *JobContext) SetJobName(jobName string)
func (*JobContext) SetJobParameters ¶
func (j *JobContext) SetJobParameters(jobParameters string)
func (*JobContext) SetJobType ¶
func (j *JobContext) SetJobType(jobType string)
func (*JobContext) SetMaxAttempt ¶
func (j *JobContext) SetMaxAttempt(maxAttempt int32)
func (*JobContext) SetScheduleTime ¶
func (j *JobContext) SetScheduleTime(scheduleTime time.Duration)
func (*JobContext) SetSerialNum ¶
func (j *JobContext) SetSerialNum(serialNum int64)
func (*JobContext) SetShardingId ¶
func (j *JobContext) SetShardingId(shardingId int64)
func (*JobContext) SetShardingNum ¶
func (j *JobContext) SetShardingNum(shardingNum int32)
func (*JobContext) SetShardingParameter ¶
func (j *JobContext) SetShardingParameter(shardingParameter string)
func (*JobContext) SetTask ¶
func (j *JobContext) SetTask(task []byte)
func (*JobContext) SetTaskAttempt ¶
func (j *JobContext) SetTaskAttempt(taskAttempt int32)
func (*JobContext) SetTaskAttemptInterval ¶
func (j *JobContext) SetTaskAttemptInterval(taskAttemptInterval int32)
func (*JobContext) SetTaskId ¶
func (j *JobContext) SetTaskId(taskId int64)
func (*JobContext) SetTaskMaxAttempt ¶
func (j *JobContext) SetTaskMaxAttempt(taskMaxAttempt int32)
func (*JobContext) SetTaskName ¶
func (j *JobContext) SetTaskName(taskName string)
func (*JobContext) SetTaskResults ¶
func (j *JobContext) SetTaskResults(taskResults map[int64]string)
func (*JobContext) SetTaskStatuses ¶
func (j *JobContext) SetTaskStatuses(taskStatuses map[int64]taskstatus.TaskStatus)
func (*JobContext) SetTimeExpression ¶
func (j *JobContext) SetTimeExpression(timeExpression string)
func (*JobContext) SetTimeType ¶
func (j *JobContext) SetTimeType(timeType int32)
func (*JobContext) SetUpstreamData ¶
func (j *JobContext) SetUpstreamData(upstreamData []*common.JobInstanceData)
func (*JobContext) SetUser ¶
func (j *JobContext) SetUser(user string)
func (*JobContext) SetWfInstanceId ¶
func (j *JobContext) SetWfInstanceId(wfInstanceId int64)
func (*JobContext) SetWorkerAddr ¶
func (j *JobContext) SetWorkerAddr(workerAddr string)
func (*JobContext) ShardingId ¶
func (j *JobContext) ShardingId() int64
func (*JobContext) ShardingNum ¶
func (j *JobContext) ShardingNum() int32
func (*JobContext) ShardingParameter ¶
func (j *JobContext) ShardingParameter() string
func (*JobContext) Task ¶
func (j *JobContext) Task() []byte
func (*JobContext) TaskAttempt ¶
func (j *JobContext) TaskAttempt() int32
func (*JobContext) TaskAttemptInterval ¶
func (j *JobContext) TaskAttemptInterval() int32
func (*JobContext) TaskId ¶
func (j *JobContext) TaskId() int64
func (*JobContext) TaskMaxAttempt ¶
func (j *JobContext) TaskMaxAttempt() int32
func (*JobContext) TaskName ¶
func (j *JobContext) TaskName() string
func (*JobContext) TaskResults ¶
func (j *JobContext) TaskResults() map[int64]string
func (*JobContext) TaskStatuses ¶
func (j *JobContext) TaskStatuses() map[int64]taskstatus.TaskStatus
func (*JobContext) TimeExpression ¶
func (j *JobContext) TimeExpression() string
func (*JobContext) TimeType ¶
func (j *JobContext) TimeType() int32
func (*JobContext) UpstreamData ¶
func (j *JobContext) UpstreamData() []*common.JobInstanceData
func (*JobContext) User ¶
func (j *JobContext) User() string
func (*JobContext) WfInstanceId ¶
func (j *JobContext) WfInstanceId() int64
func (*JobContext) WorkerAddr ¶
func (j *JobContext) WorkerAddr() string
Click to show internal directories.
Click to hide internal directories.