model

package
v0.0.59 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2021 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 ActionProgress 

type ActionProgress struct {
	Creating *string `json:"CREATING,omitempty"`

	Growing *string `json:"GROWING,omitempty"`

	Restoring *string `json:"RESTORING,omitempty"`

	Snapshotting *string `json:"SNAPSHOTTING,omitempty"`

	Repairing *string `json:"REPAIRING,omitempty"`
}

集群操作进度，任务信息，由key、value组成。key值为正在进行的任务，value值为正在进行任务的进度。示例如 \"action_progress\":{\"SNAPSHOTTING\":\"16%\"}

func (ActionProgress) String 

func (o ActionProgress) String() string

type CdmCreateAndUpdateLinkReq 

type CdmCreateAndUpdateLinkReq struct {
	Links []Links `json:"links"`
}

func (CdmCreateAndUpdateLinkReq) String 

func (o CdmCreateAndUpdateLinkReq) String() string

type CdmCreateClusterReq 

type CdmCreateClusterReq struct {
	Cluster *CdmCreateClusterReqCluster `json:"cluster"`

	AutoRemind *bool `json:"auto_remind,omitempty"`

	PhoneNum *string `json:"phone_num,omitempty"`

	Email *string `json:"email,omitempty"`
}

func (CdmCreateClusterReq) String 

func (o CdmCreateClusterReq) String() string

type CdmCreateClusterReqCluster 

type CdmCreateClusterReqCluster struct {
	ScheduleBootTime *string `json:"scheduleBootTime,omitempty"`

	IsScheduleBootOff bool `json:"isScheduleBootOff"`

	Instances []Instance `json:"instances"`

	Datastore *CdmCreateClusterReqClusterDatastore `json:"datastore"`

	ScheduleOffTime *string `json:"scheduleOffTime,omitempty"`

	VpcId string `json:"vpcId"`

	Name string `json:"name"`

	SysTags []SysTags `json:"sys_tags"`

	IsAutoOff bool `json:"isAutoOff"`
}

集群对象，请参见cluster参数说明

func (CdmCreateClusterReqCluster) String 

func (o CdmCreateClusterReqCluster) String() string

type CdmCreateClusterReqClusterDatastore 

type CdmCreateClusterReqClusterDatastore struct {
	Type string `json:"type"`

	Version string `json:"version"`
}

集群信息，请参见•datastore参数说明

func (CdmCreateClusterReqClusterDatastore) String 

func (o CdmCreateClusterReqClusterDatastore) String() string

type CdmCreateJobJsonReq 

type CdmCreateJobJsonReq struct {
	Jobs []Job `json:"jobs"`
}

func (CdmCreateJobJsonReq) String 

func (o CdmCreateJobJsonReq) String() string

type CdmDeleteClusterReq 

type CdmDeleteClusterReq struct {
	KeepLastManualBackup int32 `json:"keep_last_manual_backup"`
}

func (CdmDeleteClusterReq) String 

func (o CdmDeleteClusterReq) String() string

type CdmQueryClusterDetailsRepsonseMaintainWindow 

type CdmQueryClusterDetailsRepsonseMaintainWindow struct {
	Day *string `json:"day,omitempty"`

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

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

维护窗口

func (CdmQueryClusterDetailsRepsonseMaintainWindow) String 

func (o CdmQueryClusterDetailsRepsonseMaintainWindow) String() string

type CdmQueryClusterDetailsRepsonsePublicEndpointStatus 

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

	ErrorMessage *string `json:"errorMessage,omitempty"`
}

EIP状态信息

func (CdmQueryClusterDetailsRepsonsePublicEndpointStatus) String 

func (o CdmQueryClusterDetailsRepsonsePublicEndpointStatus) String() string

type CdmRandomCreateAndStartJobJsonReq 

type CdmRandomCreateAndStartJobJsonReq struct {
	Jobs []Job `json:"jobs"`

	Clusters []string `json:"clusters"`
}

