v2

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenReqDefForBatchDeleteJobs 

func GenReqDefForBatchDeleteJobs() *def.HttpRequestDef

func GenReqDefForCancelSql 

func GenReqDefForCancelSql() *def.HttpRequestDef

func GenReqDefForCreateCluster 

func GenReqDefForCreateCluster() *def.HttpRequestDef

func GenReqDefForCreateDataConnector 

func GenReqDefForCreateDataConnector() *def.HttpRequestDef

func GenReqDefForCreateExecuteJob 

func GenReqDefForCreateExecuteJob() *def.HttpRequestDef

func GenReqDefForDeleteDataConnector 

func GenReqDefForDeleteDataConnector() *def.HttpRequestDef

func GenReqDefForExecuteSql 

func GenReqDefForExecuteSql() *def.HttpRequestDef

func GenReqDefForListDataConnector 

func GenReqDefForListDataConnector() *def.HttpRequestDef

func GenReqDefForRunJobFlow 

func GenReqDefForRunJobFlow() *def.HttpRequestDef

func GenReqDefForShowAgencyMapping 

func GenReqDefForShowAgencyMapping() *def.HttpRequestDef

func GenReqDefForShowAutoScalingPolicy 

func GenReqDefForShowAutoScalingPolicy() *def.HttpRequestDef

func GenReqDefForShowHdfsFileList 

func GenReqDefForShowHdfsFileList() *def.HttpRequestDef

func GenReqDefForShowJobExeListNew 

func GenReqDefForShowJobExeListNew() *def.HttpRequestDef

func GenReqDefForShowSingleJobExe 

func GenReqDefForShowSingleJobExe() *def.HttpRequestDef

func GenReqDefForShowSqlResult 

func GenReqDefForShowSqlResult() *def.HttpRequestDef

func GenReqDefForShowSqlResultWithJob 

func GenReqDefForShowSqlResultWithJob() *def.HttpRequestDef

func GenReqDefForStopJob 

func GenReqDefForStopJob() *def.HttpRequestDef

func GenReqDefForUpdateAgencyMapping 

func GenReqDefForUpdateAgencyMapping() *def.HttpRequestDef

func GenReqDefForUpdateClusterName 

func GenReqDefForUpdateClusterName() *def.HttpRequestDef

func GenReqDefForUpdateDataConnector 

func GenReqDefForUpdateDataConnector() *def.HttpRequestDef

func MrsClientBuilder 

func MrsClientBuilder() *http_client.HcHttpClientBuilder

Types

type BatchDeleteJobsInvoker 

type BatchDeleteJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteJobsInvoker) Invoke 

func (i *BatchDeleteJobsInvoker) Invoke() (*model.BatchDeleteJobsResponse, error)

type CancelSqlInvoker 

type CancelSqlInvoker struct {
	*invoker.BaseInvoker
}

func (*CancelSqlInvoker) Invoke 

func (i *CancelSqlInvoker) Invoke() (*model.CancelSqlResponse, error)

type CreateClusterInvoker 

type CreateClusterInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateClusterInvoker) Invoke 

func (i *CreateClusterInvoker) Invoke() (*model.CreateClusterResponse, error)

type CreateDataConnectorInvoker 

type CreateDataConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateDataConnectorInvoker) Invoke 

func (i *CreateDataConnectorInvoker) Invoke() (*model.CreateDataConnectorResponse, error)

type CreateExecuteJobInvoker 

type CreateExecuteJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateExecuteJobInvoker) Invoke 

func (i *CreateExecuteJobInvoker) Invoke() (*model.CreateExecuteJobResponse, error)

type DeleteDataConnectorInvoker 

type DeleteDataConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteDataConnectorInvoker) Invoke 

func (i *DeleteDataConnectorInvoker) Invoke() (*model.DeleteDataConnectorResponse, error)

type ExecuteSqlInvoker 

type ExecuteSqlInvoker struct {
	*invoker.BaseInvoker
}

func (*ExecuteSqlInvoker) Invoke 

func (i *ExecuteSqlInvoker) Invoke() (*model.ExecuteSqlResponse, error)

type ListDataConnectorInvoker 

type ListDataConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*ListDataConnectorInvoker) Invoke 

func (i *ListDataConnectorInvoker) Invoke() (*model.ListDataConnectorResponse, error)

type MrsClient 

type MrsClient struct {
	HcClient *http_client.HcHttpClient
}

func NewMrsClient 

func NewMrsClient(hcClient *http_client.HcHttpClient) *MrsClient

func (*MrsClient) BatchDeleteJobs 

func (c *MrsClient) BatchDeleteJobs(request *model.BatchDeleteJobsRequest) (*model.BatchDeleteJobsResponse, error)

