model

package
v0.1.60 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicConfig added in v0.1.58 

type BasicConfig struct {

	// 作业责任人
	Owner *string `json:"owner,omitempty"`

	// 作业优先级
	Priority *int32 `json:"priority,omitempty"`

	// 作业执行用户
	ExecuteUser *string `json:"executeUser,omitempty"`

	// 实例超时时间
	InstanceTimeout *int32 `json:"instanceTimeout,omitempty"`

	// 用户自定义属性字段
	CustomFields *interface{} `json:"customFields,omitempty"`
}

func (BasicConfig) String added in v0.1.58 

func (o BasicConfig) String() string

type CancelScriptRequest 

type CancelScriptRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	ScriptName string `json:"script_name"`

	InstanceId string `json:"instance_id"`
}

CancelScriptRequest Request Object

func (CancelScriptRequest) String 

func (o CancelScriptRequest) String() string

type CancelScriptResponse 

type CancelScriptResponse struct {
	HttpStatusCode int `json:"-"`
}

CancelScriptResponse Response Object

func (CancelScriptResponse) String 

func (o CancelScriptResponse) String() string

type Condition 

type Condition struct {

	// 本节点依赖的前一个节点名称
	PreNodeName string `json:"preNodeName"`

	// EL表达式，如果EL表达式的计算结果为true，则触发执行本节点
	Expression string `json:"expression"`
}

func (Condition) String 

func (o Condition) String() string

type ConnectionInfo 

type ConnectionInfo struct {
	Name string `json:"name"`

	Type ConnectionInfoType `json:"type"`

	Config *interface{} `json:"config,omitempty"`

	Description *string `json:"description,omitempty"`
}

func (ConnectionInfo) String 

func (o ConnectionInfo) String() string

type ConnectionInfoType added in v0.0.78 

type ConnectionInfoType struct {
	// contains filtered or unexported fields
}

func (ConnectionInfoType) MarshalJSON added in v0.0.78 

func (c ConnectionInfoType) MarshalJSON() ([]byte, error)

func (*ConnectionInfoType) UnmarshalJSON added in v0.0.78 

func (c *ConnectionInfoType) UnmarshalJSON(b []byte) error

func (ConnectionInfoType) Value added in v0.0.90 

func (c ConnectionInfoType) Value() string

type ConnectionInfoTypeEnum added in v0.0.78 

type ConnectionInfoTypeEnum struct {
	DWS         ConnectionInfoType
	DLI         ConnectionInfoType
	SPARK_SQL   ConnectionInfoType
	HIVE        ConnectionInfoType
	RDS         ConnectionInfoType
	CLOUD_TABLE ConnectionInfoType
}

func GetConnectionInfoTypeEnum added in v0.0.78 

func GetConnectionInfoTypeEnum() ConnectionInfoTypeEnum

type ConnectionParam 

type ConnectionParam struct {
	Name *string `json:"name,omitempty"`

	ConnectionType *ConnectionParamConnectionType `json:"connectionType,omitempty"`

	Params *interface{} `json:"params,omitempty"`
}

func (ConnectionParam) String 

func (o ConnectionParam) String() string

type ConnectionParamConnectionType 

type ConnectionParamConnectionType struct {
	// contains filtered or unexported fields
}

func (ConnectionParamConnectionType) MarshalJSON 

func (c ConnectionParamConnectionType) MarshalJSON() ([]byte, error)

func (*ConnectionParamConnectionType) UnmarshalJSON 

func (c *ConnectionParamConnectionType) UnmarshalJSON(b []byte) error

func (ConnectionParamConnectionType) Value added in v0.0.90 

func (c ConnectionParamConnectionType) Value() string

type ConnectionParamConnectionTypeEnum 

type ConnectionParamConnectionTypeEnum struct {
	DWS         ConnectionParamConnectionType
	DLI         ConnectionParamConnectionType
	SPARK_SQL   ConnectionParamConnectionType
	HIVE        ConnectionParamConnectionType
	RDS         ConnectionParamConnectionType
	CLOUD_TABLE ConnectionParamConnectionType
}

func GetConnectionParamConnectionTypeEnum 

func GetConnectionParamConnectionTypeEnum() ConnectionParamConnectionTypeEnum

type CreateConnectionRequest 

type CreateConnectionRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *ConnectionInfo `json:"body,omitempty"`
}

CreateConnectionRequest Request Object

func (CreateConnectionRequest) String 

func (o CreateConnectionRequest) String() string

type CreateConnectionResponse 

type CreateConnectionResponse struct {
	HttpStatusCode int `json:"-"`
}

CreateConnectionResponse Response Object

func (CreateConnectionResponse) String 

func (o CreateConnectionResponse) String() string

type CreateJobRequest 

type CreateJobRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *JobInfo `json:"body,omitempty"`
}

CreateJobRequest Request Object

func (CreateJobRequest) String 

func (o CreateJobRequest) String() string

type CreateJobResponse 

type CreateJobResponse struct {
	HttpStatusCode int `json:"-"`
}

CreateJobResponse Response Object

func (CreateJobResponse) String 

func (o CreateJobResponse) String() string

type CreateResourceRequest 

type CreateResourceRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *ResourceInfo `json:"body,omitempty"`
}

CreateResourceRequest Request Object

func (CreateResourceRequest) String 

func (o CreateResourceRequest) String() string

type CreateResourceResponse 

type CreateResourceResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateResourceResponse Response Object

func (CreateResourceResponse) String 

func (o CreateResourceResponse) String() string

type CreateScriptRequest 

type CreateScriptRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *ScriptInfo `json:"body,omitempty"`
}

CreateScriptRequest Request Object

func (CreateScriptRequest) String 

func (o CreateScriptRequest) String() string

type CreateScriptResponse 

type CreateScriptResponse struct {
	HttpStatusCode int `json:"-"`
}

CreateScriptResponse Response Object

func (CreateScriptResponse) String 

func (o CreateScriptResponse) String() string

type CreateSupplementdataRequest added in v0.1.57 

type CreateSupplementdataRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *SupplementDataInfo `json:"body,omitempty"`
}

CreateSupplementdataRequest Request Object

func (CreateSupplementdataRequest) String added in v0.1.57 

func (o CreateSupplementdataRequest) String() string

type CreateSupplementdataResponse added in v0.1.57 

type CreateSupplementdataResponse struct {
	HttpStatusCode int `json:"-"`
}

CreateSupplementdataResponse Response Object

func (CreateSupplementdataResponse) String added in v0.1.57 

func (o CreateSupplementdataResponse) String() string

type Cron 

type Cron struct {

	// 调度开始时间，采用ISO 8601时间表示方法，格式为yyyy-MM-dd'T'HH:mm:ssZ，例如2018-10-22T23:59:59+08表示的时间为2018年10月22日23时59分59秒，在正8区，即北京时区
	StartTime string `json:"startTime"`

	// 调度结束时间，采用ISO 8601时间表示方法，格式为yyyy-MM-dd'T'HH:mm:ssZ，例如2018-10-22T23:59:59+08表示的时间为2018年10月22日23时59分59秒，在正8区，即北京时区。如果结束时间不配置，作业会按照调度周期一直执行下去
	EndTime *string `json:"endTime,omitempty"`

	// Cron表达式，格式为\"<秒> <分> <时> <天> <月> <星期>\"
	Expression string `json:"expression"`

	// Cron表达式对应的时区信息，例如GMT+8
	ExpressionTimeZone *string `json:"expressionTimeZone,omitempty"`

	// 是否依赖本作业上一个运行周期任务的执行结果
	DependPrePeriod *bool `json:"dependPrePeriod,omitempty"`

	DependJobs *DependJobs `json:"dependJobs,omitempty"`
}

func (Cron) String 

func (o Cron) String() string

type CronTrigger added in v0.1.58 

type CronTrigger struct {
	StartTime string `json:"startTime"`

	EndTime *string `json:"endTime,omitempty"`

	// Cron表达式
	Expression string `json:"expression"`

	// 时区
	ExpressionTimeZone *string `json:"expressionTimeZone,omitempty"`

	Period string `json:"period"`

	// 是否依赖本作业上一个运行周期任务的执行结果
	DependPrePeriod *bool `json:"dependPrePeriod,omitempty"`

	// 依赖其它作业列表
	DependJobs *[]DependJobs `json:"dependJobs,omitempty"`

	// 并发调用数
	Concurrent *int32 `json:"concurrent,omitempty"`
}

func (CronTrigger) String added in v0.1.58 

func (o CronTrigger) String() string

type DeleteConnctionRequest 

type DeleteConnctionRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 连接名称.
	ConnectionName string `json:"connection_name"`
}

DeleteConnctionRequest Request Object

func (DeleteConnctionRequest) String 

func (o DeleteConnctionRequest) String() string

type DeleteConnctionResponse 

type DeleteConnctionResponse struct {
	HttpStatusCode int `json:"-"`
}

DeleteConnctionResponse Response Object

func (DeleteConnctionResponse) String 

func (o DeleteConnctionResponse) String() string

type DeleteJobRequest 

type DeleteJobRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`
}

DeleteJobRequest Request Object

func (DeleteJobRequest) String 

func (o DeleteJobRequest) String() string

type DeleteJobResponse 

type DeleteJobResponse struct {
	HttpStatusCode int `json:"-"`
}

DeleteJobResponse Response Object

func (DeleteJobResponse) String 

func (o DeleteJobResponse) String() string

type DeleteResourceRequest 

type DeleteResourceRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 资源id.
	ResourceId string `json:"resource_id"`
}

DeleteResourceRequest Request Object

func (DeleteResourceRequest) String 

func (o DeleteResourceRequest) String() string

type DeleteResourceResponse 

type DeleteResourceResponse struct {
	HttpStatusCode int `json:"-"`
}

DeleteResourceResponse Response Object

func (DeleteResourceResponse) String 

func (o DeleteResourceResponse) String() string

type DeleteScriptRequest 

type DeleteScriptRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	ScriptName string `json:"script_name"`
}

DeleteScriptRequest Request Object

func (DeleteScriptRequest) String 

func (o DeleteScriptRequest) String() string

type DeleteScriptResponse 

type DeleteScriptResponse struct {
	HttpStatusCode int `json:"-"`
}

DeleteScriptResponse Response Object

func (DeleteScriptResponse) String 

func (o DeleteScriptResponse) String() string

type DependJobs added in v0.1.58 

type DependJobs struct {

	// 依赖的作业名称列表，必须依赖已存在的作业.
	Jobs []string `json:"jobs"`

	// 依赖周期
	DependPeriod *string `json:"dependPeriod,omitempty"`

	// 依赖作业任务执行失败处理策略
	DependFailPolicy *string `json:"dependFailPolicy,omitempty"`
}

func (DependJobs) String added in v0.1.58 

func (o DependJobs) String() string

type DependPackage added in v0.1.59 

type DependPackage struct {

	// 文件类型
	Type *string `json:"type,omitempty"`

	// 文件路径
	Location *string `json:"location,omitempty"`
}

DependPackage 依赖包信息

func (DependPackage) String added in v0.1.59 

func (o DependPackage) String() string

type Event 

type Event struct {

	// 事件类型
	EventType string `json:"eventType"`

	// DIS通道名称
	Channel string `json:"channel"`

	// 执行失败处理策略
	FailPolicy *string `json:"failPolicy,omitempty"`

	// 调度并发数
	Concurrent *int32 `json:"concurrent,omitempty"`

	// 读取策略，LAST ：从上次位置读取，NEW- 从最新位置读取，默认为LAST
	ReadPolicy *string `json:"readPolicy,omitempty"`
}

func (Event) String 

func (o Event) String() string

type ExecuteScriptReq 

type ExecuteScriptReq struct {

	// 脚本的执行参数
	Params *interface{} `json:"params,omitempty"`
}

func (ExecuteScriptReq) String 

func (o ExecuteScriptReq) String() string

type ExecuteScriptRequest 

type ExecuteScriptRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	ScriptName string `json:"script_name"`

	Body *ExecuteScriptReq `json:"body,omitempty"`
}

ExecuteScriptRequest Request Object

func (ExecuteScriptRequest) String 

func (o ExecuteScriptRequest) String() string

type ExecuteScriptResponse 

type ExecuteScriptResponse struct {
	InstanceId     *string `json:"instanceId,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ExecuteScriptResponse Response Object

func (ExecuteScriptResponse) String 

func (o ExecuteScriptResponse) String() string

type ExportConnectionsRequest 

type ExportConnectionsRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`
}

ExportConnectionsRequest Request Object

func (ExportConnectionsRequest) String 

func (o ExportConnectionsRequest) String() string

type ExportConnectionsResponse 

type ExportConnectionsResponse struct {
	HttpStatusCode int `json:"-"`
}

ExportConnectionsResponse Response Object

func (ExportConnectionsResponse) String 

func (o ExportConnectionsResponse) String() string

type ExportJobListRequest 

type ExportJobListRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *ExportJobsReq `json:"body,omitempty"`
}

ExportJobListRequest Request Object

func (ExportJobListRequest) String 

func (o ExportJobListRequest) String() string

type ExportJobListResponse 

type ExportJobListResponse struct {
	HttpStatusCode int `json:"-"`
}

ExportJobListResponse Response Object

func (ExportJobListResponse) String 

func (o ExportJobListResponse) String() string

type ExportJobRequest 

type ExportJobRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`
}

ExportJobRequest Request Object

func (ExportJobRequest) String 

func (o ExportJobRequest) String() string

type ExportJobResponse 

type ExportJobResponse struct {
	HttpStatusCode int `json:"-"`
}

ExportJobResponse Response Object

func (ExportJobResponse) String 

func (o ExportJobResponse) String() string

type ExportJobsReq 

type ExportJobsReq struct {
	JobList *[]string `json:"jobList,omitempty"`

	// 是否导出作业依赖的脚本和资源
	ExportDepend *bool `json:"exportDepend,omitempty"`
}

func (ExportJobsReq) String 

func (o ExportJobsReq) String() string

type FilePath 

type FilePath struct {

	// 文件在OBS上的路径
	Path *string `json:"path,omitempty"`
}

func (FilePath) String 

func (o FilePath) String() string

type ImportConnectionReq 

type ImportConnectionReq struct {
	Path *string `json:"path,omitempty"`

	// 连接参数
	Params *[]ConnectionParam `json:"params,omitempty"`

	SameNamePolicy *ImportConnectionReqSameNamePolicy `json:"sameNamePolicy,omitempty"`
}

func (ImportConnectionReq) String 

func (o ImportConnectionReq) String() string

type ImportConnectionReqSameNamePolicy 

type ImportConnectionReqSameNamePolicy struct {
	// contains filtered or unexported fields
}

func (ImportConnectionReqSameNamePolicy) MarshalJSON 

func (c ImportConnectionReqSameNamePolicy) MarshalJSON() ([]byte, error)

func (*ImportConnectionReqSameNamePolicy) UnmarshalJSON 

func (c *ImportConnectionReqSameNamePolicy) UnmarshalJSON(b []byte) error

func (ImportConnectionReqSameNamePolicy) Value added in v0.0.90 

func (c ImportConnectionReqSameNamePolicy) Value() string

type ImportConnectionReqSameNamePolicyEnum 

type ImportConnectionReqSameNamePolicyEnum struct {
	SKIP      ImportConnectionReqSameNamePolicy
	OVERWRITE ImportConnectionReqSameNamePolicy
}

func GetImportConnectionReqSameNamePolicyEnum 

func GetImportConnectionReqSameNamePolicyEnum() ImportConnectionReqSameNamePolicyEnum

type ImportConnectionsRequest 

type ImportConnectionsRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *ImportConnectionReq `json:"body,omitempty"`
}

ImportConnectionsRequest Request Object

func (ImportConnectionsRequest) String 

func (o ImportConnectionsRequest) String() string

type ImportConnectionsResponse 