func (CdmRandomCreateAndStartJobJsonReq) String 

func (o CdmRandomCreateAndStartJobJsonReq) String() string

type CdmRestartClusterReq 

type CdmRestartClusterReq struct {
	Restart *CdmRestartClusterReqRestart `json:"restart"`
}

func (CdmRestartClusterReq) String 

func (o CdmRestartClusterReq) String() string

type CdmRestartClusterReqRestart 

type CdmRestartClusterReqRestart struct {
	RestartDelayTime *int32 `json:"restartDelayTime,omitempty"`

	RestartMode *string `json:"restartMode,omitempty"`

	RestartLevel *string `json:"restartLevel,omitempty"`

	Type string `json:"type"`

	Instance *string `json:"instance,omitempty"`

	Group *string `json:"group,omitempty"`
}

集群重启操作，定义哪些集群节点需要重启，请参见restart参数说明

func (CdmRestartClusterReqRestart) String 

func (o CdmRestartClusterReqRestart) String() string

type CdmStartClusterReq 

type CdmStartClusterReq struct {
	Start *interface{} `json:"start"`
}

func (CdmStartClusterReq) String 

func (o CdmStartClusterReq) String() string

type CdmStopClusterReq 

type CdmStopClusterReq struct {
	Stop *CdmStopClusterReqStop `json:"stop"`
}

func (CdmStopClusterReq) String 

func (o CdmStopClusterReq) String() string

type CdmStopClusterReqStop 

type CdmStopClusterReqStop struct {
	StopMode CdmStopClusterReqStopStopMode `json:"stopMode"`

	DelayTime *int32 `json:"delayTime,omitempty"`
}

集群启动操作，定义集群启动标识，为空对象

func (CdmStopClusterReqStop) String 

func (o CdmStopClusterReqStop) String() string

type CdmStopClusterReqStopStopMode 

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

func (CdmStopClusterReqStopStopMode) MarshalJSON 

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

func (*CdmStopClusterReqStopStopMode) UnmarshalJSON 

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

type CdmStopClusterReqStopStopModeEnum 

type CdmStopClusterReqStopStopModeEnum struct {
	IMMEDIATELY CdmStopClusterReqStopStopMode
	GRACEFULLY  CdmStopClusterReqStopStopMode
}

func GetCdmStopClusterReqStopStopModeEnum 

func GetCdmStopClusterReqStopStopModeEnum() CdmStopClusterReqStopStopModeEnum

type CdmUpdateJobJsonReq 

type CdmUpdateJobJsonReq struct {
	Jobs []Job `json:"jobs"`
}

func (CdmUpdateJobJsonReq) String 

func (o CdmUpdateJobJsonReq) String() string

type ClusterDetailInstance 

type ClusterDetailInstance struct {
	Flavor *ClusterDetailInstanceFlavor `json:"flavor"`

	Volume *ClusterDetailInstanceVolume `json:"volume"`

	Status string `json:"status"`

	Actions *[]string `json:"actions,omitempty"`

	Type string `json:"type"`

	Id string `json:"id"`

	Name string `json:"name"`

	IsFrozen string `json:"isFrozen"`

	ConfigStatus *string `json:"config_status,omitempty"`

	Role *string `json:"role,omitempty"`

	Group *string `json:"group,omitempty"`

	Links *[]ClusterLinks `json:"links,omitempty"`

	ParamsGroupId *string `json:"paramsGroupId,omitempty"`

	PublicIp *string `json:"publicIp,omitempty"`

	ManageIp *string `json:"manageIp,omitempty"`

	TrafficIp *string `json:"trafficIp,omitempty"`

	ShardId *string `json:"shard_id,omitempty"`

	ManageFixIp *string `json:"manage_fix_ip,omitempty"`

	PrivateIp *string `json:"private_ip,omitempty"`

	InternalIp *string `json:"internal_ip,omitempty"`

	Resource *[]Resource `json:"resource,omitempty"`
}

func (ClusterDetailInstance) String 

