Documentation
¶
Index ¶
- Variables
- func AddSubtaskEvent(cfg *target.BaseTargetConfig, jobID, jobType, subtask string, status JobStatus, ...)
- func AddTaskEvent(cfg *target.BaseTargetConfig, jobID, jobType string, status JobStatus)
- func StartJob(cfg *target.BaseTargetConfig) (string, error)
- func UpdateJobEvent(cfg *target.BaseTargetConfig, jobID string, status JobStatus)
- type Job
- type JobStatus
- type Response
- type Subtask
- type SubtaskEventUpdater
- type SubtaskResponse
- type TaskEventUpdater
Constants ¶
This section is empty.
Variables ¶
View Source
var AllJobStatus = []JobStatus{ Started, InProgress, DataRetrieve, DataUpload, Queued, DataProcessing, Completed, Failed, Skipped, }
Functions ¶
func AddSubtaskEvent ¶ added in v0.17.0
func AddSubtaskEvent(cfg *target.BaseTargetConfig, jobID, jobType, subtask string, status JobStatus, receivedDate *int64)
func AddTaskEvent ¶ added in v0.17.0
func AddTaskEvent(cfg *target.BaseTargetConfig, jobID, jobType string, status JobStatus)
func UpdateJobEvent ¶ added in v0.17.0
func UpdateJobEvent(cfg *target.BaseTargetConfig, jobID string, status JobStatus)
Types ¶
type JobStatus ¶ added in v0.16.0
type JobStatus int
func (JobStatus) MarshalJSON ¶ added in v0.16.0
func (*JobStatus) UnmarshalJSON ¶ added in v0.16.0
type Subtask ¶ added in v0.17.0
type Subtask struct {
JobID string `json:"jobId"`
JobType string `json:"jobType"`
SubtaskId string `json:"subtaskId"`
Status JobStatus `json:"status"`
LastUpdate time.Time `json:"lastUpdate"`
Result interface{} `json:"result"`
Errors []string `json:"errors"`
}
func GetSubtask ¶ added in v0.17.0
func GetSubtask(cfg *target.BaseTargetConfig, jobID, jobType, subtaskId string, responseResult interface{}) (*Subtask, error)
type SubtaskEventUpdater ¶ added in v0.19.0
type SubtaskEventUpdater struct {
Cfg *target.BaseTargetConfig
JobId string
JobType string
Subtask string
// contains filtered or unexported fields
}
func (*SubtaskEventUpdater) AddSubtaskEvent ¶ added in v0.19.0
func (u *SubtaskEventUpdater) AddSubtaskEvent(status JobStatus)
func (*SubtaskEventUpdater) SetReceivedDate ¶ added in v0.19.0
func (u *SubtaskEventUpdater) SetReceivedDate(receivedDate int64)
type SubtaskResponse ¶ added in v0.17.0
type SubtaskResponse struct {
SubtaskResponse Subtask `json:"jobSubtask"`
}
type TaskEventUpdater ¶ added in v0.19.0
type TaskEventUpdater struct {
Cfg *target.BaseTargetConfig
JobId string
JobType string
}
func (*TaskEventUpdater) AddTaskEvent ¶ added in v0.19.0
func (u *TaskEventUpdater) AddTaskEvent(status JobStatus)
func (*TaskEventUpdater) GetSubtaskEventUpdater ¶ added in v0.19.0
func (u *TaskEventUpdater) GetSubtaskEventUpdater(subtask string) SubtaskEventUpdater
Click to show internal directories.
Click to hide internal directories.