type ImportConnectionsResponse struct {

	// 任务id
	TaskId         *string `json:"taskId,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ImportConnectionsResponse Response Object

func (ImportConnectionsResponse) String 

func (o ImportConnectionsResponse) String() string

type ImportFileReq 

type ImportFileReq struct {
	Path *string `json:"path,omitempty"`

	// 公共作业参数
	Params *interface{} `json:"params,omitempty"`

	SameNamePolicy *ImportFileReqSameNamePolicy `json:"sameNamePolicy,omitempty"`

	// 指定作业参数
	JobsParam *interface{} `json:"jobsParam,omitempty"`

	ExecuteUser *string `json:"executeUser,omitempty"`
}

func (ImportFileReq) String 

func (o ImportFileReq) String() string

type ImportFileReqSameNamePolicy 

type ImportFileReqSameNamePolicy struct {
	// contains filtered or unexported fields
}

func (ImportFileReqSameNamePolicy) MarshalJSON 

func (c ImportFileReqSameNamePolicy) MarshalJSON() ([]byte, error)

func (*ImportFileReqSameNamePolicy) UnmarshalJSON 

func (c *ImportFileReqSameNamePolicy) UnmarshalJSON(b []byte) error

func (ImportFileReqSameNamePolicy) Value added in v0.0.90 

func (c ImportFileReqSameNamePolicy) Value() string

type ImportFileReqSameNamePolicyEnum 

type ImportFileReqSameNamePolicyEnum struct {
	SKIP      ImportFileReqSameNamePolicy
	OVERWRITE ImportFileReqSameNamePolicy
}

func GetImportFileReqSameNamePolicyEnum 

func GetImportFileReqSameNamePolicyEnum() ImportFileReqSameNamePolicyEnum

type ImportJobRequest 

type ImportJobRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *ImportFileReq `json:"body,omitempty"`
}

ImportJobRequest Request Object

func (ImportJobRequest) String 

func (o ImportJobRequest) String() string

type ImportJobResponse 

type ImportJobResponse struct {

	// 任务id
	TaskId         *string `json:"taskId,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ImportJobResponse Response Object

func (ImportJobResponse) String 

func (o ImportJobResponse) String() string

type Job 

type Job struct {
	Name *string `json:"name,omitempty"`

	Path *string `json:"path,omitempty"`

	Params *interface{} `json:"params,omitempty"`
}

func (Job) String 

func (o Job) String() string

type JobAlarm added in v0.1.58 

type JobAlarm struct {

	// 告警类型
	AlarmType string `json:"alarmType"`

	TopicUrn string `json:"topicUrn"`
}

func (JobAlarm) String added in v0.1.58 

func (o JobAlarm) String() string

type JobApprover added in v0.1.58 

type JobApprover struct {

	// 审批人名称
	ApproverName string `json:"approverName"`
}

func (JobApprover) String added in v0.1.58 

func (o JobApprover) String() string

type JobInfo 

type JobInfo struct {

	// 作业名称
	Name string `json:"name"`

	// 节点定义
	Nodes []Node `json:"nodes"`

	Schedule *Schedule `json:"schedule"`

	// 作业参数定义
	Params *[]JobParam `json:"params,omitempty"`

	// 作业在目录树上的路径。创建作业时如果路径目录不存在，会自动创建目录，如/dir/a/，默认在根目录/。
	Directory *string `json:"directory,omitempty"`

	// 作业类型，REAL_TIME： 实时处理，BATCH：批处理
	ProcessType JobInfoProcessType `json:"processType"`

	// 作业最后修改人
	LastUpdateUser *string `json:"lastUpdateUser,omitempty"`

	// 作业运行日志存放的OBS路径。
	LogPath *string `json:"logPath,omitempty"`

	BasicConfig *BasicConfig `json:"basicConfig,omitempty"`

	// 在开启审批开关后，需要填写该字段。表示创建作业的目标状态，有三种状态：SAVED、SUBMITTED和PRODUCTION，分别表示作业创建后是保存态，提交态，生产态。
	TargetStatus *JobInfoTargetStatus `json:"targetStatus,omitempty"`

	// 在开启审批开关后，需要填写该字段，表示作业审批人。
	Approvers *[]JobApprover `json:"approvers,omitempty"`
}

func (JobInfo) String 

func (o JobInfo) String() string

type JobInfoProcessType added in v0.1.58 

type JobInfoProcessType struct {
	// contains filtered or unexported fields
}

func (JobInfoProcessType) MarshalJSON added in v0.1.58 

func (c JobInfoProcessType) MarshalJSON() ([]byte, error)

func (*JobInfoProcessType) UnmarshalJSON added in v0.1.58 

func (c *JobInfoProcessType) UnmarshalJSON(b []byte) error

func (JobInfoProcessType) Value added in v0.1.58 

func (c JobInfoProcessType) Value() string

type JobInfoProcessTypeEnum added in v0.1.58 

type JobInfoProcessTypeEnum struct {
	BATCH     JobInfoProcessType
	REAL_TIME JobInfoProcessType
}

func GetJobInfoProcessTypeEnum added in v0.1.58 

func GetJobInfoProcessTypeEnum() JobInfoProcessTypeEnum

type JobInfoTargetStatus added in v0.1.58 

type JobInfoTargetStatus struct {
	// contains filtered or unexported fields
}

func (JobInfoTargetStatus) MarshalJSON added in v0.1.58 

func (c JobInfoTargetStatus) MarshalJSON() ([]byte, error)

func (*JobInfoTargetStatus) UnmarshalJSON added in v0.1.58 

func (c *JobInfoTargetStatus) UnmarshalJSON(b []byte) error

func (JobInfoTargetStatus) Value added in v0.1.58 

func (c JobInfoTargetStatus) Value() string

type JobInfoTargetStatusEnum added in v0.1.58 

type JobInfoTargetStatusEnum struct {
	SAVED      JobInfoTargetStatus
	SUBMITTED  JobInfoTargetStatus
	PRODUCTION JobInfoTargetStatus
}

func GetJobInfoTargetStatusEnum added in v0.1.58 

func GetJobInfoTargetStatusEnum() JobInfoTargetStatusEnum

type JobInstance 

type JobInstance struct {

	// 作业名称。如果要查询指定批处理作业的实例列表，jobName就是批处理作业名。如果要查询实时作业下某个节点关联的子作业，jobName格式为[实时作业名称]_[节点名称]。
	JobName *string `json:"jobName,omitempty"`

	// 实例运行状态： - waiting：等待运行 - running：运行中 - success：运行成功 - fail： 运行失败 - running-exception：运行异常 - pause： 暂停 - manual-stop：取消
	Status *JobInstanceStatus `json:"status,omitempty"`

	// 作业实例计划执行时间
	PlanTime *int64 `json:"planTime,omitempty"`

	// 作业实例实际执行开始时间
	StartTime *int64 `json:"startTime,omitempty"`

	// 作业实例实际执行结束时间
	EndTime *int64 `json:"endTime,omitempty"`

	// 执行耗时，单位：毫秒
	ExecuteTime *int64 `json:"executeTime,omitempty"`

	// 作业提交运行时间
	SubmitTime *int64 `json:"submitTime,omitempty"`

	// 作业实例ID
	InstanceId *int64 `json:"instanceId,omitempty"`

	// 作业ID
	JobId *int64 `json:"jobId,omitempty"`

	// 作业实例运行时日志记录的实例名称, 非作业定义的名称
	JobInstanceName *string `json:"jobInstanceName,omitempty"`

	// 作业实例类型
	InstanceType *int32 `json:"instanceType,omitempty"`

	// 作业版本号
	Version *int32 `json:"version,omitempty"`

	// 作业成功状态，是否忽略成功
	IgnoreSuccess *bool `json:"ignoreSuccess,omitempty"`

	// 作业成功状态，是否强制成功
	ForceSuccess *bool `json:"forceSuccess,omitempty"`
}

func (JobInstance) String 

func (o JobInstance) String() string

type JobInstanceStatus added in v0.1.58 

type JobInstanceStatus struct {
	// contains filtered or unexported fields
}

func (JobInstanceStatus) MarshalJSON added in v0.1.58 

func (c JobInstanceStatus) MarshalJSON() ([]byte, error)

func (*JobInstanceStatus) UnmarshalJSON added in v0.1.58 

func (c *JobInstanceStatus) UnmarshalJSON(b []byte) error

func (JobInstanceStatus) Value added in v0.1.58 

func (c JobInstanceStatus) Value() string

type JobInstanceStatusEnum added in v0.1.58 

type JobInstanceStatusEnum struct {
	WAITING           JobInstanceStatus
	RUNNING           JobInstanceStatus
	SUCCESS           JobInstanceStatus
	FAIL              JobInstanceStatus
	RUNNING_EXCEPTION JobInstanceStatus
	PAUSE             JobInstanceStatus
	MANUAL_STOP       JobInstanceStatus
}

func GetJobInstanceStatusEnum added in v0.1.58 

func GetJobInstanceStatusEnum() JobInstanceStatusEnum

type JobParam 

type JobParam struct {
	Name string `json:"name"`

	Value string `json:"value"`

	// 参数类型
	Type *JobParamType `json:"type,omitempty"`
}

func (JobParam) String 

func (o JobParam) String() string

type JobParamType added in v0.1.58 

type JobParamType struct {
	// contains filtered or unexported fields
}

func (JobParamType) MarshalJSON added in v0.1.58 

func (c JobParamType) MarshalJSON() ([]byte, error)

func (*JobParamType) UnmarshalJSON added in v0.1.58 

func (c *JobParamType) UnmarshalJSON(b []byte) error

func (JobParamType) Value added in v0.1.58 

func (c JobParamType) Value() string

type JobParamTypeEnum added in v0.1.58 

type JobParamTypeEnum struct {
	PROCEDURE JobParamType
	VARIABLE  JobParamType
}

func GetJobParamTypeEnum added in v0.1.58 

func GetJobParamTypeEnum() JobParamTypeEnum

type JobResult added in v0.1.58 

type JobResult struct {

	// 作业名称
	Name string `json:"name"`

	// 作业类型
	JobType string `json:"jobType"`

	// 作业责任人，长度不能超过128个字符
	Owner *string `json:"owner,omitempty"`

	// 作业优先级，取值范围[0, 2]，默认值是0。0代表高优先级，1代表中优先级，2代表低优先级
	Priority *int32 `json:"priority,omitempty"`

	Status JobResultStatus `json:"status"`

	// 作业的创建者
	CreateUser string `json:"createUser"`

	// 作业的创建时间
	CreateTime int64 `json:"createTime"`

	// 作业的启动时间
	StartTime *int64 `json:"startTime,omitempty"`

	// 作业配置的结束时间
	EndTime *int64 `json:"endTime,omitempty"`

	// 作业最近一次运行实例状态，当jobType为BATCH时才有本字段
	LastInstanceStatus *string `json:"lastInstanceStatus,omitempty"`

	// 作业最近一次运行实例运行结束时间，当jobType为BATCH时才有本字段
	LastInstanceEndTime *int64 `json:"lastInstanceEndTime,omitempty"`

	// 作业最后一次更新时间
	LastUpdateTime *int64 `json:"lastUpdateTime,omitempty"`

	// 作业最后一次更新用户
	LastUpdateUser *string `json:"lastUpdateUser,omitempty"`

	// 作业的路径
	Path *string `json:"path,omitempty"`

	// 作业是否为单任务作业
	SingleNodeJobFlag *bool `json:"singleNodeJobFlag,omitempty"`

	// flink作业信息
	FlinkJobInfo *string `json:"flinkJobInfo,omitempty"`

	// 作业监控告警信息
	Alarms *[]JobAlarm `json:"alarms,omitempty"`
}

func (JobResult) String added in v0.1.58 

func (o JobResult) String() string

type JobResultStatus added in v0.1.58 

type JobResultStatus struct {
	// contains filtered or unexported fields
}

func (JobResultStatus) MarshalJSON added in v0.1.58 

func (c JobResultStatus) MarshalJSON() ([]byte, error)

func (*JobResultStatus) UnmarshalJSON added in v0.1.58 

func (c *JobResultStatus) UnmarshalJSON(b []byte) error

func (JobResultStatus) Value added in v0.1.58 

func (c JobResultStatus) Value() string

type JobResultStatusEnum added in v0.1.58 

type JobResultStatusEnum struct {
	STARTING   JobResultStatus
	NORMAL     JobResultStatus
	EXCEPTION  JobResultStatus
	STOPPING   JobResultStatus
	STOPPED    JobResultStatus
	SCHEDULING JobResultStatus
	PAUSED     JobResultStatus
}

func GetJobResultStatusEnum added in v0.1.58 

func GetJobResultStatusEnum() JobResultStatusEnum

type ListConnectionsRequest 

type ListConnectionsRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 分页参数：每页限定数量。范围[1,100]
	Limit *int32 `json:"limit,omitempty"`

	// 分页参数：页数
	Offset *int32 `json:"offset,omitempty"`

	// 连接名称.
	ConnectionName *string `json:"connectionName,omitempty"`
}

ListConnectionsRequest Request Object

func (ListConnectionsRequest) String 

func (o ListConnectionsRequest) String() string

type ListConnectionsResponse 

type ListConnectionsResponse struct {
	Total *int32 `json:"total,omitempty"`

	Connections    *[]ConnectionInfo `json:"connections,omitempty"`
	HttpStatusCode int               `json:"-"`
}

ListConnectionsResponse Response Object

func (ListConnectionsResponse) String 

func (o ListConnectionsResponse) String() string

type ListJobInstancesRequest 

type ListJobInstancesRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 分页参数:每页限定数量
	Limit *int32 `json:"limit,omitempty"`

	// 分页参数：页数
	Offset *int32 `json:"offset,omitempty"`

	// 返回作业实际开始时间大于minPlanTime的作业实例，单位为毫秒ms。
	MinPlanTime *int64 `json:"minPlanTime,omitempty"`

	// 返回作业实际开始时间小于maxPlanTime的作业实例，单位为毫秒ms。
	MaxPlanTime *int64 `json:"maxPlanTime,omitempty"`

	// 实例运行状态： - waiting：等待运行 - running：运行中 - success：运行成功 - fail： 运行失败 - running-exception：运行异常 - pause： 暂停 - manual-stop：取消
	Status *ListJobInstancesRequestStatus `json:"status,omitempty"`

	// 支持通过作业名进行精确查询。
	PreciseQuery *bool `json:"preciseQuery,omitempty"`

	// 作业名称。如果要查询指定批处理作业的实例列表，jobName就是批处理作业名称；如果要查询实时作业下某个节点关联的子作业，jobName格式为[实时作业名称]_[节点名称]。
	JobName *string `json:"jobName,omitempty"`

	// 作业调度方式： - 0：正常调度 - 2：手工调度 - 5：补数据 - 6：子作业调度 - 7：单次调度
	InstanceType *ListJobInstancesRequestInstanceType `json:"instanceType,omitempty"`
}