func (o ClusterDetailInstance) String() string

type ClusterDetailInstanceFlavor 

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

节点的虚拟机规格，请参见flavor参数说明。

func (ClusterDetailInstanceFlavor) String 

func (o ClusterDetailInstanceFlavor) String() string

type ClusterDetailInstanceVolume 

type ClusterDetailInstanceVolume struct {
	Type *string `json:"type,omitempty"`

	Size *int64 `json:"size,omitempty"`
}

节点的磁盘信息，请参见volume参数说明。

func (ClusterDetailInstanceVolume) String 

func (o ClusterDetailInstanceVolume) String() string
type ClusterLinks struct {
	Rel *string `json:"rel,omitempty"`

	Href *string `json:"href,omitempty"`
}

集群连接信息

func (ClusterLinks) String 

func (o ClusterLinks) String() string

type ClusterTask 

type ClusterTask struct {
	Description *string `json:"description,omitempty"`

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

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

任务信息

func (ClusterTask) String 

func (o ClusterTask) String() string

type Clusters 

type Clusters struct {
	CustomerConfig *CustomerConfig `json:"customerConfig,omitempty"`

	Datastore *Datastore `json:"datastore,omitempty"`

	Instances *[]ClusterDetailInstance `json:"instances,omitempty"`

	AzName *string `json:"azName,omitempty"`

	Dbuser *string `json:"dbuser,omitempty"`

	FlavorName *string `json:"flavorName,omitempty"`

	RecentEvent *int32 `json:"recentEvent,omitempty"`

	IsAutoOff *bool `json:"isAutoOff,omitempty"`

	IsScheduleBootOff *bool `json:"isScheduleBootOff,omitempty"`

	ClusterMode *string `json:"clusterMode,omitempty"`

	Namespace *string `json:"namespace,omitempty"`

	Task *ClusterTask `json:"task,omitempty"`

	PublicEndpoint *string `json:"publicEndpoint,omitempty"`

	ActionProgress *ActionProgress `json:"actionProgress,omitempty"`

	Created string `json:"created"`

	Name string `json:"name"`

	StatusDetail *string `json:"statusDetail,omitempty"`

	Id string `json:"id"`

	IsFrozen string `json:"isFrozen"`

	ConfigStatus *string `json:"config_status,omitempty"`

	Updated string `json:"updated"`

	Version string `json:"version"`

	Status string `json:"status"`

	FailedReasons *FailedReasons `json:"failedReasons,omitempty"`
}

func (Clusters) String 

func (o Clusters) String() string

type ConfigValues 

type ConfigValues struct {
	Configs *[]Configs `json:"configs,omitempty"`
}

func (ConfigValues) String 

func (o ConfigValues) String() string

type Configs 

type Configs struct {
	Inputs []interface{} `json:"inputs"`

	Name string `json:"name"`
}

func (Configs) String 

func (o Configs) String() string

type Counter 

type Counter struct {
	BytesWritten *int64 `json:"BYTES_WRITTEN,omitempty"`

	TotalFiles *int32 `json:"TOTAL_FILES,omitempty"`

	RowsRead *int64 `json:"ROWS_READ,omitempty"`

	BytesRead *int64 `json:"BYTES_READ,omitempty"`

	RowsWritten *int64 `json:"ROWS_WRITTEN,omitempty"`

	FilesWritten *int32 `json:"FILES_WRITTEN,omitempty"`

	FilesRead *int32 `json:"FILES_READ,omitempty"`

	TotalSize *int64 `json:"TOTAL_SIZE,omitempty"`

	FilesSkipped *int32 `json:"FILES_SKIPPED,omitempty"`

	RowsWrittenSkipped *int64 `json:"ROWS_WRITTEN_SKIPPED,omitempty"`
}

func (Counter) String 

func (o Counter) String() string

type Counters 

type Counters struct {
	OrgApacheSqoopSubmissionCounterSqoopCounters *Counter `json:"org.apache.sqoop.submission.counter.SqoopCounters"`
}

func (Counters) String 

func (o Counters) String() string

type CreateAndStartRandomClusterJobRequest 

type CreateAndStartRandomClusterJobRequest struct {
	XLanguage string `json:"X-Language"`

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

Request Object

func (CreateAndStartRandomClusterJobRequest) String 

func (o CreateAndStartRandomClusterJobRequest) String() string

type CreateAndStartRandomClusterJobResponse 

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

	ValidationResult *[]JobValidationResult `json:"validation-result,omitempty"`
	HttpStatusCode   int                    `json:"-"`
}

Response Object

func (CreateAndStartRandomClusterJobResponse) String 

func (o CreateAndStartRandomClusterJobResponse) String() string

type CreateClusterRequest 

type CreateClusterRequest struct {
	XLanguage string `json:"X-Language"`

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

Request Object

func (CreateClusterRequest) String 

func (o CreateClusterRequest) String() string

type CreateClusterResponse 

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

	Id             *string `json:"id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateClusterResponse) String 

func (o CreateClusterResponse) String() string

type CreateJobRequest 

type CreateJobRequest struct {
	ClusterId string `json:"cluster_id"`

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

Request Object

func (CreateJobRequest) String 

func (o CreateJobRequest) String() string

type CreateJobResponse 

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

	ValidationResult *[]JobValidationResult `json:"validation-result,omitempty"`
	HttpStatusCode   int                    `json:"-"`
}

Response Object

func (CreateJobResponse) String 

func (o CreateJobResponse) String() string

type CreateLinkRequest 

type CreateLinkRequest struct {
	ClusterId string `json:"cluster_id"`

	Validate *string `json:"validate,omitempty"`

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

Request Object

func (CreateLinkRequest) String 

func (o CreateLinkRequest) String() string

type CreateLinkResponse 

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

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

Response Object

func (CreateLinkResponse) String 

func (o CreateLinkResponse) String() string

type CustomerConfig 

type CustomerConfig struct {
	FailureRemind *string `json:"failureRemind,omitempty"`

	ClusterName *string `json:"clusterName,omitempty"`

	ServiceProvider *string `json:"serviceProvider,omitempty"`

	LocalDisk *string `json:"localDisk,omitempty"`

	Ssl *string `json:"ssl,omitempty"`
}

用户配置信息

func (CustomerConfig) String 

func (o CustomerConfig) String() string

type Datastore 

type Datastore struct {
	Type *string `json:"type,omitempty"`

	Version *string `json:"version,omitempty"`
}

cdm信息

func (Datastore) String 

func (o Datastore) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {
	ClusterId string `json:"cluster_id"`

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

Request Object

func (DeleteClusterRequest) String 

func (o DeleteClusterRequest) String() string

type DeleteClusterResponse 

type DeleteClusterResponse struct {
	JobId          *string `json:"jobId,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteClusterResponse) String 

func (o DeleteClusterResponse) String() string

type DeleteJobRequest 

type DeleteJobRequest struct {
	ClusterId string `json:"cluster_id"`

	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 DeleteLinkRequest 

type DeleteLinkRequest struct {
	ClusterId string `json:"cluster_id"`

	LinkName string `json:"link_name"`
}

Request Object

func (DeleteLinkRequest) String 

func (o DeleteLinkRequest) String() string

type DeleteLinkResponse 

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

Response Object

func (DeleteLinkResponse) String 

func (o DeleteLinkResponse) String() string

type FailedReasons 

type FailedReasons struct {
	CreateFailed *FailedReasonsCreateFailed `json:"CREATE_FAILED,omitempty"`
}

失败原因。如果为空，则集群处于正常状态。

func (FailedReasons) String 

func (o FailedReasons) String() string

type FailedReasonsCreateFailed 

type FailedReasonsCreateFailed struct {
	ErrorCode *string `json:"errorCode,omitempty"`

	ErrorMsg *string `json:"errorMsg,omitempty"`
}

集群创建失败原因。

func (FailedReasonsCreateFailed) String 

func (o FailedReasonsCreateFailed) String() string

type Instance 

type Instance struct {
	AvailabilityZone string `json:"availability_zone"`

	Nics []Nics `json:"nics"`

	FlavorRef string `json:"flavorRef"`

	Type string `json:"type"`
}

func (Instance) String 

func (o Instance) String() string

type Job 

type Job struct {
	JobType *JobJobType `json:"job_type,omitempty"`

	FromConnectorName *string `json:"from-connector-name,omitempty"`

	ToConfigValues *ConfigValues `json:"to-config-values,omitempty"`

	ToLinkName *string `json:"to-link-name,omitempty"`

	DriverConfigValues *ConfigValues `json:"driver-config-values,omitempty"`

	FromConfigValues *ConfigValues `json:"from-config-values,omitempty"`

	ToConnectorName *string `json:"to-connector-name,omitempty"`

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

	FromLinkName *string `json:"from-link-name,omitempty"`

	CreationUser *string `json:"creation-user,omitempty"`

	CreationDate *int64 `json:"creation-date,omitempty"`

	UpdateDate *int64 `json:"update-date,omitempty"`

	UpdateUser *string `json:"update-user,omitempty"`

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

func (Job) String 

func (o Job) String() string

type JobJobType 

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

func (JobJobType) MarshalJSON 

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

func (*JobJobType) UnmarshalJSON 

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

type JobJobTypeEnum 

type JobJobTypeEnum struct {
	NORMAL_JOB   JobJobType
	BATCH_JOB    JobJobType
	SCENARIO_JOB JobJobType
}

func GetJobJobTypeEnum 

func GetJobJobTypeEnum() JobJobTypeEnum

type JobValidationResult 

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

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

失败原因

func (JobValidationResult) String 

func (o JobValidationResult) String() string

type JobValidationResultStatus 

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

func (JobValidationResultStatus) MarshalJSON 

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

func (*JobValidationResultStatus) UnmarshalJSON 

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

type JobValidationResultStatusEnum 

type JobValidationResultStatusEnum struct {
	ERROR   JobValidationResultStatus
	WARNING JobValidationResultStatus
}

func GetJobValidationResultStatusEnum 

func GetJobValidationResultStatusEnum() JobValidationResultStatusEnum
type Links struct {
	LinkConfigValues *LinksLinkconfigvalues `json:"link-config-values"`

	CreationUser *string `json:"creation-user,omitempty"`

	Name string `json:"name"`

	CreationDate *int64 `json:"creation-date,omitempty"`

	ConnectorName string `json:"connector-name"`

	UpdateDate *int64 `json:"update-date,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`

	UpdateUser *string `json:"update-user,omitempty"`
}

func (Links) String 

func (o Links) String() string

type LinksLinkconfigvalues 

type LinksLinkconfigvalues struct {
	Configs []Configs `json:"configs"`
}

连接参数配置，请参见link-config-values参数说明

func (LinksLinkconfigvalues) String 

func (o LinksLinkconfigvalues) String() string

type ListClustersRequest 

type ListClustersRequest struct {
}

Request Object

func (ListClustersRequest) String 

func (o ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {
	Clusters       *[]Clusters `json:"clusters,omitempty"`
	HttpStatusCode int         `json:"-"`
}

Response Object

func (ListClustersResponse) String 

func (o ListClustersResponse) String() string

type Nics 

type Nics struct {
	SecurityGroupId string `json:"securityGroupId"`

	NetId string `json:"net-id"`
}

func (Nics) String 

func (o Nics) String() string

type Resource 

type Resource struct {
	ResourceId *string `json:"resource_id,omitempty"`

	ResourceType *string `json:"resource_type,omitempty"`
}

func (Resource) String 

func (o Resource) String() string

type RestartClusterRequest 

type RestartClusterRequest struct {
	ClusterId string `json:"cluster_id"`

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

Request Object

func (RestartClusterRequest) String 

func (o RestartClusterRequest) String() string

type RestartClusterResponse 

type RestartClusterResponse struct {
	JobId          *string `json:"jobId,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (RestartClusterResponse) String 

func (o RestartClusterResponse) String() string

type ShowClusterDetailRequest 

type ShowClusterDetailRequest struct {
	ClusterId string `json:"cluster_id"`
}

Request Object

func (ShowClusterDetailRequest) String 

func (o ShowClusterDetailRequest) String() string

type ShowClusterDetailResponse 

type ShowClusterDetailResponse struct {
	PublicEndpoint *string `json:"publicEndpoint,omitempty"`

	Instances *[]ClusterDetailInstance `json:"instances,omitempty"`

	SecurityGroupId *string `json:"security_group_id,omitempty"`

	SubnetId *string `json:"subnet_id,omitempty"`

	VpcId *string `json:"vpc_id,omitempty"`

	CustomerConfig *CustomerConfig `json:"customerConfig,omitempty"`

	Datastore *Datastore `json:"datastore,omitempty"`

	IsAutoOff *bool `json:"isAutoOff,omitempty"`

	PublicEndpointDomainName *string `json:"publicEndpointDomainName,omitempty"`

	BakExpectedStartTime *string `json:"bakExpectedStartTime,omitempty"`

	BakKeepDay *int32 `json:"bakKeepDay,omitempty"`

	MaintainWindow *CdmQueryClusterDetailsRepsonseMaintainWindow `json:"maintainWindow,omitempty"`

	RecentEvent *int32 `json:"recentEvent,omitempty"`

	FlavorName *string `json:"flavorName,omitempty"`

	AzName *string `json:"azName,omitempty"`

	PublicEndpointStatus *CdmQueryClusterDetailsRepsonsePublicEndpointStatus `json:"publicEndpointStatus,omitempty"`

	Namespace *string `json:"namespace,omitempty"`

	EipId *string `json:"eipId,omitempty"`

	Dbuser *string `json:"dbuser,omitempty"`

	Links *[]ClusterLinks `json:"links,omitempty"`

	ClusterMode *string `json:"clusterMode,omitempty"`

	Task *ClusterTask `json:"task,omitempty"`

	Created *string `json:"created,omitempty"`

	StatusDetail *string `json:"statusDetail,omitempty"`

	ConfigStatus *string `json:"config_status,omitempty"`

	ActionProgress *ActionProgress `json:"actionProgress,omitempty"`

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

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

	IsFrozen *string `json:"isFrozen,omitempty"`

	Actions *[]string `json:"actions,omitempty"`

	Updated *string `json:"updated,omitempty"`

	Status         *string `json:"status,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ShowClusterDetailResponse) String 

func (o ShowClusterDetailResponse) String() string

type ShowJobStatusRequest 

type ShowJobStatusRequest struct {
	ClusterId string `json:"cluster_id"`

	JobName string `json:"job_name"`
}

Request Object

func (ShowJobStatusRequest) String 

func (o ShowJobStatusRequest) String() string

type ShowJobStatusResponse 

type ShowJobStatusResponse struct {
	Submissions    *[]Submission `json:"submissions,omitempty"`
	HttpStatusCode int           `json:"-"`
}

Response Object

func (ShowJobStatusResponse) String 

func (o ShowJobStatusResponse) String() string

type ShowJobsRequest 

type ShowJobsRequest struct {
	ClusterId string `json:"cluster_id"`

	JobName string `json:"job_name"`

	Filter *string `json:"filter,omitempty"`

	PageNo *int32 `json:"page_no,omitempty"`

	PageSize *int32 `json:"page_size,omitempty"`

	JobType *ShowJobsRequestJobType `json:"jobType,omitempty"`
}

Request Object

func (ShowJobsRequest) String 

func (o ShowJobsRequest) String() string

type ShowJobsRequestJobType 

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

func (ShowJobsRequestJobType) MarshalJSON 

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

func (*ShowJobsRequestJobType) UnmarshalJSON 

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

type ShowJobsRequestJobTypeEnum 

type ShowJobsRequestJobTypeEnum struct {
	NORMAL_JOB   ShowJobsRequestJobType
	BATCH_JOB    ShowJobsRequestJobType
	SCENARIO_JOB ShowJobsRequestJobType
}

func GetShowJobsRequestJobTypeEnum 

func GetShowJobsRequestJobTypeEnum() ShowJobsRequestJobTypeEnum

type ShowJobsResponse 

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

	Jobs *[]Job `json:"jobs,omitempty"`

	Simple *bool `json:"simple,omitempty"`

	PageNo *int32 `json:"page_no,omitempty"`

	PageSize       *int32 `json:"page_size,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowJobsResponse) String 

func (o ShowJobsResponse) String() string

type ShowLinkRequest 

type ShowLinkRequest struct {
	ClusterId string `json:"cluster_id"`

	LinkName string `json:"link_name"`
}

Request Object

func (ShowLinkRequest) String 

func (o ShowLinkRequest) String() string

type ShowLinkResponse 

type ShowLinkResponse struct {
	Links *[]Links `json:"links,omitempty"`

	FromToUnMapping *string `json:"fromTo-unMapping,omitempty"`

	BatchFromToMapping *string `json:"batchFromTo-mapping,omitempty"`
	HttpStatusCode     int     `json:"-"`
}

Response Object

func (ShowLinkResponse) String 

func (o ShowLinkResponse) String() string

type ShowSubmissionsRequest 

type ShowSubmissionsRequest struct {
	ClusterId string `json:"cluster_id"`

	Jname string `json:"jname"`
}

Request Object

func (ShowSubmissionsRequest) String 

func (o ShowSubmissionsRequest) String() string

type ShowSubmissionsResponse 

type ShowSubmissionsResponse struct {
	Submissions *[]Submission `json:"submissions,omitempty"`

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

	PageNo *int32 `json:"page_no,omitempty"`

	PageSize       *int32 `json:"page_size,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowSubmissionsResponse) String 

func (o ShowSubmissionsResponse) String() string

type StartClusterRequest 

type StartClusterRequest struct {
	ClusterId string `json:"cluster_id"`

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

Request Object

func (StartClusterRequest) String 

func (o StartClusterRequest) String() string

type StartClusterResponse 

type StartClusterResponse struct {
	JobId          *[]string `json:"jobId,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (StartClusterResponse) String 

func (o StartClusterResponse) String() string

type StartJobRequest 

type StartJobRequest struct {
	ClusterId string `json:"cluster_id"`

	JobName string `json:"job_name"`
}

Request Object

func (StartJobRequest) String 

func (o StartJobRequest) String() string

type StartJobResponse 

type StartJobResponse struct {
	Submissions    *[]StartJobSubmission `json:"submissions,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (StartJobResponse) String 

func (o StartJobResponse) String() string

type StartJobSubmission 

type StartJobSubmission struct {
	IsIncrementing *bool `json:"isIncrementing,omitempty"`

	DeleteRows *int32 `json:"delete_rows,omitempty"`

	UpdateRows *int32 `json:"update_rows,omitempty"`

	WriteRows *int32 `json:"write_rows,omitempty"`

	SubmissionId *int32 `json:"submission-id,omitempty"`

	JobName string `json:"job-name"`

	CreationUser string `json:"creation-user"`

	CreationDate int64 `json:"creation-date"`

	Progress int32 `json:"progress"`

	Status string `json:"status"`

	IsStopingIncrement *bool `json:"isStopingIncrement,omitempty"`

	IsExecuteAuto *bool `json:"is-execute-auto,omitempty"`

	LastUpdateDate *int64 `json:"last-update-date,omitempty"`

	LastUdpateUser *string `json:"last-udpate-user,omitempty"`

	IsDeleteJob *bool `json:"isDeleteJob,omitempty"`
}

func (StartJobSubmission) String 

func (o StartJobSubmission) String() string

type StopClusterRequest 

type StopClusterRequest struct {
	ClusterId string `json:"cluster_id"`

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

Request Object

func (StopClusterRequest) String 

func (o StopClusterRequest) String() string

type StopClusterResponse 

type StopClusterResponse struct {
	JobId          *[]string `json:"jobId,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (StopClusterResponse) String 

func (o StopClusterResponse) String() string

type StopJobRequest 

type StopJobRequest struct {
	ClusterId string `json:"cluster_id"`

	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 Submission 

type Submission struct {
	IsIncrementing bool `json:"isIncrementing"`

	JobName string `json:"job-name"`

	Counters *Counters `json:"counters,omitempty"`

	IsStopingIncrement string `json:"isStopingIncrement"`

	IsExecuteAuto bool `json:"is-execute-auto"`

	LastUpdateDate int64 `json:"last-update-date"`

	LastUdpateUser string `json:"last-udpate-user"`

	IsDeleteJob bool `json:"isDeleteJob"`

	CreationUser string `json:"creation-user"`

	CreationDate int64 `json:"creation-date"`

	ExternalId string `json:"external-id"`

	Progress float64 `json:"progress"`

	SubmissionId *int32 `json:"submission-id,omitempty"`

	DeleteRows *int32 `json:"delete_rows,omitempty"`

	UpdateRows *int32 `json:"update_rows,omitempty"`

	WriteRows *int32 `json:"write_rows,omitempty"`

	ExecuteDate *int64 `json:"execute-date,omitempty"`

	Status string `json:"status"`

	ErrorDetails *string `json:"error-details,omitempty"`

	ErrorSummary *string `json:"error-summary,omitempty"`
}

func (Submission) String 

func (o Submission) String() string

type SysTags 

type SysTags struct {
	Value string `json:"value"`

	Key string `json:"key"`
}

func (SysTags) String 

func (o SysTags) String() string

type UpdateJobRequest 

type UpdateJobRequest struct {
	ClusterId string `json:"cluster_id"`

	JobName string `json:"job_name"`

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

Request Object

func (UpdateJobRequest) String 

func (o UpdateJobRequest) String() string

type UpdateJobResponse 

type UpdateJobResponse struct {
	ValidationResult *[]JobValidationResult `json:"validation-result,omitempty"`
	HttpStatusCode   int                    `json:"-"`
}

Response Object

func (UpdateJobResponse) String 

func (o UpdateJobResponse) String() string

type UpdateLinkRequest 

type UpdateLinkRequest struct {
	ClusterId string `json:"cluster_id"`

	LinkName string `json:"link_name"`

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

Request Object

func (UpdateLinkRequest) String 

func (o UpdateLinkRequest) String() string

type UpdateLinkResponse 

type UpdateLinkResponse struct {
	ValidationResult *[]ValidationResult `json:"validation-result,omitempty"`
	HttpStatusCode   int                 `json:"-"`
}

Response Object

func (UpdateLinkResponse) String 

func (o UpdateLinkResponse) String() string

type ValidationLinkConfig 

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

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

func (ValidationLinkConfig) String 

func (o ValidationLinkConfig) String() string

type ValidationLinkConfigStatus 

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

func (ValidationLinkConfigStatus) MarshalJSON 

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

func (*ValidationLinkConfigStatus) UnmarshalJSON 

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

type ValidationLinkConfigStatusEnum 

type ValidationLinkConfigStatusEnum struct {
	ERROR   ValidationLinkConfigStatus
	WARNING ValidationLinkConfigStatus
}

func GetValidationLinkConfigStatusEnum 

func GetValidationLinkConfigStatusEnum() ValidationLinkConfigStatusEnum

type ValidationResult 

type ValidationResult struct {
	LinkConfig *[]ValidationLinkConfig `json:"linkConfig,omitempty"`
}

func (ValidationResult) String 

func (o ValidationResult) 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.