model

package
v0.1.49 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 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 BasicInfo 

type BasicInfo struct {

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

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

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

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

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

func (BasicInfo) String 

func (o BasicInfo) 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,omitempty"`

	Expression *string `json:"expression,omitempty"`
}

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 

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

func (ConnectionInfoType) MarshalJSON 

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

func (*ConnectionInfoType) UnmarshalJSON 

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

func (ConnectionInfoType) Value 

func (c ConnectionInfoType) Value() string

type ConnectionInfoTypeEnum 

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

func GetConnectionInfoTypeEnum 

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 

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 Cron 

type Cron struct {
	StartTime *string `json:"startTime,omitempty"`

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

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

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

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

func (Cron) String 

func (o Cron) 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 DependJob 

type DependJob struct {
	Jobs *string `json:"jobs,omitempty"`

	DependPeriod *string `json:"dependPeriod,omitempty"`

	DependFailPolicy *DependJobDependFailPolicy `json:"dependFailPolicy,omitempty"`
}

func (DependJob) String 

func (o DependJob) String() string

type DependJobDependFailPolicy 

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

func (DependJobDependFailPolicy) MarshalJSON 

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

func (*DependJobDependFailPolicy) UnmarshalJSON 

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

func (DependJobDependFailPolicy) Value 

func (c DependJobDependFailPolicy) Value() string

type DependJobDependFailPolicyEnum 

type DependJobDependFailPolicyEnum struct {
	FAIL    DependJobDependFailPolicy
	IGNORE  DependJobDependFailPolicy
	SUSPEND DependJobDependFailPolicy
}

func GetDependJobDependFailPolicyEnum 

func GetDependJobDependFailPolicyEnum() DependJobDependFailPolicyEnum

type DirectoryTreeResp 

type DirectoryTreeResp struct {
	ParentDirectoryId *string `json:"parent_directory_id,omitempty"`

	DirectoryName *string `json:"directory_name,omitempty"`

	CategoryType *string `json:"category_type,omitempty"`

	DirectoryId *string `json:"directory_id,omitempty"`

	Paging *bool `json:"paging,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	Count *int32 `json:"count,omitempty"`

	Elements *[]TreeNodeElement `json:"elements,omitempty"`

	SubDirectories *[]DirectoryTreeResp `json:"sub_directories,omitempty"`
}

func (DirectoryTreeResp) String 

func (o DirectoryTreeResp) String() string

type Event 

type Event struct {

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

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

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

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

	// 读取策略
	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 

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 

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 JobInfo 

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

	Id *int32 `json:"id,omitempty"`

	Nodes *[]Node `json:"nodes,omitempty"`

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

	Params *[]JobParam `json:"params,omitempty"`

	Directory *string `json:"directory,omitempty"`

	JobType *JobInfoJobType `json:"jobType,omitempty"`

	LastUpdateUser *string `json:"lastUpdateUser,omitempty"`

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

func (JobInfo) String 

func (o JobInfo) String() string

type JobInfoJobType 

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

func (JobInfoJobType) MarshalJSON 

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

func (*JobInfoJobType) UnmarshalJSON 

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

func (JobInfoJobType) Value 

func (c JobInfoJobType) Value() string

type JobInfoJobTypeEnum 

type JobInfoJobTypeEnum struct {
	BATCH     JobInfoJobType
	REAL_TIME JobInfoJobType
}

func GetJobInfoJobTypeEnum 

func GetJobInfoJobTypeEnum() JobInfoJobTypeEnum

type JobInstance 

type JobInstance struct {
	JobName *string `json:"jobName,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"`

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

func (JobInstance) String 

func (o JobInstance) String() string

type JobParam 

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

	Value *string `json:"value,omitempty"`

	ParamType *JobParamParamType `json:"paramType,omitempty"`
}

func (JobParam) String 

func (o JobParam) String() string

type JobParamParamType 

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

func (JobParamParamType) MarshalJSON 

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

func (*JobParamParamType) UnmarshalJSON 

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

func (JobParamParamType) Value 

func (c JobParamParamType) Value() string

type JobParamParamTypeEnum 

type JobParamParamTypeEnum struct {
	VARIABLE  JobParamParamType
	CONSTANTS JobParamParamType
}

func GetJobParamParamTypeEnum 

func GetJobParamParamTypeEnum() JobParamParamTypeEnum

type ListConnectionsRequest 

type ListConnectionsRequest struct {

	// 工作空间id
	Workspace *string `json:"workspace,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"`
}

ListJobInstancesRequest Request Object

func (ListJobInstancesRequest) String 

func (o ListJobInstancesRequest) String() string

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"`
}

ListJobsRequest Request Object

func (ListJobsRequest) String 

func (o ListJobsRequest) String() string

type ListJobsResponse 

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

	Jobs           *[]JobInfo `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"`
}

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"`
}

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 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 

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 *int32 `json:"x,omitempty"`

	Y *int32 `json:"y,omitempty"`
}