BatchDeleteJobs 批量删除作业

在MRS集群中批量删除作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) BatchDeleteJobsInvoker 

func (c *MrsClient) BatchDeleteJobsInvoker(request *model.BatchDeleteJobsRequest) *BatchDeleteJobsInvoker

BatchDeleteJobsInvoker 批量删除作业

func (*MrsClient) CancelSql 

func (c *MrsClient) CancelSql(request *model.CancelSqlRequest) (*model.CancelSqlResponse, error)

CancelSql 取消SQL执行任务

在MRS集群中取消一条SQL的执行任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) CancelSqlInvoker 

func (c *MrsClient) CancelSqlInvoker(request *model.CancelSqlRequest) *CancelSqlInvoker

CancelSqlInvoker 取消SQL执行任务

func (*MrsClient) CreateCluster 

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

CreateCluster 创建集群

创建一个MRS集群。使用接口前，您需要先获取下的资源信息。 - 通过VPC创建或查询VPC、子网 - 通过ECS创建或查询密钥对 - 通过[终端节点](https://support.huaweicloud.com/api-mrs/mrs_02_0003.html)获取区域信息 - 参考[MRS服务支持的组件](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)获取MRS版本及对应版本支持的组件信息

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) CreateClusterInvoker 

func (c *MrsClient) CreateClusterInvoker(request *model.CreateClusterRequest) *CreateClusterInvoker

CreateClusterInvoker 创建集群

func (*MrsClient) CreateDataConnector 

func (c *MrsClient) CreateDataConnector(request *model.CreateDataConnectorRequest) (*model.CreateDataConnectorResponse, error)

CreateDataConnector 创建数据连接

创建数据连接

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) CreateDataConnectorInvoker 

func (c *MrsClient) CreateDataConnectorInvoker(request *model.CreateDataConnectorRequest) *CreateDataConnectorInvoker

CreateDataConnectorInvoker 创建数据连接

func (*MrsClient) CreateExecuteJob 

func (c *MrsClient) CreateExecuteJob(request *model.CreateExecuteJobRequest) (*model.CreateExecuteJobResponse, error)

CreateExecuteJob 新增并执行作业

在MRS集群中新增并提交一个作业。

需要先在集群详情页的“概览”页签，单击“IAM用户同步”右侧的“同步”进行IAM用户同步，然后再通过该接口提交作业。

如需使用OBS加密功能，请先参考“MRS用户指南 > 管理现有集群 > 作业管理 > 使用OBS加密数据运行作业”页面进行相关配置后，再调用API接口运行作业。

所有示例中涉及的OBS路径、样例文件及终端节点和AKSK，请提前准备并在提交请求时根据实际情况替换。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) CreateExecuteJobInvoker 

func (c *MrsClient) CreateExecuteJobInvoker(request *model.CreateExecuteJobRequest) *CreateExecuteJobInvoker

CreateExecuteJobInvoker 新增并执行作业

func (*MrsClient) DeleteDataConnector 

func (c *MrsClient) DeleteDataConnector(request *model.DeleteDataConnectorRequest) (*model.DeleteDataConnectorResponse, error)

DeleteDataConnector 删除数据连接

删除数据连接

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) DeleteDataConnectorInvoker 

func (c *MrsClient) DeleteDataConnectorInvoker(request *model.DeleteDataConnectorRequest) *DeleteDataConnectorInvoker

DeleteDataConnectorInvoker 删除数据连接

func (*MrsClient) ExecuteSql 

func (c *MrsClient) ExecuteSql(request *model.ExecuteSqlRequest) (*model.ExecuteSqlResponse, error)

ExecuteSql 提交SQL语句

在MRS集群中提交并执行一条SQL语句。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ExecuteSqlInvoker 

func (c *MrsClient) ExecuteSqlInvoker(request *model.ExecuteSqlRequest) *ExecuteSqlInvoker

ExecuteSqlInvoker 提交SQL语句

func (*MrsClient) ListDataConnector 

func (c *MrsClient) ListDataConnector(request *model.ListDataConnectorRequest) (*model.ListDataConnectorResponse, error)

ListDataConnector 查询数据连接列表

查询数据连接列表

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ListDataConnectorInvoker 

func (c *MrsClient) ListDataConnectorInvoker(request *model.ListDataConnectorRequest) *ListDataConnectorInvoker

ListDataConnectorInvoker 查询数据连接列表

func (*MrsClient) RunJobFlow 

func (c *MrsClient) RunJobFlow(request *model.RunJobFlowRequest) (*model.RunJobFlowResponse, error)

RunJobFlow 创建集群并提交作业

