job

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, inputErr error)
• type Job
• type JobStatus
  • func (e JobStatus) IsRunning() bool
  • func (e JobStatus) IsValid() bool
  • func (e JobStatus) MarshalJSON() ([]byte, error)
  • func (e JobStatus) String() string
  • func (e *JobStatus) UnmarshalJSON(b []byte) error
• type Response
• type Subtask
  • func GetSubtask(cfg *target.BaseTargetConfig, jobID, jobType, subtaskId string, ...) (*Subtask, error)
  • func WaitForJobToComplete(jobID string, syncType string, subtaskId string, syncResult interface{}, ...) (*Subtask, error)
• type SubtaskEventUpdater
• type SubtaskResponse
• type Task
• type TaskEventUpdater
  • func NewTaskEventUpdater(cfg *target.BaseTargetConfig, jobId, jobType string) TaskEventUpdater
• type TaskPart

Variables

var AllJobStatus = []JobStatus{
	Started,
	InProgress,
	DataRetrieve,
	DataUpload,
	Queued,
	DataProcessing,
	Completed,
	Failed,
	Skipped,
}

Functions

func AddSubtaskEvent

func AddSubtaskEvent(cfg *target.BaseTargetConfig, jobID, jobType, subtask string, status JobStatus, receivedDate *int64)

func AddTaskEvent

func AddTaskEvent(cfg *target.BaseTargetConfig, jobID, jobType string, status JobStatus)

func StartJob

func StartJob(cfg *target.BaseTargetConfig) (string, error)

func UpdateJobEvent

func UpdateJobEvent(cfg *target.BaseTargetConfig, jobID string, status JobStatus, inputErr error)

Types

type Job

type Job struct {
	JobID *string `json:"jobId"`
}

type JobStatus

type JobStatus int

const (
	Started JobStatus = iota
	InProgress
	DataRetrieve
	DataUpload
	Queued
	DataProcessing
	Completed
	Failed
	Skipped
)

func (JobStatus) IsRunning

func (e JobStatus) IsRunning() bool

func (JobStatus) IsValid

func (e JobStatus) IsValid() bool

func (JobStatus) MarshalJSON

func (e JobStatus) MarshalJSON() ([]byte, error)

func (JobStatus) String

func (e JobStatus) String() string

func (*JobStatus) UnmarshalJSON

func (e *JobStatus) UnmarshalJSON(b []byte) error

type Response

type Response struct {
	Job Job `json:"createJob"`
}

type Subtask

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

func GetSubtask(cfg *target.BaseTargetConfig, jobID, jobType, subtaskId string, responseResult interface{}) (*Subtask, error)

func WaitForJobToComplete

func WaitForJobToComplete(jobID string, syncType string, subtaskId string, syncResult interface{}, cfg *target.BaseTargetConfig, currentStatus JobStatus) (*Subtask, error)

type SubtaskEventUpdater

type SubtaskEventUpdater interface {
	AddSubtaskEvent(status JobStatus)
	SetReceivedDate(receivedDate int64)
}

type SubtaskResponse

type SubtaskResponse struct {
	SubtaskResponse Subtask `json:"jobSubtask"`
}

type Task

type Task interface {
	IsClientValid(ctx context.Context, c plugin.PluginClient) (bool, error)
	GetParts() []TaskPart
}

type TaskEventUpdater

type TaskEventUpdater interface {
	AddTaskEvent(status JobStatus)
	GetSubtaskEventUpdater(subtask string) SubtaskEventUpdater
}

func NewTaskEventUpdater

func NewTaskEventUpdater(cfg *target.BaseTargetConfig, jobId, jobType string) TaskEventUpdater

type TaskPart

type TaskPart interface {
	StartSyncAndQueueTaskPart(c plugin.PluginClient, statusUpdater TaskEventUpdater) (JobStatus, string, error)
	ProcessResults(results interface{}) error
	GetResultObject() interface{}
}