func (Location) String 

func (o Location) String() string

type Node 

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

	// 节点的类型
	NodeType *NodeNodeType `json:"nodeType,omitempty"`

	Location *Location `json:"location,omitempty"`

	// 本节点依赖的前一个节点名称
	PreNodeNames *string `json:"preNodeNames,omitempty"`

	// 节点执行条件
	Condition *[]Condition `json:"condition,omitempty"`

	// 节点的属性
	NodeProperties *string `json:"nodeProperties,omitempty"`

	// 轮询节点执行结果时间间隔
	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 *Cron `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 

func (c NodeFailPolicy) Value() string

type NodeFailPolicyEnum 

type NodeFailPolicyEnum struct {
	FAIL    NodeFailPolicy
	IGNORE  NodeFailPolicy
	SUSPEND 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 NodeNodeType 

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

func (NodeNodeType) MarshalJSON 

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

func (*NodeNodeType) UnmarshalJSON 

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

func (NodeNodeType) Value 

func (c NodeNodeType) Value() string

type NodeNodeTypeEnum 

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

func GetNodeNodeTypeEnum 

func GetNodeNodeTypeEnum() NodeNodeTypeEnum

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 

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 

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 ResourceInfo 

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

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

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

	DependFiles *[]string `json:"dependFiles,omitempty"`

	Desc *string `json:"desc,omitempty"`

	// 资源所在目录
	Directory *string `json:"directory,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 

func (c ResourceInfoType) Value() string

type ResourceInfoTypeEnum 