创建一个MRS集群并提交作业，并支持作业完成后删除集群，支持MRS 1.8.9及以上集群版本使用。使用接口前，您需要先获取下的资源信息。 - 通过VPC创建或查询VPC、子网 - 通过ECS创建或查询密钥对 - 通过[终端节点](https://support.huaweicloud.com/api-mrs/mrs_02_0003.html)获取区域信息 - 参考[MRS服务支持的组件](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)获取MRS版本及对应版本支持的组件信息

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) RunJobFlowInvoker 

func (c *MrsClient) RunJobFlowInvoker(request *model.RunJobFlowRequest) *RunJobFlowInvoker

RunJobFlowInvoker 创建集群并提交作业

func (*MrsClient) ShowAgencyMapping 

func (c *MrsClient) ShowAgencyMapping(request *model.ShowAgencyMappingRequest) (*model.ShowAgencyMappingResponse, error)

ShowAgencyMapping 查询用户（组）与IAM委托的映射关系

获取用户（组）与IAM委托之间的映射关系的详细信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowAgencyMappingInvoker 

func (c *MrsClient) ShowAgencyMappingInvoker(request *model.ShowAgencyMappingRequest) *ShowAgencyMappingInvoker

ShowAgencyMappingInvoker 查询用户（组）与IAM委托的映射关系

func (*MrsClient) ShowAutoScalingPolicy 

func (c *MrsClient) ShowAutoScalingPolicy(request *model.ShowAutoScalingPolicyRequest) (*model.ShowAutoScalingPolicyResponse, error)

ShowAutoScalingPolicy 查看弹性伸缩策略

查看指定集群的所有的弹性伸缩策略信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowAutoScalingPolicyInvoker 

func (c *MrsClient) ShowAutoScalingPolicyInvoker(request *model.ShowAutoScalingPolicyRequest) *ShowAutoScalingPolicyInvoker

ShowAutoScalingPolicyInvoker 查看弹性伸缩策略

func (*MrsClient) ShowHdfsFileList 

func (c *MrsClient) ShowHdfsFileList(request *model.ShowHdfsFileListRequest) (*model.ShowHdfsFileListResponse, error)

ShowHdfsFileList 获取指定目录文件列表

在MRS集群中获取指定目录文件列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowHdfsFileListInvoker 

func (c *MrsClient) ShowHdfsFileListInvoker(request *model.ShowHdfsFileListRequest) *ShowHdfsFileListInvoker

ShowHdfsFileListInvoker 获取指定目录文件列表

func (*MrsClient) ShowJobExeListNew 

func (c *MrsClient) ShowJobExeListNew(request *model.ShowJobExeListNewRequest) (*model.ShowJobExeListNewResponse, error)

ShowJobExeListNew 查询作业列表信息

在MRS指定集群中查询作业列表信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowJobExeListNewInvoker 

func (c *MrsClient) ShowJobExeListNewInvoker(request *model.ShowJobExeListNewRequest) *ShowJobExeListNewInvoker

ShowJobExeListNewInvoker 查询作业列表信息

func (*MrsClient) ShowSingleJobExe 

func (c *MrsClient) ShowSingleJobExe(request *model.ShowSingleJobExeRequest) (*model.ShowSingleJobExeResponse, error)

ShowSingleJobExe 查询单个作业信息

在MRS集群中查询指定作业的详细信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowSingleJobExeInvoker 

func (c *MrsClient) ShowSingleJobExeInvoker(request *model.ShowSingleJobExeRequest) *ShowSingleJobExeInvoker

ShowSingleJobExeInvoker 查询单个作业信息

func (*MrsClient) ShowSqlResult 

func (c *MrsClient) ShowSqlResult(request *model.ShowSqlResultRequest) (*model.ShowSqlResultResponse, error)

ShowSqlResult 查询SQL结果

在MRS集群中查询一条SQL的执行结果。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowSqlResultInvoker 

func (c *MrsClient) ShowSqlResultInvoker(request *model.ShowSqlResultRequest) *ShowSqlResultInvoker

ShowSqlResultInvoker 查询SQL结果

func (*MrsClient) ShowSqlResultWithJob 

func (c *MrsClient) ShowSqlResultWithJob(request *model.ShowSqlResultWithJobRequest) (*model.ShowSqlResultWithJobResponse, error)

ShowSqlResultWithJob 获取SQL结果

在MRS集群中查询SparkSql和SparkScript两种类型作业的SQL语句运行完成后返回的查询结果。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowSqlResultWithJobInvoker 

func (c *MrsClient) ShowSqlResultWithJobInvoker(request *model.ShowSqlResultWithJobRequest) *ShowSqlResultWithJobInvoker

ShowSqlResultWithJobInvoker 获取SQL结果

func (*MrsClient) StopJob 

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

StopJob 终止作业

在MRS集群中终止指定作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) StopJobInvoker 

func (c *MrsClient) StopJobInvoker(request *model.StopJobRequest) *StopJobInvoker

StopJobInvoker 终止作业

func (*MrsClient) UpdateAgencyMapping 

func (c *MrsClient) UpdateAgencyMapping(request *model.UpdateAgencyMappingRequest) (*model.UpdateAgencyMappingResponse, error)

UpdateAgencyMapping 更新用户（组）与IAM委托的映射关系

更新用户（组）与IAM委托之间的映射关系。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) UpdateAgencyMappingInvoker 

func (c *MrsClient) UpdateAgencyMappingInvoker(request *model.UpdateAgencyMappingRequest) *UpdateAgencyMappingInvoker

UpdateAgencyMappingInvoker 更新用户（组）与IAM委托的映射关系

func (*MrsClient) UpdateClusterName 

func (c *MrsClient) UpdateClusterName(request *model.UpdateClusterNameRequest) (*model.UpdateClusterNameResponse, error)

UpdateClusterName 修改集群名称

修改集群名称

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) UpdateClusterNameInvoker 

func (c *MrsClient) UpdateClusterNameInvoker(request *model.UpdateClusterNameRequest) *UpdateClusterNameInvoker

UpdateClusterNameInvoker 修改集群名称

func (*MrsClient) UpdateDataConnector 

func (c *MrsClient) UpdateDataConnector(request *model.UpdateDataConnectorRequest) (*model.UpdateDataConnectorResponse, error)

UpdateDataConnector 更新数据连接

更新数据连接

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) UpdateDataConnectorInvoker 

func (c *MrsClient) UpdateDataConnectorInvoker(request *model.UpdateDataConnectorRequest) *UpdateDataConnectorInvoker

UpdateDataConnectorInvoker 更新数据连接

type RunJobFlowInvoker 

type RunJobFlowInvoker struct {
	*invoker.BaseInvoker
}

func (*RunJobFlowInvoker) Invoke 

func (i *RunJobFlowInvoker) Invoke() (*model.RunJobFlowResponse, error)

type ShowAgencyMappingInvoker 

type ShowAgencyMappingInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAgencyMappingInvoker) Invoke 

func (i *ShowAgencyMappingInvoker) Invoke() (*model.ShowAgencyMappingResponse, error)

type ShowAutoScalingPolicyInvoker 

type ShowAutoScalingPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAutoScalingPolicyInvoker) Invoke 

func (i *ShowAutoScalingPolicyInvoker) Invoke() (*model.ShowAutoScalingPolicyResponse, error)

type ShowHdfsFileListInvoker 

type ShowHdfsFileListInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowHdfsFileListInvoker) Invoke 

func (i *ShowHdfsFileListInvoker) Invoke() (*model.ShowHdfsFileListResponse, error)

type ShowJobExeListNewInvoker 

type ShowJobExeListNewInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobExeListNewInvoker) Invoke 

func (i *ShowJobExeListNewInvoker) Invoke() (*model.ShowJobExeListNewResponse, error)

type ShowSingleJobExeInvoker 

type ShowSingleJobExeInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSingleJobExeInvoker) Invoke 

func (i *ShowSingleJobExeInvoker) Invoke() (*model.ShowSingleJobExeResponse, error)

type ShowSqlResultInvoker 

type ShowSqlResultInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSqlResultInvoker) Invoke 

func (i *ShowSqlResultInvoker) Invoke() (*model.ShowSqlResultResponse, error)

type ShowSqlResultWithJobInvoker 

type ShowSqlResultWithJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSqlResultWithJobInvoker) Invoke 

func (i *ShowSqlResultWithJobInvoker) Invoke() (*model.ShowSqlResultWithJobResponse, error)

type StopJobInvoker 

type StopJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StopJobInvoker) Invoke 

func (i *StopJobInvoker) Invoke() (*model.StopJobResponse, error)

type UpdateAgencyMappingInvoker 

type UpdateAgencyMappingInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateAgencyMappingInvoker) Invoke 

func (i *UpdateAgencyMappingInvoker) Invoke() (*model.UpdateAgencyMappingResponse, error)

type UpdateClusterNameInvoker 

type UpdateClusterNameInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateClusterNameInvoker) Invoke 

func (i *UpdateClusterNameInvoker) Invoke() (*model.UpdateClusterNameResponse, error)

type UpdateDataConnectorInvoker 

type UpdateDataConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateDataConnectorInvoker) Invoke 

func (i *UpdateDataConnectorInvoker) Invoke() (*model.UpdateDataConnectorResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

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.