ListJobInstancesRequest Request Object

func (ListJobInstancesRequest) String 

func (o ListJobInstancesRequest) String() string

type ListJobInstancesRequestInstanceType added in v0.1.58 

type ListJobInstancesRequestInstanceType struct {
	// contains filtered or unexported fields
}

func (ListJobInstancesRequestInstanceType) MarshalJSON added in v0.1.58 

func (c ListJobInstancesRequestInstanceType) MarshalJSON() ([]byte, error)

func (*ListJobInstancesRequestInstanceType) UnmarshalJSON added in v0.1.58 

func (c *ListJobInstancesRequestInstanceType) UnmarshalJSON(b []byte) error

func (ListJobInstancesRequestInstanceType) Value added in v0.1.58 

func (c ListJobInstancesRequestInstanceType) Value() string

type ListJobInstancesRequestInstanceTypeEnum added in v0.1.58 

type ListJobInstancesRequestInstanceTypeEnum struct {
	E_0 ListJobInstancesRequestInstanceType
	E_2 ListJobInstancesRequestInstanceType
	E_5 ListJobInstancesRequestInstanceType
	E_6 ListJobInstancesRequestInstanceType
	E_7 ListJobInstancesRequestInstanceType
}

func GetListJobInstancesRequestInstanceTypeEnum added in v0.1.58 

func GetListJobInstancesRequestInstanceTypeEnum() ListJobInstancesRequestInstanceTypeEnum

type ListJobInstancesRequestStatus added in v0.1.58 

type ListJobInstancesRequestStatus struct {
	// contains filtered or unexported fields
}

func (ListJobInstancesRequestStatus) MarshalJSON added in v0.1.58 

func (c ListJobInstancesRequestStatus) MarshalJSON() ([]byte, error)

func (*ListJobInstancesRequestStatus) UnmarshalJSON added in v0.1.58 

func (c *ListJobInstancesRequestStatus) UnmarshalJSON(b []byte) error

func (ListJobInstancesRequestStatus) Value added in v0.1.58 

func (c ListJobInstancesRequestStatus) Value() string

type ListJobInstancesRequestStatusEnum added in v0.1.58 

type ListJobInstancesRequestStatusEnum struct {
	WAITING           ListJobInstancesRequestStatus
	RUNNING           ListJobInstancesRequestStatus
	SUCCESS           ListJobInstancesRequestStatus
	FAIL              ListJobInstancesRequestStatus
	RUNNING_EXCEPTION ListJobInstancesRequestStatus
	PAUSE             ListJobInstancesRequestStatus
	MANUAL_STOP       ListJobInstancesRequestStatus
}

func GetListJobInstancesRequestStatusEnum added in v0.1.58 

func GetListJobInstancesRequestStatusEnum() ListJobInstancesRequestStatusEnum

type ListJobInstancesResponse 

type ListJobInstancesResponse struct {
	Total *int32 `json:"total,omitempty"`

	Instances      *[]JobInstance `json:"instances,omitempty"`
	HttpStatusCode int            `json:"-"`
}

ListJobInstancesResponse Response Object

func (ListJobInstancesResponse) String 

func (o ListJobInstancesResponse) String() string

type ListJobsRequest 

type ListJobsRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 分页参数：每页限定数量
	Limit *int32 `json:"limit,omitempty"`

	// 分页参数：页数
	Offset *int32 `json:"offset,omitempty"`

	// 作业类型:  - REAL_TIME: 实时处理   - BATCH: 批处理
	JobType *ListJobsRequestJobType `json:"jobType,omitempty"`

	// 作业名称
	JobName *string `json:"jobName,omitempty"`
}

ListJobsRequest Request Object

func (ListJobsRequest) String 

func (o ListJobsRequest) String() string

type ListJobsRequestJobType added in v0.1.59 

type ListJobsRequestJobType struct {
	// contains filtered or unexported fields
}

func (ListJobsRequestJobType) MarshalJSON added in v0.1.59 

func (c ListJobsRequestJobType) MarshalJSON() ([]byte, error)

func (*ListJobsRequestJobType) UnmarshalJSON added in v0.1.59 

func (c *ListJobsRequestJobType) UnmarshalJSON(b []byte) error

func (ListJobsRequestJobType) Value added in v0.1.59 

func (c ListJobsRequestJobType) Value() string

type ListJobsRequestJobTypeEnum added in v0.1.59 

type ListJobsRequestJobTypeEnum struct {
	REAL_TIME ListJobsRequestJobType
	BATCH     ListJobsRequestJobType
}

func GetListJobsRequestJobTypeEnum added in v0.1.59 

func GetListJobsRequestJobTypeEnum() ListJobsRequestJobTypeEnum

type ListJobsResponse 

type ListJobsResponse struct {

	// 作业数量
	Total *int32 `json:"total,omitempty"`

	// 作业信息
	Jobs           *[]JobResult `json:"jobs,omitempty"`
	HttpStatusCode int          `json:"-"`
}

ListJobsResponse Response Object

func (ListJobsResponse) String 

func (o ListJobsResponse) String() string

type ListResourcesRequest 

type ListResourcesRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 分页参数:每页限定数量
	Limit *int32 `json:"limit,omitempty"`

	// 分页参数：页数
	Offset *int32 `json:"offset,omitempty"`

	// 资源名称
	ResourceName *string `json:"resourceName,omitempty"`
}

ListResourcesRequest Request Object

func (ListResourcesRequest) String 

func (o ListResourcesRequest) String() string

type ListResourcesResponse 

type ListResourcesResponse struct {

	// 总的资源个数
	Total *int32 `json:"total,omitempty"`

	// 资源列表
	Resources      *[]ResourceInfo `json:"resources,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ListResourcesResponse Response Object

func (ListResourcesResponse) String 

func (o ListResourcesResponse) String() string

type ListScriptResultsRequest 

type ListScriptResultsRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	ScriptName string `json:"script_name"`

	InstanceId string `json:"instance_id"`
}

ListScriptResultsRequest Request Object

func (ListScriptResultsRequest) String 

func (o ListScriptResultsRequest) String() string

type ListScriptResultsResponse 

type ListScriptResultsResponse struct {
	Status *string `json:"status,omitempty"`

	Result         *[]Result `json:"result,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ListScriptResultsResponse Response Object

func (ListScriptResultsResponse) String 

func (o ListScriptResultsResponse) String() string

type ListScriptsRequest 

type ListScriptsRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 分页参数:每页限定数量
	Limit *int32 `json:"limit,omitempty"`

	// 分页参数：页数
	Offset *int32 `json:"offset,omitempty"`

	// 脚本名称
	ScriptName *string `json:"scriptName,omitempty"`
}

ListScriptsRequest Request Object

func (ListScriptsRequest) String 

func (o ListScriptsRequest) String() string

type ListScriptsResponse 

type ListScriptsResponse struct {
	Total *int32 `json:"total,omitempty"`

	Scripts        *[]ScriptInfo `json:"scripts,omitempty"`
	HttpStatusCode int           `json:"-"`
}

ListScriptsResponse Response Object

func (ListScriptsResponse) String 

func (o ListScriptsResponse) String() string

type ListSupplementdataRequest added in v0.1.57 

type ListSupplementdataRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 排序字段:desc：创建时间按照降序展示asc ：创建时间按照升序展示默认值：desc
	Sort *string `json:"sort,omitempty"`

	// 分页列表的起始页，默认值为0。取值范围大于等于0。
	Page *string `json:"page,omitempty"`

	// 分页返回结果，指定每页最大记录数。默认值：10
	Size *string `json:"size,omitempty"`

	// 补数据名称
	Name *string `json:"name,omitempty"`

	// 用户名
	UserName *string `json:"userName,omitempty"`

	// 实例状态：SUCCESS：成功RUNNING ：运行中CANCLE：取消
	Status *string `json:"status,omitempty"`

	// 查询作业的开始日期 13位时间戳
	StartDate *string `json:"startDate,omitempty"`

	// 查询作业的结束日期 13位时间戳
	EndDate *string `json:"endDate,omitempty"`
}

ListSupplementdataRequest Request Object

func (ListSupplementdataRequest) String added in v0.1.57 

func (o ListSupplementdataRequest) String() string

type ListSupplementdataResponse added in v0.1.57 

