job

package

v0.16.1 Latest Latest Go to latest Published: Aug 31, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/raito-io/cli

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AddJobEvent(cfg *target.BaseTargetConfig, jobID, jobType, status string)
func StartJob(cfg *target.BaseTargetConfig) (string, error)
type Job
type JobStatus
- func GetTaskStatus(cfg *target.BaseTargetConfig, jobID, jobType string, ...) (*JobStatus, error)
type Response
type Task
type TaskStatusResponse

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

func AddJobEvent ¶

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

func StartJob ¶

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

Types ¶

type Job ¶

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

type JobStatus ¶ added in v0.16.0

type JobStatus int

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

func GetTaskStatus ¶ added in v0.16.0

func GetTaskStatus(cfg *target.BaseTargetConfig, jobID, jobType string, responseResult interface{}) (*JobStatus, error)

func (JobStatus) IsRunning ¶ added in v0.16.0

func (e JobStatus) IsRunning() bool

func (JobStatus) IsValid ¶ added in v0.16.0

func (e JobStatus) IsValid() bool

func (JobStatus) MarshalJSON ¶ added in v0.16.0

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

func (JobStatus) String ¶ added in v0.16.0

func (e JobStatus) String() string

func (*JobStatus) UnmarshalJSON ¶ added in v0.16.0

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

type Response ¶

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

type Task ¶ added in v0.16.0

type Task struct {
	JobID      string      `json:"jobId"`
	JobType    string      `json:"jobType"`
	Status     JobStatus   `json:"status"`
	LastUpdate time.Time   `json:"lastUpdate"`
	Result     interface{} `json:"result"`
}

type TaskStatusResponse ¶ added in v0.16.0

type TaskStatusResponse struct {
	TaskResponse Task `json:"jobTask"`
}

Source Files ¶

View all Source files

job.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL