model

package
v0.0.88 Latest Latest
Warning

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

Go to latest
Published: May 13, 2022 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 {
	ScriptName string `json:"script_name"`

	InstanceId string `json:"instance_id"`
}

Request Object

func (CancelScriptRequest) String

func (o CancelScriptRequest) String() string

type CancelScriptResponse

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

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

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

type CreateConnectionRequest

type CreateConnectionRequest struct {
	Body *ConnectionInfo `json:"body,omitempty"`
}

Request Object

func (CreateConnectionRequest) String

func (o CreateConnectionRequest) String() string

type CreateConnectionResponse

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

Response Object

func (CreateConnectionResponse) String

func (o CreateConnectionResponse) String() string

type CreateJobRequest

type CreateJobRequest struct {
	Body *JobInfo `json:"body,omitempty"`
}

Request Object

func (CreateJobRequest) String

func (o CreateJobRequest) String() string

type CreateJobResponse

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

Response Object

func (CreateJobResponse) String

func (o CreateJobResponse) String() string

type CreateResourceRequest

type CreateResourceRequest struct {
	Body *ResourceInfo `json:"body,omitempty"`
}

Request Object

func (CreateResourceRequest) String

func (o CreateResourceRequest) String() string

type CreateResourceResponse

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

Response Object

func (CreateResourceResponse) String

func (o CreateResourceResponse) String() string

type CreateScriptRequest

type CreateScriptRequest struct {
	Body *ScriptInfo `json:"body,omitempty"`
}

Request Object

func (CreateScriptRequest) String

func (o CreateScriptRequest) String() string