type ListSupplementdataResponse struct {
	Msg *string `json:"msg,omitempty"`

	// 包含若干补数据实例信息
	Rows *[]SupplementDataResp `json:"rows,omitempty"`

	// 查询是否成功，取值为true或者false
	Success *bool `json:"success,omitempty"`

	// 补数据实例数量
	Total          *int32 `json:"total,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListSupplementdataResponse Response Object

func (ListSupplementdataResponse) String added in v0.1.57 

func (o ListSupplementdataResponse) String() string

type ListSystemTasksRequest 

type ListSystemTasksRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 系统任务id.
	TaskId string `json:"task_id"`
}

ListSystemTasksRequest Request Object

func (ListSystemTasksRequest) String 

func (o ListSystemTasksRequest) String() string

type ListSystemTasksResponse 

type ListSystemTasksResponse struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	StartTime *string `json:"startTime,omitempty"`

	EndTime *string `json:"endTime,omitempty"`

	LastUpdate *string `json:"lastUpdate,omitempty"`

	Status *ListSystemTasksResponseStatus `json:"status,omitempty"`

	Message *string `json:"message,omitempty"`

	SubTasks       *[]SubTaskStatus `json:"subTasks,omitempty"`
	HttpStatusCode int              `json:"-"`
}

ListSystemTasksResponse Response Object

func (ListSystemTasksResponse) String 

func (o ListSystemTasksResponse) String() string

type ListSystemTasksResponseStatus 

type ListSystemTasksResponseStatus struct {
	// contains filtered or unexported fields
}

func (ListSystemTasksResponseStatus) MarshalJSON 

func (c ListSystemTasksResponseStatus) MarshalJSON() ([]byte, error)

func (*ListSystemTasksResponseStatus) UnmarshalJSON 

func (c *ListSystemTasksResponseStatus) UnmarshalJSON(b []byte) error

func (ListSystemTasksResponseStatus) Value added in v0.0.90 

func (c ListSystemTasksResponseStatus) Value() string

type ListSystemTasksResponseStatusEnum 

type ListSystemTasksResponseStatusEnum struct {
	RUNNING    ListSystemTasksResponseStatus
	SUCCESSFUL ListSystemTasksResponseStatus
	FAILED     ListSystemTasksResponseStatus
}

func GetListSystemTasksResponseStatusEnum 

func GetListSystemTasksResponseStatusEnum() ListSystemTasksResponseStatusEnum

type Location 

type Location struct {
	X string `json:"x"`

	Y string `json:"y"`
}

func (Location) String 

func (o Location) String() string

type Node 

type Node struct {

	// 节点名称，只能包含六种字符：英文字母、数字、中文、中划线、下划线和点号，且长度小于等于128个字符。同一个作业中节点名称不能重复。
	Name string `json:"name"`

	// 节点的类型
	Type NodeType `json:"type"`

	Location *Location `json:"location"`

	// 本本节点依赖的前面的节点名称列表
	PreNodeName *[]string `json:"preNodeName,omitempty"`

	// 节点执行条件，如果配置此参数，本节点是否执行由condition的字段expression所保存的EL表达式计算结果决定
	Conditions *[]Condition `json:"conditions,omitempty"`

	// 节点属性
	Properties []Property `json:"properties"`

	// 轮询节点执行结果时间间隔
	PollingInterval *int32 `json:"pollingInterval,omitempty"`

	// 节点最大执行时间
	MaxExecutionTime *int32 `json:"maxExecutionTime,omitempty"`

	// 节点失败重试次数
	RetryTimes *int32 `json:"retryTimes,omitempty"`

	// 失败重试时间间隔
	RetryInterval *int32 `json:"retryInterval,omitempty"`

	// 作业失败策略
	FailPolicy *NodeFailPolicy `json:"failPolicy,omitempty"`

	EventTrigger *Event `json:"eventTrigger,omitempty"`

	CronTrigger *CronTrigger `json:"cronTrigger,omitempty"`
}

func (Node) String 

func (o Node) String() string

type NodeFailPolicy 

type NodeFailPolicy struct {
	// contains filtered or unexported fields
}

func (NodeFailPolicy) MarshalJSON 

func (c NodeFailPolicy) MarshalJSON() ([]byte, error)

func (*NodeFailPolicy) UnmarshalJSON 

func (c *NodeFailPolicy) UnmarshalJSON(b []byte) error

func (NodeFailPolicy) Value added in v0.0.90 

func (c NodeFailPolicy) Value() string

type NodeFailPolicyEnum 

type NodeFailPolicyEnum struct {
	FAIL       NodeFailPolicy
	IGNORE     NodeFailPolicy
	SUSPEND    NodeFailPolicy
	FAIL_CHILD NodeFailPolicy
}

func GetNodeFailPolicyEnum 

func GetNodeFailPolicyEnum() NodeFailPolicyEnum

type NodeInstance 

type NodeInstance struct {
	NodeName *string `json:"nodeName,omitempty"`

	Status *string `json:"status,omitempty"`

	PlanTime *int32 `json:"planTime,omitempty"`

	StartTime *int32 `json:"startTime,omitempty"`

	EndTime *int32 `json:"endTime,omitempty"`

	ExecuteTime *int32 `json:"executeTime,omitempty"`

	NodeType *string `json:"nodeType,omitempty"`

	RetryTimes *int32 `json:"retryTimes,omitempty"`

	InstanceId *int32 `json:"instanceId,omitempty"`

	InputRowCount *int32 `json:"inputRowCount,omitempty"`

	OutputRowCount *int32 `json:"outputRowCount,omitempty"`

	LogPath *string `json:"logPath,omitempty"`
}

func (NodeInstance) String 

func (o NodeInstance) String() string

type NodeType added in v0.1.58 

type NodeType struct {
	// contains filtered or unexported fields
}

func (NodeType) MarshalJSON added in v0.1.58 

func (c NodeType) MarshalJSON() ([]byte, error)

func (*NodeType) UnmarshalJSON added in v0.1.58 

func (c *NodeType) UnmarshalJSON(b []byte) error

func (NodeType) Value added in v0.1.58 

func (c NodeType) Value() string

type NodeTypeEnum added in v0.1.58 

type NodeTypeEnum struct {
	HIVE_SQL           NodeType
	SPARK_SQL          NodeType
	DWSSQL             NodeType
	DLISQL             NodeType
	SHELL              NodeType
	CDM_JOB            NodeType
	DIS_TRANSFER_TASK  NodeType
	CS_JOB             NodeType
	CLOUD_TABLE_MANAGE NodeType
	OBS_MANAGER        NodeType
	RESTAPI            NodeType
	MACHINE_LEARNING   NodeType
	SMN                NodeType
	MRS_SPARK          NodeType
	MAP_REDUCE         NodeType
	DLI_SPARK          NodeType
	MRS_FLINK          NodeType
	MRS_HETU_ENGINE    NodeType
	RDS_SQL            NodeType
}

func GetNodeTypeEnum added in v0.1.58 

func GetNodeTypeEnum() NodeTypeEnum

type Property added in v0.1.58 

type Property struct {

	// 属性名称
	Name string `json:"name"`

	// 属性值
	Value string `json:"value"`
}

func (Property) String added in v0.1.58 

func (o Property) String() string

type RealTimeNodeStatus 

type RealTimeNodeStatus struct {
	Name *string `json:"name,omitempty"`

	Status *RealTimeNodeStatusStatus `json:"status,omitempty"`

	LogPath *string `json:"logPath,omitempty"`

	NodeType *RealTimeNodeStatusNodeType `json:"nodeType,omitempty"`
}

func (RealTimeNodeStatus) String 

func (o RealTimeNodeStatus) String() string

type RealTimeNodeStatusNodeType 

type RealTimeNodeStatusNodeType struct {
	// contains filtered or unexported fields
}

func (RealTimeNodeStatusNodeType) MarshalJSON 

func (c RealTimeNodeStatusNodeType) MarshalJSON() ([]byte, error)

func (*RealTimeNodeStatusNodeType) UnmarshalJSON 

func (c *RealTimeNodeStatusNodeType) UnmarshalJSON(b []byte) error

func (RealTimeNodeStatusNodeType) Value added in v0.0.90 

func (c RealTimeNodeStatusNodeType) Value() string

type RealTimeNodeStatusNodeTypeEnum 

type RealTimeNodeStatusNodeTypeEnum struct {
	HIVE_SQL           RealTimeNodeStatusNodeType
	SPARK_SQL          RealTimeNodeStatusNodeType
	DWSSQL             RealTimeNodeStatusNodeType
	DLISQL             RealTimeNodeStatusNodeType
	SHELL              RealTimeNodeStatusNodeType
	CDM_JOB            RealTimeNodeStatusNodeType
	DIS_TRANSFER_TASK  RealTimeNodeStatusNodeType
	CS_JOB             RealTimeNodeStatusNodeType
	CLOUD_TABLE_MANAGE RealTimeNodeStatusNodeType
	OBS_MANAGER        RealTimeNodeStatusNodeType
	RESTAPI            RealTimeNodeStatusNodeType
	MACHINE_LEARNING   RealTimeNodeStatusNodeType
	SMN                RealTimeNodeStatusNodeType
	MRS_SPARK          RealTimeNodeStatusNodeType
	MAP_REDUCE         RealTimeNodeStatusNodeType
	DLI_SPARK          RealTimeNodeStatusNodeType
}

func GetRealTimeNodeStatusNodeTypeEnum 

func GetRealTimeNodeStatusNodeTypeEnum() RealTimeNodeStatusNodeTypeEnum

type RealTimeNodeStatusStatus 

type RealTimeNodeStatusStatus struct {
	// contains filtered or unexported fields
}

func (RealTimeNodeStatusStatus) MarshalJSON 

func (c RealTimeNodeStatusStatus) MarshalJSON() ([]byte, error)

func (*RealTimeNodeStatusStatus) UnmarshalJSON 

func (c *RealTimeNodeStatusStatus) UnmarshalJSON(b []byte) error

func (RealTimeNodeStatusStatus) Value added in v0.0.90 

func (c RealTimeNodeStatusStatus) Value() string

type RealTimeNodeStatusStatusEnum 

type RealTimeNodeStatusStatusEnum struct {
	STARTTING RealTimeNodeStatusStatus
	NORMAL    RealTimeNodeStatusStatus
	EXCEPTION RealTimeNodeStatusStatus
	STOPPING  RealTimeNodeStatusStatus
	STOPPED   RealTimeNodeStatusStatus
}

func GetRealTimeNodeStatusStatusEnum 

func GetRealTimeNodeStatusStatusEnum() RealTimeNodeStatusStatusEnum

type Relation added in v0.1.59 

type Relation struct {

	// 依赖类型
	RelationType *string `json:"relationType,omitempty"`

	// 作业名称
	TaskName *string `json:"taskName,omitempty"`

	// 作业ID
	TaskId *int64 `json:"taskId,omitempty"`

	// 脚本名称
	ScriptName *string `json:"scriptName,omitempty"`

	// 脚本ID
	ScriptId *string `json:"scriptId,omitempty"`

	// 用户名
	UserName *string `json:"userName,omitempty"`

	// 版本号
	Version *int32 `json:"version,omitempty"`

	// 依赖类型ID
	RelationId *string `json:"relationId,omitempty"`

	Deleted *bool `json:"deleted,omitempty"`
}

Relation 依赖的job信息

func (Relation) String added in v0.1.59 

func (o Relation) String() string

type ResourceInfo 

type ResourceInfo struct {

	// 资源id
	Id *string `json:"id,omitempty"`

	// 资源名称，只能包含英文字母、数字、中文字符、下划线或中划线。
	Name *string `json:"name,omitempty"`

	// 资源类型:   - archive: 压缩包   - file: 文件   - jar: jar文件   - pyFile：python文件
	Type *ResourceInfoType `json:"type,omitempty"`

	// 资源文件所在OBS路径
	Location *string `json:"location,omitempty"`

	// 主Jar包所依赖的JAR包、properties文件
	DependFiles *[]string `json:"dependFiles,omitempty"`

	// 资源描述
	Desc *string `json:"desc,omitempty"`

	// 资源所在目录
	Directory *string `json:"directory,omitempty"`

	// 主Jar包所依赖的JAR包、properties文件。同时存在dependFiles和dependPackages时，优先解析该字段。
	DependPackages *[]DependPackage `json:"dependPackages,omitempty"`

	// 通过jar包名称查询相关的job
	JobRelation *[]Relation `json:"jobRelation,omitempty"`
}

func (ResourceInfo) String 

func (o ResourceInfo) String() string

type ResourceInfoType 

type ResourceInfoType struct {
	// contains filtered or unexported fields
}

func (ResourceInfoType) MarshalJSON 

func (c ResourceInfoType) MarshalJSON() ([]byte, error)

func (*ResourceInfoType) UnmarshalJSON 

func (c *ResourceInfoType) UnmarshalJSON(b []byte) error

func (ResourceInfoType) Value added in v0.0.90 

func (c ResourceInfoType) Value() string

type ResourceInfoTypeEnum 

type ResourceInfoTypeEnum struct {
	ARCHIVE ResourceInfoType
	FILE    ResourceInfoType
	JAR     ResourceInfoType
	PY_FILE ResourceInfoType
}

func GetResourceInfoTypeEnum 

func GetResourceInfoTypeEnum() ResourceInfoTypeEnum

type RestoreJobInstanceRequest 

type RestoreJobInstanceRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`

	// 作业实例id.
	InstanceId string `json:"instance_id"`
}