type ResourceInfoTypeEnum struct {
	ARCHIVE ResourceInfoType
	FILE    ResourceInfoType
	JAR     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 {
	ScheType *ScheduleScheType `json:"scheType,omitempty"`

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

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

func (Schedule) String 

func (o Schedule) String() string

type ScheduleScheType 

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

func (ScheduleScheType) MarshalJSON 

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

func (*ScheduleScheType) UnmarshalJSON 

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

func (ScheduleScheType) Value 

func (c ScheduleScheType) Value() string

type ScheduleScheTypeEnum 

type ScheduleScheTypeEnum struct {
	EXECUTE_ONCE ScheduleScheType
	CRON         ScheduleScheType
	EVENT        ScheduleScheType
}

func GetScheduleScheTypeEnum 

func GetScheduleScheTypeEnum() ScheduleScheTypeEnum

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 

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 

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

func (ShowConnectionResponseType) MarshalJSON 

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

func (*ShowConnectionResponseType) UnmarshalJSON 

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

func (ShowConnectionResponseType) Value 

func (c ShowConnectionResponseType) Value() string

type ShowConnectionResponseTypeEnum 

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

func GetShowConnectionResponseTypeEnum 

func GetShowConnectionResponseTypeEnum() ShowConnectionResponseTypeEnum

type ShowDirectoryTreeRequest 

type ShowDirectoryTreeRequest struct {

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

	// 查询的目录节点类型.
	Category *string `json:"category,omitempty"`

	// 目录编号.
	DirectoryId *string `json:"directory_id,omitempty"`

	// 目标元素名称.
	Name *string `json:"name,omitempty"`

	// 查询偏移量.
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量.
	Limit *int32 `json:"limit,omitempty"`
}

ShowDirectoryTreeRequest Request Object

func (ShowDirectoryTreeRequest) String 

func (o ShowDirectoryTreeRequest) String() string

type ShowDirectoryTreeResponse 

type ShowDirectoryTreeResponse struct {
	ParentDirectoryId *string `json:"parent_directory_id,omitempty"`

	DirectoryName *string `json:"directory_name,omitempty"`

	CategoryType *string `json:"category_type,omitempty"`

	DirectoryId *string `json:"directory_id,omitempty"`

	Paging *bool `json:"paging,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	Count *int32 `json:"count,omitempty"`

	Elements *[]TreeNodeElement `json:"elements,omitempty"`

	SubDirectories *[]DirectoryTreeResp `json:"sub_directories,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

ShowDirectoryTreeResponse Response Object

func (ShowDirectoryTreeResponse) String 

func (o ShowDirectoryTreeResponse) String() string

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"`

	Id *int32 `json:"id,omitempty"`

	Nodes *[]Node `json:"nodes,omitempty"`

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

	Params *[]JobParam `json:"params,omitempty"`

	Directory *string `json:"directory,omitempty"`

	JobType *ShowJobResponseJobType `json:"jobType,omitempty"`

	LastUpdateUser *string `json:"lastUpdateUser,omitempty"`

	BasicConfig    *BasicInfo `json:"basicConfig,omitempty"`
	HttpStatusCode int        `json:"-"`
}

ShowJobResponse Response Object

func (ShowJobResponse) String 

func (o ShowJobResponse) String() string

type ShowJobResponseJobType 

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

func (ShowJobResponseJobType) MarshalJSON 

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

func (*ShowJobResponseJobType) UnmarshalJSON 

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

func (ShowJobResponseJobType) Value 

func (c ShowJobResponseJobType) Value() string

type ShowJobResponseJobTypeEnum 

type ShowJobResponseJobTypeEnum struct {
	BATCH     ShowJobResponseJobType
	REAL_TIME ShowJobResponseJobType
}

func GetShowJobResponseJobTypeEnum 

func GetShowJobResponseJobTypeEnum() ShowJobResponseJobTypeEnum

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 

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 {
	Name *string `json:"name,omitempty"`

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

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

	DependFiles *[]string `json:"dependFiles,omitempty"`

	Desc *string `json:"desc,omitempty"`

	// 资源所在目录
	Directory      *string `json:"directory,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 

func (c ShowResourceResponseType) Value() string

type ShowResourceResponseTypeEnum 

type ShowResourceResponseTypeEnum struct {
	ARCHIVE ShowResourceResponseType
	FILE    ShowResourceResponseType
	JAR     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 

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 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 

func (c SubTaskStatusStatus) Value() string

type SubTaskStatusStatusEnum 

type SubTaskStatusStatusEnum struct {
	RUNNING    SubTaskStatusStatus
	SUCCESSFUL SubTaskStatusStatus
	FAILED     SubTaskStatusStatus
}

func GetSubTaskStatusStatusEnum 

func GetSubTaskStatusStatusEnum() SubTaskStatusStatusEnum

type TreeNodeElement 

type TreeNodeElement struct {
	Type *TreeNodeElementType `json:"type,omitempty"`

	ParentDirectoryId *string `json:"parent_directory_id,omitempty"`

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

	ElementId *string `json:"element_id,omitempty"`

	Owner *string `json:"owner,omitempty"`

	ProcessType *string `json:"process_type,omitempty"`

	IsSingleNodeJob *bool `json:"is_single_node_job,omitempty"`
}

func (TreeNodeElement) String 

func (o TreeNodeElement) String() string

type TreeNodeElementType 

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

func (TreeNodeElementType) MarshalJSON 

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

func (*TreeNodeElementType) UnmarshalJSON 

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

func (TreeNodeElementType) Value 

func (c TreeNodeElementType) Value() string

type TreeNodeElementTypeEnum 

type TreeNodeElementTypeEnum struct {
	JOB    TreeNodeElementType
	SCRIPT TreeNodeElementType
}

func GetTreeNodeElementTypeEnum 

func GetTreeNodeElementTypeEnum() TreeNodeElementTypeEnum

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.