type CreateScriptResponse

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

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 {

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

Request Object

func (DeleteConnctionRequest) String

func (o DeleteConnctionRequest) String() string

type DeleteConnctionResponse

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

Response Object

func (DeleteConnctionResponse) String

func (o DeleteConnctionResponse) String() string

type DeleteJobRequest

type DeleteJobRequest struct {

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

Request Object

func (DeleteJobRequest) String

func (o DeleteJobRequest) String() string

type DeleteJobResponse

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

Response Object

func (DeleteJobResponse) String

func (o DeleteJobResponse) String() string

type DeleteResourceRequest

type DeleteResourceRequest struct {

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

Request Object

func (DeleteResourceRequest) String

func (o DeleteResourceRequest) String() string

type DeleteResourceResponse

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

Response Object

func (DeleteResourceResponse) String

func (o DeleteResourceResponse) String() string

type DeleteScriptRequest

type DeleteScriptRequest struct {
	ScriptName string `json:"script_name"`
}

Request Object

func (DeleteScriptRequest) String

func (o DeleteScriptRequest) String() string

type DeleteScriptResponse

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

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

type DependJobDependFailPolicyEnum

type DependJobDependFailPolicyEnum struct {
	FAIL    DependJobDependFailPolicy
	IGNORE  DependJobDependFailPolicy
	SUSPEND DependJobDependFailPolicy
}

func GetDependJobDependFailPolicyEnum

func GetDependJobDependFailPolicyEnum() DependJobDependFailPolicyEnum

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 {
	ScriptName string `json:"script_name"`

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

Request Object

func (ExecuteScriptRequest) String

func (o ExecuteScriptRequest) String() string

type ExecuteScriptResponse

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

Response Object

func (ExecuteScriptResponse) String

func (o ExecuteScriptResponse) String() string

type ExportConnectionsRequest

type ExportConnectionsRequest struct {
}

Request Object

func (ExportConnectionsRequest) String

func (o ExportConnectionsRequest) String() string

type ExportConnectionsResponse

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

Response Object

func (ExportConnectionsResponse) String

func (o ExportConnectionsResponse) String() string

type ExportJobListRequest

type ExportJobListRequest struct {
	Body *ExportJobsReq `json:"body,omitempty"`
}

Request Object

func (ExportJobListRequest) String

func (o ExportJobListRequest) String() string

type ExportJobListResponse

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

Response Object

func (ExportJobListResponse) String

func (o ExportJobListResponse) String() string

type ExportJobRequest

type ExportJobRequest struct {

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

Request Object

func (ExportJobRequest) String

func (o ExportJobRequest) String() string

type ExportJobResponse

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

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

type ImportConnectionReqSameNamePolicyEnum

type ImportConnectionReqSameNamePolicyEnum struct {
	SKIP      ImportConnectionReqSameNamePolicy
	OVERWRITE ImportConnectionReqSameNamePolicy
}

func GetImportConnectionReqSameNamePolicyEnum

func GetImportConnectionReqSameNamePolicyEnum() ImportConnectionReqSameNamePolicyEnum

type ImportConnectionsRequest

type ImportConnectionsRequest struct {
	Body *ImportConnectionReq `json:"body,omitempty"`
}

Request Object

func (ImportConnectionsRequest) String

func (o ImportConnectionsRequest) String() string

type ImportConnectionsResponse

type ImportConnectionsResponse struct {

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

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

type ImportFileReqSameNamePolicyEnum

type ImportFileReqSameNamePolicyEnum struct {
	SKIP      ImportFileReqSameNamePolicy
	OVERWRITE ImportFileReqSameNamePolicy
}

func GetImportFileReqSameNamePolicyEnum

func GetImportFileReqSameNamePolicyEnum() ImportFileReqSameNamePolicyEnum

type ImportJobRequest

type ImportJobRequest struct {
	Body *ImportFileReq `json:"body,omitempty"`
}

Request Object

func (ImportJobRequest) String

func (o ImportJobRequest) String() string

type ImportJobResponse

type ImportJobResponse struct {

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

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

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

	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

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

type JobParamParamTypeEnum

type JobParamParamTypeEnum struct {
	VARIABLE  JobParamParamType
	CONSTANTS JobParamParamType
}

func GetJobParamParamTypeEnum

func GetJobParamParamTypeEnum() JobParamParamTypeEnum

type ListConnectionsRequest

type ListConnectionsRequest struct {
}

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

Response Object

func (ListConnectionsResponse) String

func (o ListConnectionsResponse) String() string

type ListJobInstancesRequest

type ListJobInstancesRequest struct {
}

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

Response Object

func (ListJobInstancesResponse) String

func (o ListJobInstancesResponse) String() string

type ListJobsRequest

type ListJobsRequest struct {
}

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

Response Object

func (ListJobsResponse) String

func (o ListJobsResponse) String() string

type ListResourcesRequest

type ListResourcesRequest struct {
}

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

Response Object

func (ListResourcesResponse) String

func (o ListResourcesResponse) String() string

type ListScriptResultsRequest

type ListScriptResultsRequest struct {
	ScriptName string `json:"script_name"`

	InstanceId string `json:"instance_id"`
}

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

Response Object

func (ListScriptResultsResponse) String

func (o ListScriptResultsResponse) String() string

type ListScriptsRequest

type ListScriptsRequest struct {
}

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

Response Object

func (ListScriptsResponse) String

func (o ListScriptsResponse) String() string

type ListSystemTasksRequest

type ListSystemTasksRequest struct {

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

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

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

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

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

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

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

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

type ResourceInfoTypeEnum

type ResourceInfoTypeEnum struct {
	ARCHIVE ResourceInfoType
	FILE    ResourceInfoType
	JAR     ResourceInfoType
}

func GetResourceInfoTypeEnum

func GetResourceInfoTypeEnum() ResourceInfoTypeEnum

type RestoreJobInstanceRequest

type RestoreJobInstanceRequest struct {

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

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

Request Object

func (RestoreJobInstanceRequest) String

func (o RestoreJobInstanceRequest) String() string

type RestoreJobInstanceResponse

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

Response Object

func (RestoreJobInstanceResponse) 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 {

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

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

Request Object

func (RunOnceRequest) String

func (o RunOnceRequest) String() string

type RunOnceResponse

type RunOnceResponse struct {

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

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

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

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 {

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

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

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

type ShowConnectionResponseTypeEnum added in v0.0.78

func GetShowConnectionResponseTypeEnum added in v0.0.78

func GetShowConnectionResponseTypeEnum() ShowConnectionResponseTypeEnum

type ShowFileInfoRequest

type ShowFileInfoRequest struct {
	Body *FilePath `json:"body,omitempty"`
}

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

Response Object

func (ShowFileInfoResponse) String

func (o ShowFileInfoResponse) String() string

type ShowJobInstanceRequest

type ShowJobInstanceRequest struct {

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

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

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

Response Object

func (ShowJobInstanceResponse) String

func (o ShowJobInstanceResponse) String() string

type ShowJobRequest

type ShowJobRequest struct {

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

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

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

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

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

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

type ShowJobResponseJobTypeEnum

type ShowJobResponseJobTypeEnum struct {
	BATCH     ShowJobResponseJobType
	REAL_TIME ShowJobResponseJobType
}

func GetShowJobResponseJobTypeEnum

func GetShowJobResponseJobTypeEnum() ShowJobResponseJobTypeEnum

type ShowJobStatusRequest

type ShowJobStatusRequest struct {

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

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

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

type ShowResourceRequest

type ShowResourceRequest struct {

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

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

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

type ShowResourceResponseTypeEnum

type ShowResourceResponseTypeEnum struct {
	ARCHIVE ShowResourceResponseType
	FILE    ShowResourceResponseType
	JAR     ShowResourceResponseType
}

func GetShowResourceResponseTypeEnum

func GetShowResourceResponseTypeEnum() ShowResourceResponseTypeEnum

type ShowScriptRequest

type ShowScriptRequest struct {
	ScriptName string `json:"script_name"`
}

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

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

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 {

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

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

Request Object

func (StartJobRequest) String

func (o StartJobRequest) String() string

type StartJobResponse

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

Response Object

func (StartJobResponse) String

func (o StartJobResponse) String() string

type StopJobInstanceRequest

type StopJobInstanceRequest struct {

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

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

Request Object

func (StopJobInstanceRequest) String

func (o StopJobInstanceRequest) String() string

type StopJobInstanceResponse

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

Response Object

func (StopJobInstanceResponse) String

func (o StopJobInstanceResponse) String() string

type StopJobRequest

type StopJobRequest struct {

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

Request Object

func (StopJobRequest) String

func (o StopJobRequest) String() string

type StopJobResponse

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

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

type SubTaskStatusStatusEnum

type SubTaskStatusStatusEnum struct {
	RUNNING    SubTaskStatusStatus
	SUCCESSFUL SubTaskStatusStatus
	FAILED     SubTaskStatusStatus
}

func GetSubTaskStatusStatusEnum

func GetSubTaskStatusStatusEnum() SubTaskStatusStatusEnum

type UpdateConnectionRequest

type UpdateConnectionRequest struct {

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

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

Request Object

func (UpdateConnectionRequest) String

func (o UpdateConnectionRequest) String() string

type UpdateConnectionResponse

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

Response Object

func (UpdateConnectionResponse) String

func (o UpdateConnectionResponse) String() string

type UpdateJobRequest

type UpdateJobRequest struct {

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

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

Request Object

func (UpdateJobRequest) String

func (o UpdateJobRequest) String() string

type UpdateJobResponse

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

Response Object

func (UpdateJobResponse) String

func (o UpdateJobResponse) String() string

type UpdateResourceRequest

type UpdateResourceRequest struct {

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

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

Request Object

func (UpdateResourceRequest) String

func (o UpdateResourceRequest) String() string

type UpdateResourceResponse

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

Response Object

func (UpdateResourceResponse) String

func (o UpdateResourceResponse) String() string

type UpdateScriptRequest

type UpdateScriptRequest struct {
	ScriptName string `json:"script_name"`

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

Request Object

func (UpdateScriptRequest) String

func (o UpdateScriptRequest) String() string

type UpdateScriptResponse

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

Response Object

func (UpdateScriptResponse) String

func (o UpdateScriptResponse) String() string

Source Files

Jump to

Keyboard shortcuts

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