RestoreJobInstanceRequest Request Object

func (RestoreJobInstanceRequest) String 

func (o RestoreJobInstanceRequest) String() string

type RestoreJobInstanceResponse 

type RestoreJobInstanceResponse struct {
	HttpStatusCode int `json:"-"`
}

RestoreJobInstanceResponse Response Object

func (RestoreJobInstanceResponse) String 

func (o RestoreJobInstanceResponse) String() string

type Result 

type Result struct {
	Message *string `json:"message,omitempty"`

	RowCount *int32 `json:"rowCount,omitempty"`

	Rows *string `json:"rows,omitempty"`

	Schema *string `json:"schema,omitempty"`
}

func (Result) String 

func (o Result) String() string

type RunOnceRequest 

type RunOnceRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`

	Body *StartJobReq `json:"body,omitempty"`
}

RunOnceRequest Request Object

func (RunOnceRequest) String 

func (o RunOnceRequest) String() string

type RunOnceResponse 

type RunOnceResponse struct {

	// 作业实例id
	InstanceId     *string `json:"instanceId,omitempty"`
	HttpStatusCode int     `json:"-"`
}

RunOnceResponse Response Object

func (RunOnceResponse) String 

func (o RunOnceResponse) String() string

type Schedule 

type Schedule struct {
	Type *ScheduleType `json:"type,omitempty"`

	Cron *Cron `json:"cron,omitempty"`

	Event *Event `json:"event,omitempty"`
}

func (Schedule) String 

func (o Schedule) String() string

type ScheduleType added in v0.1.58 

type ScheduleType struct {
	// contains filtered or unexported fields
}

func (ScheduleType) MarshalJSON added in v0.1.58 

func (c ScheduleType) MarshalJSON() ([]byte, error)

func (*ScheduleType) UnmarshalJSON added in v0.1.58 

func (c *ScheduleType) UnmarshalJSON(b []byte) error

func (ScheduleType) Value added in v0.1.58 

func (c ScheduleType) Value() string

type ScheduleTypeEnum added in v0.1.58 

type ScheduleTypeEnum struct {
	EXECUTE_ONCE  ScheduleType
	EVENT_TRIGGER ScheduleType
	RUN_ONCE      ScheduleType
	CRON          ScheduleType
	EVENT         ScheduleType
	SCHEDULE      ScheduleType
}

func GetScheduleTypeEnum added in v0.1.58 

func GetScheduleTypeEnum() ScheduleTypeEnum

type Script 

type Script struct {
	Name *string `json:"name,omitempty"`

	Path *string `json:"path,omitempty"`
}

func (Script) String 

func (o Script) String() string

type ScriptInfo 

type ScriptInfo struct {
	Name *string `json:"name,omitempty"`

	// 脚本类型
	Type *ScriptInfoType `json:"type,omitempty"`

	// 脚本关联的目录
	Directory *string `json:"directory,omitempty"`

	// 脚本内容
	Content *string `json:"content,omitempty"`

	// 脚本关联的连接名称
	ConnectionName *string `json:"connectionName,omitempty"`

	// 脚本执行所在的数据库
	Database *string `json:"database,omitempty"`

	// 脚本关联的DLI队列名称
	QueueName *string `json:"queueName,omitempty"`

	// 脚本的配置项参数
	Configuration *string `json:"configuration,omitempty"`
}

func (ScriptInfo) String 

func (o ScriptInfo) String() string

type ScriptInfoType 

type ScriptInfoType struct {
	// contains filtered or unexported fields
}

func (ScriptInfoType) MarshalJSON 

func (c ScriptInfoType) MarshalJSON() ([]byte, error)

func (*ScriptInfoType) UnmarshalJSON 

func (c *ScriptInfoType) UnmarshalJSON(b []byte) error

func (ScriptInfoType) Value added in v0.0.90 

func (c ScriptInfoType) Value() string

type ScriptInfoTypeEnum 

type ScriptInfoTypeEnum struct {
	FLINK_SQL ScriptInfoType
	DLISQL    ScriptInfoType
	SPARK_SQL ScriptInfoType
	HIVE_SQL  ScriptInfoType
	DWSSQL    ScriptInfoType
	SHELL     ScriptInfoType
}

func GetScriptInfoTypeEnum 

func GetScriptInfoTypeEnum() ScriptInfoTypeEnum

type ShowConnectionRequest 

type ShowConnectionRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 连接名称.
	ConnectionName string `json:"connection_name"`
}

ShowConnectionRequest Request Object

func (ShowConnectionRequest) String 

func (o ShowConnectionRequest) String() string

type ShowConnectionResponse 

type ShowConnectionResponse struct {
	Name *string `json:"name,omitempty"`

	Type *ShowConnectionResponseType `json:"type,omitempty"`

	Config *interface{} `json:"config,omitempty"`

	Description    *string `json:"description,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowConnectionResponse Response Object

func (ShowConnectionResponse) String 

func (o ShowConnectionResponse) String() string

type ShowConnectionResponseType added in v0.0.78 

type ShowConnectionResponseType struct {
	// contains filtered or unexported fields
}

func (ShowConnectionResponseType) MarshalJSON added in v0.0.78 

func (c ShowConnectionResponseType) MarshalJSON() ([]byte, error)

func (*ShowConnectionResponseType) UnmarshalJSON added in v0.0.78 

func (c *ShowConnectionResponseType) UnmarshalJSON(b []byte) error

func (ShowConnectionResponseType) Value added in v0.0.90 

func (c ShowConnectionResponseType) Value() string

type ShowConnectionResponseTypeEnum added in v0.0.78 

type ShowConnectionResponseTypeEnum struct {
	DWS         ShowConnectionResponseType
	DLI         ShowConnectionResponseType
	SPARK_SQL   ShowConnectionResponseType
	HIVE        ShowConnectionResponseType
	RDS         ShowConnectionResponseType
	CLOUD_TABLE ShowConnectionResponseType
}

func GetShowConnectionResponseTypeEnum added in v0.0.78 

func GetShowConnectionResponseTypeEnum() ShowConnectionResponseTypeEnum

type ShowFileInfoRequest 

type ShowFileInfoRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	Body *FilePath `json:"body,omitempty"`
}

ShowFileInfoRequest Request Object

func (ShowFileInfoRequest) String 

func (o ShowFileInfoRequest) String() string

type ShowFileInfoResponse 

type ShowFileInfoResponse struct {
	Jobs *[]Job `json:"jobs,omitempty"`

	Scripts        *[]Script `json:"scripts,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ShowFileInfoResponse Response Object

func (ShowFileInfoResponse) String 

func (o ShowFileInfoResponse) String() string

type ShowJobInstanceRequest 

type ShowJobInstanceRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`

	// 作业实例id.
	InstanceId string `json:"instance_id"`
}

ShowJobInstanceRequest Request Object

func (ShowJobInstanceRequest) String 

func (o ShowJobInstanceRequest) String() string

type ShowJobInstanceResponse 

type ShowJobInstanceResponse struct {
	Status *string `json:"status,omitempty"`

	PlanTime *int32 `json:"planTime,omitempty"`

	StartTime *int32 `json:"startTime,omitempty"`

	EndTime *int32 `json:"endTime,omitempty"`

	ExecuteTime *int32 `json:"executeTime,omitempty"`

	InstancesId *string `json:"instancesId,omitempty"`

	Total *int32 `json:"total,omitempty"`

	Nodes          *[]NodeInstance `json:"nodes,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ShowJobInstanceResponse Response Object

func (ShowJobInstanceResponse) String 

func (o ShowJobInstanceResponse) String() string

type ShowJobRequest 

type ShowJobRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`
}

ShowJobRequest Request Object

func (ShowJobRequest) String 

func (o ShowJobRequest) String() string

type ShowJobResponse 

type ShowJobResponse struct {

	// 作业名称
	Name *string `json:"name,omitempty"`

	// 节点定义
	Nodes *[]Node `json:"nodes,omitempty"`

	Schedule *Schedule `json:"schedule,omitempty"`

	// 作业参数定义
	Params *[]JobParam `json:"params,omitempty"`

	// 作业在目录树上的路径。创建作业时如果路径目录不存在，会自动创建目录，如/dir/a/，默认在根目录/。
	Directory *string `json:"directory,omitempty"`

	// 作业类型，REAL_TIME： 实时处理，BATCH：批处理
	ProcessType *ShowJobResponseProcessType `json:"processType,omitempty"`

	// 作业最后修改人
	LastUpdateUser *string `json:"lastUpdateUser,omitempty"`

	// 作业运行日志存放的OBS路径。
	LogPath *string `json:"logPath,omitempty"`

	BasicConfig *BasicConfig `json:"basicConfig,omitempty"`

	// 在开启审批开关后，需要填写该字段。表示创建作业的目标状态，有三种状态：SAVED、SUBMITTED和PRODUCTION，分别表示作业创建后是保存态，提交态，生产态。
	TargetStatus *ShowJobResponseTargetStatus `json:"targetStatus,omitempty"`

	// 在开启审批开关后，需要填写该字段，表示作业审批人。
	Approvers      *[]JobApprover `json:"approvers,omitempty"`
	HttpStatusCode int            `json:"-"`
}

