v1

Documentation

Index

• func CdmClientBuilder() *http_client.HcHttpClientBuilder
• func GenReqDefForCreateAndStartRandomClusterJob() *def.HttpRequestDef
• func GenReqDefForCreateCluster() *def.HttpRequestDef
• func GenReqDefForCreateJob() *def.HttpRequestDef
• func GenReqDefForCreateLink() *def.HttpRequestDef
• func GenReqDefForDeleteCluster() *def.HttpRequestDef
• func GenReqDefForDeleteJob() *def.HttpRequestDef
• func GenReqDefForDeleteLink() *def.HttpRequestDef
• func GenReqDefForListClusters() *def.HttpRequestDef
• func GenReqDefForRestartCluster() *def.HttpRequestDef
• func GenReqDefForShowClusterDetail() *def.HttpRequestDef
• func GenReqDefForShowJobStatus() *def.HttpRequestDef
• func GenReqDefForShowJobs() *def.HttpRequestDef
• func GenReqDefForShowLink() *def.HttpRequestDef
• func GenReqDefForShowSubmissions() *def.HttpRequestDef
• func GenReqDefForStartCluster() *def.HttpRequestDef
• func GenReqDefForStartJob() *def.HttpRequestDef
• func GenReqDefForStopCluster() *def.HttpRequestDef
• func GenReqDefForStopJob() *def.HttpRequestDef
• func GenReqDefForUpdateJob() *def.HttpRequestDef
• func GenReqDefForUpdateLink() *def.HttpRequestDef
• type CdmClient
  • func NewCdmClient(hcClient *http_client.HcHttpClient) *CdmClient
  • func (c *CdmClient) CreateAndStartRandomClusterJob(request *model.CreateAndStartRandomClusterJobRequest) (*model.CreateAndStartRandomClusterJobResponse, error)
  • func (c *CdmClient) CreateCluster(request *model.CreateClusterRequest) (*model.CreateClusterResponse, error)
  • func (c *CdmClient) CreateJob(request *model.CreateJobRequest) (*model.CreateJobResponse, error)
  • func (c *CdmClient) CreateLink(request *model.CreateLinkRequest) (*model.CreateLinkResponse, error)
  • func (c *CdmClient) DeleteCluster(request *model.DeleteClusterRequest) (*model.DeleteClusterResponse, error)
  • func (c *CdmClient) DeleteJob(request *model.DeleteJobRequest) (*model.DeleteJobResponse, error)
  • func (c *CdmClient) DeleteLink(request *model.DeleteLinkRequest) (*model.DeleteLinkResponse, error)
  • func (c *CdmClient) ListClusters(request *model.ListClustersRequest) (*model.ListClustersResponse, error)
  • func (c *CdmClient) RestartCluster(request *model.RestartClusterRequest) (*model.RestartClusterResponse, error)
  • func (c *CdmClient) ShowClusterDetail(request *model.ShowClusterDetailRequest) (*model.ShowClusterDetailResponse, error)
  • func (c *CdmClient) ShowJobStatus(request *model.ShowJobStatusRequest) (*model.ShowJobStatusResponse, error)
  • func (c *CdmClient) ShowJobs(request *model.ShowJobsRequest) (*model.ShowJobsResponse, error)
  • func (c *CdmClient) ShowLink(request *model.ShowLinkRequest) (*model.ShowLinkResponse, error)
  • func (c *CdmClient) ShowSubmissions(request *model.ShowSubmissionsRequest) (*model.ShowSubmissionsResponse, error)
  • func (c *CdmClient) StartCluster(request *model.StartClusterRequest) (*model.StartClusterResponse, error)
  • func (c *CdmClient) StartJob(request *model.StartJobRequest) (*model.StartJobResponse, error)
  • func (c *CdmClient) StopCluster(request *model.StopClusterRequest) (*model.StopClusterResponse, error)
  • func (c *CdmClient) StopJob(request *model.StopJobRequest) (*model.StopJobResponse, error)
  • func (c *CdmClient) UpdateJob(request *model.UpdateJobRequest) (*model.UpdateJobResponse, error)
  • func (c *CdmClient) UpdateLink(request *model.UpdateLinkRequest) (*model.UpdateLinkResponse, error)

Functions

func CdmClientBuilder

func CdmClientBuilder() *http_client.HcHttpClientBuilder

func GenReqDefForCreateAndStartRandomClusterJob

func GenReqDefForCreateAndStartRandomClusterJob() *def.HttpRequestDef

func GenReqDefForCreateCluster

func GenReqDefForCreateCluster() *def.HttpRequestDef

func GenReqDefForCreateJob

func GenReqDefForCreateJob() *def.HttpRequestDef

func GenReqDefForCreateLink

func GenReqDefForCreateLink() *def.HttpRequestDef

func GenReqDefForDeleteCluster

func GenReqDefForDeleteCluster() *def.HttpRequestDef

func GenReqDefForDeleteJob

func GenReqDefForDeleteJob() *def.HttpRequestDef

func GenReqDefForDeleteLink

func GenReqDefForDeleteLink() *def.HttpRequestDef

func GenReqDefForListClusters

func GenReqDefForListClusters() *def.HttpRequestDef