ShowJobResponse Response Object

func (ShowJobResponse) String 

func (o ShowJobResponse) String() string

type ShowJobResponseProcessType added in v0.1.58 

type ShowJobResponseProcessType struct {
	// contains filtered or unexported fields
}

func (ShowJobResponseProcessType) MarshalJSON added in v0.1.58 

func (c ShowJobResponseProcessType) MarshalJSON() ([]byte, error)

func (*ShowJobResponseProcessType) UnmarshalJSON added in v0.1.58 

func (c *ShowJobResponseProcessType) UnmarshalJSON(b []byte) error

func (ShowJobResponseProcessType) Value added in v0.1.58 

func (c ShowJobResponseProcessType) Value() string

type ShowJobResponseProcessTypeEnum added in v0.1.58 

type ShowJobResponseProcessTypeEnum struct {
	BATCH     ShowJobResponseProcessType
	REAL_TIME ShowJobResponseProcessType
}

func GetShowJobResponseProcessTypeEnum added in v0.1.58 

func GetShowJobResponseProcessTypeEnum() ShowJobResponseProcessTypeEnum

type ShowJobResponseTargetStatus added in v0.1.58 

type ShowJobResponseTargetStatus struct {
	// contains filtered or unexported fields
}

func (ShowJobResponseTargetStatus) MarshalJSON added in v0.1.58 

func (c ShowJobResponseTargetStatus) MarshalJSON() ([]byte, error)

func (*ShowJobResponseTargetStatus) UnmarshalJSON added in v0.1.58 

func (c *ShowJobResponseTargetStatus) UnmarshalJSON(b []byte) error

func (ShowJobResponseTargetStatus) Value added in v0.1.58 

func (c ShowJobResponseTargetStatus) Value() string

type ShowJobResponseTargetStatusEnum added in v0.1.58 

type ShowJobResponseTargetStatusEnum struct {
	SAVED      ShowJobResponseTargetStatus
	SUBMITTED  ShowJobResponseTargetStatus
	PRODUCTION ShowJobResponseTargetStatus
}

func GetShowJobResponseTargetStatusEnum added in v0.1.58 

func GetShowJobResponseTargetStatusEnum() ShowJobResponseTargetStatusEnum

type ShowJobStatusRequest 

type ShowJobStatusRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`
}

ShowJobStatusRequest Request Object

func (ShowJobStatusRequest) String 

func (o ShowJobStatusRequest) String() string

type ShowJobStatusResponse 

type ShowJobStatusResponse struct {
	Name *string `json:"name,omitempty"`

	Status *ShowJobStatusResponseStatus `json:"status,omitempty"`

	Starttime *string `json:"starttime,omitempty"`

	EndTime *string `json:"endTime,omitempty"`

	// 状态最后更新时间
	LastUpdateTime *string `json:"lastUpdateTime,omitempty"`

	Nodes          *[]RealTimeNodeStatus `json:"nodes,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

ShowJobStatusResponse Response Object

func (ShowJobStatusResponse) String 

func (o ShowJobStatusResponse) String() string

type ShowJobStatusResponseStatus 

type ShowJobStatusResponseStatus struct {
	// contains filtered or unexported fields
}

func (ShowJobStatusResponseStatus) MarshalJSON 

func (c ShowJobStatusResponseStatus) MarshalJSON() ([]byte, error)

func (*ShowJobStatusResponseStatus) UnmarshalJSON 

func (c *ShowJobStatusResponseStatus) UnmarshalJSON(b []byte) error

func (ShowJobStatusResponseStatus) Value added in v0.0.90 

func (c ShowJobStatusResponseStatus) Value() string

type ShowJobStatusResponseStatusEnum 

type ShowJobStatusResponseStatusEnum struct {
	STARTTING ShowJobStatusResponseStatus
	NORMAL    ShowJobStatusResponseStatus
	EXCEPTION ShowJobStatusResponseStatus
	STOPPING  ShowJobStatusResponseStatus
	STOPPED   ShowJobStatusResponseStatus
}

func GetShowJobStatusResponseStatusEnum 

func GetShowJobStatusResponseStatusEnum() ShowJobStatusResponseStatusEnum

type ShowResourceRequest 

type ShowResourceRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 资源id.
	ResourceId string `json:"resource_id"`
}

ShowResourceRequest Request Object

func (ShowResourceRequest) String 

func (o ShowResourceRequest) String() string

type ShowResourceResponse 

type ShowResourceResponse struct {

	// 资源id
	Id *string `json:"id,omitempty"`

	// 资源名称，只能包含英文字母、数字、中文字符、下划线或中划线。
	Name *string `json:"name,omitempty"`

	// 资源类型:   - archive: 压缩包   - file: 文件   - jar: jar文件   - pyFile：python文件
	Type *ShowResourceResponseType `json:"type,omitempty"`

	// 资源文件所在OBS路径
	Location *string `json:"location,omitempty"`

	// 主Jar包所依赖的JAR包、properties文件
	DependFiles *[]string `json:"dependFiles,omitempty"`

	// 资源描述
	Desc *string `json:"desc,omitempty"`

	// 资源所在目录
	Directory *string `json:"directory,omitempty"`

	// 主Jar包所依赖的JAR包、properties文件。同时存在dependFiles和dependPackages时，优先解析该字段。
	DependPackages *[]DependPackage `json:"dependPackages,omitempty"`

	// 通过jar包名称查询相关的job
	JobRelation    *[]Relation `json:"jobRelation,omitempty"`
	HttpStatusCode int         `json:"-"`
}

ShowResourceResponse Response Object

func (ShowResourceResponse) String 

func (o ShowResourceResponse) String() string

type ShowResourceResponseType 

type ShowResourceResponseType struct {
	// contains filtered or unexported fields
}

func (ShowResourceResponseType) MarshalJSON 

func (c ShowResourceResponseType) MarshalJSON() ([]byte, error)

func (*ShowResourceResponseType) UnmarshalJSON 

func (c *ShowResourceResponseType) UnmarshalJSON(b []byte) error

func (ShowResourceResponseType) Value added in v0.0.90 

func (c ShowResourceResponseType) Value() string

type ShowResourceResponseTypeEnum 

type ShowResourceResponseTypeEnum struct {
	ARCHIVE ShowResourceResponseType
	FILE    ShowResourceResponseType
	JAR     ShowResourceResponseType
	PY_FILE ShowResourceResponseType
}

func GetShowResourceResponseTypeEnum 

func GetShowResourceResponseTypeEnum() ShowResourceResponseTypeEnum

type ShowScriptRequest 

type ShowScriptRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	ScriptName string `json:"script_name"`
}

ShowScriptRequest Request Object

func (ShowScriptRequest) String 

func (o ShowScriptRequest) String() string

type ShowScriptResponse 

type ShowScriptResponse struct {
	Name *string `json:"name,omitempty"`

	// 脚本类型
	Type *ShowScriptResponseType `json:"type,omitempty"`

	// 脚本关联的目录
	Directory *string `json:"directory,omitempty"`

	// 脚本内容
	Content *string `json:"content,omitempty"`

	// 脚本关联的连接名称
	ConnectionName *string `json:"connectionName,omitempty"`

	// 脚本执行所在的数据库
	Database *string `json:"database,omitempty"`

	// 脚本关联的DLI队列名称
	QueueName *string `json:"queueName,omitempty"`

	// 脚本的配置项参数
	Configuration  *string `json:"configuration,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowScriptResponse Response Object

func (ShowScriptResponse) String 

func (o ShowScriptResponse) String() string

type ShowScriptResponseType 

type ShowScriptResponseType struct {
	// contains filtered or unexported fields
}

func (ShowScriptResponseType) MarshalJSON 

func (c ShowScriptResponseType) MarshalJSON() ([]byte, error)

func (*ShowScriptResponseType) UnmarshalJSON 

func (c *ShowScriptResponseType) UnmarshalJSON(b []byte) error

func (ShowScriptResponseType) Value added in v0.0.90 

func (c ShowScriptResponseType) Value() string

type ShowScriptResponseTypeEnum 

type ShowScriptResponseTypeEnum struct {
	FLINK_SQL ShowScriptResponseType
	DLISQL    ShowScriptResponseType
	SPARK_SQL ShowScriptResponseType
	HIVE_SQL  ShowScriptResponseType
	DWSSQL    ShowScriptResponseType
	SHELL     ShowScriptResponseType
}

func GetShowScriptResponseTypeEnum 

func GetShowScriptResponseTypeEnum() ShowScriptResponseTypeEnum

type StartJobReq 

type StartJobReq struct {
	JobParams *[]JobParam `json:"jobParams,omitempty"`
}

func (StartJobReq) String 

func (o StartJobReq) String() string

type StartJobRequest 

type StartJobRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`

	Body *StartJobReq `json:"body,omitempty"`
}

StartJobRequest Request Object

func (StartJobRequest) String 

func (o StartJobRequest) String() string

type StartJobResponse 

type StartJobResponse struct {
	HttpStatusCode int `json:"-"`
}

StartJobResponse Response Object

func (StartJobResponse) String 

func (o StartJobResponse) String() string

type StopJobInstanceRequest 

type StopJobInstanceRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`

	// 作业实例id.
	InstanceId string `json:"instance_id"`
}

StopJobInstanceRequest Request Object

func (StopJobInstanceRequest) String 

func (o StopJobInstanceRequest) String() string

type StopJobInstanceResponse 

type StopJobInstanceResponse struct {
	HttpStatusCode int `json:"-"`
}

StopJobInstanceResponse Response Object

func (StopJobInstanceResponse) String 

func (o StopJobInstanceResponse) String() string

type StopJobRequest 

type StopJobRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`
}

StopJobRequest Request Object

func (StopJobRequest) String 

func (o StopJobRequest) String() string

type StopJobResponse 

type StopJobResponse struct {
	HttpStatusCode int `json:"-"`
}

StopJobResponse Response Object

func (StopJobResponse) String 

func (o StopJobResponse) String() string

type StopSupplementdataRequest added in v0.1.57 

type StopSupplementdataRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 补数据名称.
	InstanceName string `json:"instanceName"`
}

StopSupplementdataRequest Request Object

func (StopSupplementdataRequest) String added in v0.1.57 

func (o StopSupplementdataRequest) String() string

type StopSupplementdataResponse added in v0.1.57 

type StopSupplementdataResponse struct {
	HttpStatusCode int `json:"-"`
}

StopSupplementdataResponse Response Object

func (StopSupplementdataResponse) String added in v0.1.57 

func (o StopSupplementdataResponse) String() string

type SubTaskStatus 

type SubTaskStatus struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	StartTime *string `json:"startTime,omitempty"`

	EndTime *string `json:"endTime,omitempty"`

	LastUpdate *string `json:"lastUpdate,omitempty"`

	Status *SubTaskStatusStatus `json:"status,omitempty"`
}

func (SubTaskStatus) String 

func (o SubTaskStatus) String() string

type SubTaskStatusStatus 

type SubTaskStatusStatus struct {
	// contains filtered or unexported fields
}

func (SubTaskStatusStatus) MarshalJSON 

func (c SubTaskStatusStatus) MarshalJSON() ([]byte, error)

func (*SubTaskStatusStatus) UnmarshalJSON 

func (c *SubTaskStatusStatus) UnmarshalJSON(b []byte) error

func (SubTaskStatusStatus) Value added in v0.0.90 

func (c SubTaskStatusStatus) Value() string

type SubTaskStatusStatusEnum 

type SubTaskStatusStatusEnum struct {
	RUNNING    SubTaskStatusStatus
	SUCCESSFUL SubTaskStatusStatus
	FAILED     SubTaskStatusStatus
}

func GetSubTaskStatusStatusEnum 

func GetSubTaskStatusStatusEnum() SubTaskStatusStatusEnum

type SupplementDataInfo added in v0.1.57 

type SupplementDataInfo struct {

	// 补数据实例名称
	Name *string `json:"name,omitempty"`

	// 补数据依赖的作业名称
	JobName *string `json:"jobName,omitempty"`

	// 补数据开始时间
	StartDate *string `json:"startDate,omitempty"`

	// 补数据结束时间
	EndDate *string `json:"endDate,omitempty"`

	// 并行周期数
	Parallel *int32 `json:"parallel,omitempty"`

	// 依赖的作业信息
	DependJobs *[]JobInfo `json:"dependJobs,omitempty"`

	// 是否按天粒度补数据
	IsDayGranularity *bool `json:"isDayGranularity,omitempty"`

	// 优先级
	Priority *int32 `json:"priority,omitempty"`

	// 失败时作业是否停止
	IsStopWhenFail *bool `json:"is_stop_when_fail,omitempty"`

	// 按照时间倒序补跑
	ReverseOrder *int32 `json:"reverseOrder,omitempty"`

	// 当前有补数据实例在运行时，是否强制补数据
	Force *string `json:"force,omitempty"`

	SupplementDataRunTime *SupplementDataInfoSupplementDataRunTime `json:"supplement_data_run_time,omitempty"`

	SupplementDataInstanceTime *SupplementDataInfoSupplementDataInstanceTime `json:"supplement_data_instance_time,omitempty"`
}

func (SupplementDataInfo) String added in v0.1.57 

func (o SupplementDataInfo) String() string

type SupplementDataInfoSupplementDataInstanceTime added in v0.1.59 

type SupplementDataInfoSupplementDataInstanceTime struct {

	// 离散的天
	Days *[]string `json:"days,omitempty"`

	// 指定天中的时间段
	TimeOfDay *string `json:"time_of_day,omitempty"`
}

SupplementDataInfoSupplementDataInstanceTime 离散的日期补数据

func (SupplementDataInfoSupplementDataInstanceTime) String added in v0.1.59 

func (o SupplementDataInfoSupplementDataInstanceTime) String() string

type SupplementDataInfoSupplementDataRunTime added in v0.1.59 

type SupplementDataInfoSupplementDataRunTime struct {

	// 每天的可补数据时间段，如：每天的10点15分到23点30分，表示：10:15-23:30
	TimeOfDay *string `json:"time_of_day,omitempty"`

	// 每周的星期几可以补数据，如：每周一，周三的每天10点15分到23点30分。
	DayOfWeek *string `json:"day_of_week,omitempty"`

	// 每个月的哪几天可以补数据，如每月1号，3号，表示：1,3
	DayOfMonth *string `json:"day_of_month,omitempty"`
}

SupplementDataInfoSupplementDataRunTime 运行时间段

func (SupplementDataInfoSupplementDataRunTime) String added in v0.1.59 

func (o SupplementDataInfoSupplementDataRunTime) String() string

type SupplementDataResp added in v0.1.57 

type SupplementDataResp struct {

	// 作业的开始日期 13位时间戳
	EndDate *int64 `json:"endDate,omitempty"`

	// 补数据作业名称，可能有依赖的作业，故会有多个作业的情况。
	JobList *[]string `json:"jobList,omitempty"`

	// 补数据名称
	Name *string `json:"name,omitempty"`

	// 并行周期数，取值范围[1,5]
	Parallel *int32 `json:"parallel,omitempty"`

	// 作业的结束日期 13位时间戳
	StartDate *int64 `json:"startDate,omitempty"`

	// 实例状态：SUCCESS：成功RUNNING ：运行中CANCLE：取消
	Status *string `json:"status,omitempty"`

	// 作业提交时间，13位时间戳
	SubmittedDate *int64 `json:"submittedDate,omitempty"`

	SupplementDataInstanceTime *SupplementDataRespSupplementDataInstanceTime `json:"supplement_data_instance_time,omitempty"`

	SupplementDataRunTime *SupplementDataRespSupplementDataRunTime `json:"supplement_data_run_time,omitempty"`

	// 触发补数据的类型，取值范围[0, 1]。0代表作业监控界面触发的补数据，1代表恢复动作触发的补数据
	Type *int32 `json:"type,omitempty"`

	// 用户名称
	UserName *string `json:"userName,omitempty"`
}

func (SupplementDataResp) String added in v0.1.57 

func (o SupplementDataResp) String() string

type SupplementDataRespSupplementDataInstanceTime added in v0.1.59 

type SupplementDataRespSupplementDataInstanceTime struct {

	// 支持离散的天
	Days *[]string `json:"days,omitempty"`

	// 一天中的时间段
	TimeOfDay *string `json:"time_of_day,omitempty"`
}

SupplementDataRespSupplementDataInstanceTime 支持补离散时间任务

func (SupplementDataRespSupplementDataInstanceTime) String added in v0.1.59 

func (o SupplementDataRespSupplementDataInstanceTime) String() string

type SupplementDataRespSupplementDataRunTime added in v0.1.59 

type SupplementDataRespSupplementDataRunTime struct {

	// 每天的可补数据时间段，如：每天的10点15分到23点30分，表示：10:15-23:30
	TimeOfDay *string `json:"time_of_day,omitempty"`

	// 每周的星期几可以补数据，如：每周一，周三的每天10点15分到23点30分
	DayOfWeek *string `json:"day_of_week,omitempty"`

	// 每个月的哪几天可以补数据，如每月1号，3号，表示：1,3
	DayOfMonth *string `json:"day_of_month,omitempty"`
}

SupplementDataRespSupplementDataRunTime 补数据时间段，当前仅支持每天，如果没有补数据时间，则默认为\"00:00-00:00”

func (SupplementDataRespSupplementDataRunTime) String added in v0.1.59 

func (o SupplementDataRespSupplementDataRunTime) String() string

type UpdateConnectionRequest 

type UpdateConnectionRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 连接名称.
	ConnectionName string `json:"connection_name"`

	Body *ConnectionInfo `json:"body,omitempty"`
}

UpdateConnectionRequest Request Object

func (UpdateConnectionRequest) String 

func (o UpdateConnectionRequest) String() string

type UpdateConnectionResponse 

type UpdateConnectionResponse struct {
	HttpStatusCode int `json:"-"`
}

UpdateConnectionResponse Response Object

func (UpdateConnectionResponse) String 

func (o UpdateConnectionResponse) String() string

type UpdateJobRequest 

type UpdateJobRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 作业名称.
	JobName string `json:"job_name"`

	Body *JobInfo `json:"body,omitempty"`
}

UpdateJobRequest Request Object

func (UpdateJobRequest) String 

func (o UpdateJobRequest) String() string

type UpdateJobResponse 

type UpdateJobResponse struct {
	HttpStatusCode int `json:"-"`
}

UpdateJobResponse Response Object

func (UpdateJobResponse) String 

func (o UpdateJobResponse) String() string

type UpdateResourceRequest 

type UpdateResourceRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	// 资源id.
	ResourceId string `json:"resource_id"`

	Body *ResourceInfo `json:"body,omitempty"`
}

UpdateResourceRequest Request Object

func (UpdateResourceRequest) String 

func (o UpdateResourceRequest) String() string

type UpdateResourceResponse 

type UpdateResourceResponse struct {
	HttpStatusCode int `json:"-"`
}

UpdateResourceResponse Response Object

func (UpdateResourceResponse) String 

func (o UpdateResourceResponse) String() string

type UpdateScriptRequest 

type UpdateScriptRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,omitempty"`

	ScriptName string `json:"script_name"`

	Body *ScriptInfo `json:"body,omitempty"`
}

UpdateScriptRequest Request Object

func (UpdateScriptRequest) String 

func (o UpdateScriptRequest) String() string

type UpdateScriptResponse 

type UpdateScriptResponse struct {
	HttpStatusCode int `json:"-"`
}

UpdateScriptResponse Response Object

func (UpdateScriptResponse) String 

func (o UpdateScriptResponse) String() string

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.