func GenReqDefForRestartCluster

func GenReqDefForRestartCluster() *def.HttpRequestDef

func GenReqDefForShowClusterDetail

func GenReqDefForShowClusterDetail() *def.HttpRequestDef

func GenReqDefForShowJobStatus

func GenReqDefForShowJobStatus() *def.HttpRequestDef

func GenReqDefForShowJobs

func GenReqDefForShowJobs() *def.HttpRequestDef

func GenReqDefForShowLink

func GenReqDefForShowLink() *def.HttpRequestDef

func GenReqDefForShowSubmissions

func GenReqDefForShowSubmissions() *def.HttpRequestDef

func GenReqDefForStartCluster

func GenReqDefForStartCluster() *def.HttpRequestDef

func GenReqDefForStartJob

func GenReqDefForStartJob() *def.HttpRequestDef

func GenReqDefForStopCluster

func GenReqDefForStopCluster() *def.HttpRequestDef

func GenReqDefForStopJob

func GenReqDefForStopJob() *def.HttpRequestDef

func GenReqDefForUpdateJob

func GenReqDefForUpdateJob() *def.HttpRequestDef

func GenReqDefForUpdateLink

func GenReqDefForUpdateLink() *def.HttpRequestDef

Types

type CdmClient

type CdmClient struct {
	HcClient *http_client.HcHttpClient
}

func NewCdmClient

func NewCdmClient(hcClient *http_client.HcHttpClient) *CdmClient

func (*CdmClient) CreateAndStartRandomClusterJob

func (c *CdmClient) CreateAndStartRandomClusterJob(request *model.CreateAndStartRandomClusterJobRequest) (*model.CreateAndStartRandomClusterJobResponse, error)

随机集群创建作业并执行接口。

func (*CdmClient) CreateCluster

func (c *CdmClient) CreateCluster(request *model.CreateClusterRequest) (*model.CreateClusterResponse, error)

创建集群接口。

func (*CdmClient) CreateJob

func (c *CdmClient) CreateJob(request *model.CreateJobRequest) (*model.CreateJobResponse, error)

指定集群创建作业接口。

func (*CdmClient) CreateLink

func (c *CdmClient) CreateLink(request *model.CreateLinkRequest) (*model.CreateLinkResponse, error)

创建连接接口。

func (*CdmClient) DeleteCluster

func (c *CdmClient) DeleteCluster(request *model.DeleteClusterRequest) (*model.DeleteClusterResponse, error)

删除集群接口。

func (*CdmClient) DeleteJob

func (c *CdmClient) DeleteJob(request *model.DeleteJobRequest) (*model.DeleteJobResponse, error)

删除作业接口。

func (*CdmClient) DeleteLink

func (c *CdmClient) DeleteLink(request *model.DeleteLinkRequest) (*model.DeleteLinkResponse, error)

删除连接接口。

func (*CdmClient) ListClusters

func (c *CdmClient) ListClusters(request *model.ListClustersRequest) (*model.ListClustersResponse, error)

查询集群列表接口。

func (*CdmClient) RestartCluster

func (c *CdmClient) RestartCluster(request *model.RestartClusterRequest) (*model.RestartClusterResponse, error)

重启集群接口。

func (*CdmClient) ShowClusterDetail

func (c *CdmClient) ShowClusterDetail(request *model.ShowClusterDetailRequest) (*model.ShowClusterDetailResponse, error)

查询集群详情接口。

func (*CdmClient) ShowJobStatus

func (c *CdmClient) ShowJobStatus(request *model.ShowJobStatusRequest) (*model.ShowJobStatusResponse, error)

查询作业状态接口。

func (*CdmClient) ShowJobs

func (c *CdmClient) ShowJobs(request *model.ShowJobsRequest) (*model.ShowJobsResponse, error)

查询作业接口。

func (*CdmClient) ShowLink

func (c *CdmClient) ShowLink(request *model.ShowLinkRequest) (*model.ShowLinkResponse, error)

查询连接接口。

func (*CdmClient) ShowSubmissions

func (c *CdmClient) ShowSubmissions(request *model.ShowSubmissionsRequest) (*model.ShowSubmissionsResponse, error)

查询作业执行历史接口。

func (*CdmClient) StartCluster

func (c *CdmClient) StartCluster(request *model.StartClusterRequest) (*model.StartClusterResponse, error)

启动集群接口。

func (*CdmClient) StartJob

func (c *CdmClient) StartJob(request *model.StartJobRequest) (*model.StartJobResponse, error)

启动作业接口。

func (*CdmClient) StopCluster

func (c *CdmClient) StopCluster(request *model.StopClusterRequest) (*model.StopClusterResponse, error)

停止集群接口。

func (*CdmClient) StopJob

func (c *CdmClient) StopJob(request *model.StopJobRequest) (*model.StopJobResponse, error)

停止作业接口。

func (*CdmClient) UpdateJob

func (c *CdmClient) UpdateJob(request *model.UpdateJobRequest) (*model.UpdateJobResponse, error)

修改作业接口。

func (*CdmClient) UpdateLink

func (c *CdmClient) UpdateLink(request *model.UpdateLinkRequest) (*model.UpdateLinkResponse, error)

修改连接接口。