v2

package
v0.1.79 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2024 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 GenReqDefForAddComponent added in v0.1.67 

func GenReqDefForAddComponent() *def.HttpRequestDef

func GenReqDefForBatchDeleteJobs 

func GenReqDefForBatchDeleteJobs() *def.HttpRequestDef

func GenReqDefForCancelSql 

func GenReqDefForCancelSql() *def.HttpRequestDef

func GenReqDefForCancelSyncIamUser added in v0.1.76 

func GenReqDefForCancelSyncIamUser() *def.HttpRequestDef

func GenReqDefForCreateAutoScalingPolicy added in v0.1.71 

func GenReqDefForCreateAutoScalingPolicy() *def.HttpRequestDef

func GenReqDefForCreateCluster 

func GenReqDefForCreateCluster() *def.HttpRequestDef

func GenReqDefForCreateDataConnector added in v0.1.52 

func GenReqDefForCreateDataConnector() *def.HttpRequestDef

func GenReqDefForCreateExecuteJob 

func GenReqDefForCreateExecuteJob() *def.HttpRequestDef

func GenReqDefForDeleteAutoScalingPolicy added in v0.1.71 

func GenReqDefForDeleteAutoScalingPolicy() *def.HttpRequestDef

func GenReqDefForDeleteDataConnector added in v0.1.52 

func GenReqDefForDeleteDataConnector() *def.HttpRequestDef

func GenReqDefForExecuteSql 

func GenReqDefForExecuteSql() *def.HttpRequestDef

func GenReqDefForExpandCluster added in v0.1.60 

func GenReqDefForExpandCluster() *def.HttpRequestDef

func GenReqDefForListDataConnector added in v0.1.52 

func GenReqDefForListDataConnector() *def.HttpRequestDef

func GenReqDefForRunJobFlow added in v0.1.35 

func GenReqDefForRunJobFlow() *def.HttpRequestDef

func GenReqDefForShowAgencyMapping 

func GenReqDefForShowAgencyMapping() *def.HttpRequestDef

func GenReqDefForShowAutoScalingPolicy added in v0.1.13 

func GenReqDefForShowAutoScalingPolicy() *def.HttpRequestDef

func GenReqDefForShowHdfsFileList 

func GenReqDefForShowHdfsFileList() *def.HttpRequestDef

func GenReqDefForShowJobExeListNew 

func GenReqDefForShowJobExeListNew() *def.HttpRequestDef

func GenReqDefForShowMrsFlavors added in v0.1.76 

func GenReqDefForShowMrsFlavors() *def.HttpRequestDef

func GenReqDefForShowMrsVersionList added in v0.1.57 

func GenReqDefForShowMrsVersionList() *def.HttpRequestDef

func GenReqDefForShowSingleJobExe 

func GenReqDefForShowSingleJobExe() *def.HttpRequestDef

func GenReqDefForShowSqlResult 

func GenReqDefForShowSqlResult() *def.HttpRequestDef

func GenReqDefForShowSqlResultWithJob 

func GenReqDefForShowSqlResultWithJob() *def.HttpRequestDef

func GenReqDefForShowSyncIamUser added in v0.1.76 

func GenReqDefForShowSyncIamUser() *def.HttpRequestDef

func GenReqDefForShowTagQuota added in v0.1.72 

func GenReqDefForShowTagQuota() *def.HttpRequestDef

func GenReqDefForShowTagStatus added in v0.1.72 

func GenReqDefForShowTagStatus() *def.HttpRequestDef

func GenReqDefForShrinkCluster added in v0.1.60 

func GenReqDefForShrinkCluster() *def.HttpRequestDef

func GenReqDefForStopJob 

func GenReqDefForStopJob() *def.HttpRequestDef

func GenReqDefForSwitchClusterTags added in v0.1.72 

func GenReqDefForSwitchClusterTags() *def.HttpRequestDef

func GenReqDefForUpdateAgencyMapping 

func GenReqDefForUpdateAgencyMapping() *def.HttpRequestDef

func GenReqDefForUpdateAutoScalingPolicy added in v0.1.71 

func GenReqDefForUpdateAutoScalingPolicy() *def.HttpRequestDef

func GenReqDefForUpdateClusterName added in v0.1.13 

func GenReqDefForUpdateClusterName() *def.HttpRequestDef

func GenReqDefForUpdateDataConnector added in v0.1.52 

func GenReqDefForUpdateDataConnector() *def.HttpRequestDef

func GenReqDefForUpdateSyncIamUser added in v0.1.76 

func GenReqDefForUpdateSyncIamUser() *def.HttpRequestDef

func MrsClientBuilder 

func MrsClientBuilder() *httpclient.HcHttpClientBuilder

Types

type AddComponentInvoker added in v0.1.67 

type AddComponentInvoker struct {
	*invoker.BaseInvoker
}

func (*AddComponentInvoker) Invoke added in v0.1.67 

func (i *AddComponentInvoker) Invoke() (*model.AddComponentResponse, error)

type BatchDeleteJobsInvoker added in v0.0.90 

type BatchDeleteJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteJobsInvoker) Invoke added in v0.0.90 

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

type CancelSqlInvoker added in v0.0.90 

type CancelSqlInvoker struct {
	*invoker.BaseInvoker
}

func (*CancelSqlInvoker) Invoke added in v0.0.90 

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

type CancelSyncIamUserInvoker added in v0.1.76 

type CancelSyncIamUserInvoker struct {
	*invoker.BaseInvoker
}

func (*CancelSyncIamUserInvoker) Invoke added in v0.1.76 

func (i *CancelSyncIamUserInvoker) Invoke() (*model.CancelSyncIamUserResponse, error)

type CreateAutoScalingPolicyInvoker added in v0.1.71 

type CreateAutoScalingPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateAutoScalingPolicyInvoker) Invoke added in v0.1.71 

func (i *CreateAutoScalingPolicyInvoker) Invoke() (*model.CreateAutoScalingPolicyResponse, error)

type CreateClusterInvoker added in v0.0.90 

type CreateClusterInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateClusterInvoker) Invoke added in v0.0.90 

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

type CreateDataConnectorInvoker added in v0.1.52 

type CreateDataConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateDataConnectorInvoker) Invoke added in v0.1.52 

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

type CreateExecuteJobInvoker added in v0.0.90 

type CreateExecuteJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateExecuteJobInvoker) Invoke added in v0.0.90 

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

type DeleteAutoScalingPolicyInvoker added in v0.1.71 

type DeleteAutoScalingPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteAutoScalingPolicyInvoker) Invoke added in v0.1.71 

func (i *DeleteAutoScalingPolicyInvoker) Invoke() (*model.DeleteAutoScalingPolicyResponse, error)

type DeleteDataConnectorInvoker added in v0.1.52 

type DeleteDataConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteDataConnectorInvoker) Invoke added in v0.1.52 

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

type ExecuteSqlInvoker added in v0.0.90 

type ExecuteSqlInvoker struct {
	*invoker.BaseInvoker
}

func (*ExecuteSqlInvoker) Invoke added in v0.0.90 

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

type ExpandClusterInvoker added in v0.1.60 

type ExpandClusterInvoker struct {
	*invoker.BaseInvoker
}

func (*ExpandClusterInvoker) Invoke added in v0.1.60 

func (i *ExpandClusterInvoker) Invoke() (*model.ExpandClusterResponse, error)

type ListDataConnectorInvoker added in v0.1.52 

type ListDataConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*ListDataConnectorInvoker) Invoke added in v0.1.52 

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

type MrsClient 

type MrsClient struct {
	HcClient *httpclient.HcHttpClient
}

func NewMrsClient 

func NewMrsClient(hcClient *httpclient.HcHttpClient) *MrsClient

func (*MrsClient) AddComponent added in v0.1.67 

func (c *MrsClient) AddComponent(request *model.AddComponentRequest) (*model.AddComponentResponse, error)

AddComponent 集群添加组件

集群添加组件

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) AddComponentInvoker added in v0.1.67 

func (c *MrsClient) AddComponentInvoker(request *model.AddComponentRequest) *AddComponentInvoker

AddComponentInvoker 集群添加组件

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 added in v0.0.90 

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 added in v0.0.90 

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

CancelSqlInvoker 取消SQL执行任务

func (*MrsClient) CancelSyncIamUser added in v0.1.76 

func (c *MrsClient) CancelSyncIamUser(request *model.CancelSyncIamUserRequest) (*model.CancelSyncIamUserResponse, error)

CancelSyncIamUser 指定用户、用户组取消同步

指定用户、用户组取消同步

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) CancelSyncIamUserInvoker added in v0.1.76 

func (c *MrsClient) CancelSyncIamUserInvoker(request *model.CancelSyncIamUserRequest) *CancelSyncIamUserInvoker

CancelSyncIamUserInvoker 指定用户、用户组取消同步

func (*MrsClient) CreateAutoScalingPolicy added in v0.1.71 

func (c *MrsClient) CreateAutoScalingPolicy(request *model.CreateAutoScalingPolicyRequest) (*model.CreateAutoScalingPolicyResponse, error)

CreateAutoScalingPolicy 创建弹性伸缩策略

创建弹性伸缩策略。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) CreateAutoScalingPolicyInvoker added in v0.1.71 

func (c *MrsClient) CreateAutoScalingPolicyInvoker(request *model.CreateAutoScalingPolicyRequest) *CreateAutoScalingPolicyInvoker

CreateAutoScalingPolicyInvoker 创建弹性伸缩策略

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 added in v0.0.90 

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

CreateClusterInvoker 创建集群

func (*MrsClient) CreateDataConnector added in v0.1.52 

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

CreateDataConnector 创建数据连接

创建数据连接

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) CreateDataConnectorInvoker added in v0.1.52 

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 added in v0.0.90 

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

CreateExecuteJobInvoker 新增并执行作业

func (*MrsClient) DeleteAutoScalingPolicy added in v0.1.71 

func (c *MrsClient) DeleteAutoScalingPolicy(request *model.DeleteAutoScalingPolicyRequest) (*model.DeleteAutoScalingPolicyResponse, error)

DeleteAutoScalingPolicy 删除弹性伸缩策略

删除弹性伸缩策略。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) DeleteAutoScalingPolicyInvoker added in v0.1.71 

func (c *MrsClient) DeleteAutoScalingPolicyInvoker(request *model.DeleteAutoScalingPolicyRequest) *DeleteAutoScalingPolicyInvoker

DeleteAutoScalingPolicyInvoker 删除弹性伸缩策略

func (*MrsClient) DeleteDataConnector added in v0.1.52 

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

DeleteDataConnector 删除数据连接

删除数据连接

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) DeleteDataConnectorInvoker added in v0.1.52 

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 added in v0.0.90 

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

ExecuteSqlInvoker 提交SQL语句

func (*MrsClient) ExpandCluster added in v0.1.60 

func (c *MrsClient) ExpandCluster(request *model.ExpandClusterRequest) (*model.ExpandClusterResponse, error)

ExpandCluster 扩容集群

对MRS集群进行扩容。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ExpandClusterInvoker added in v0.1.60 

func (c *MrsClient) ExpandClusterInvoker(request *model.ExpandClusterRequest) *ExpandClusterInvoker

ExpandClusterInvoker 扩容集群

func (*MrsClient) ListDataConnector added in v0.1.52 

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

ListDataConnector 查询数据连接列表

查询数据连接列表

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ListDataConnectorInvoker added in v0.1.52 

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

ListDataConnectorInvoker 查询数据连接列表

func (*MrsClient) RunJobFlow added in v0.1.35 

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 added in v0.1.35 

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 added in v0.0.90 

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

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

func (*MrsClient) ShowAutoScalingPolicy added in v0.1.13 

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

ShowAutoScalingPolicy 查看弹性伸缩策略

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

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowAutoScalingPolicyInvoker added in v0.1.13 

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 added in v0.0.90 

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 added in v0.0.90 

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

ShowJobExeListNewInvoker 查询作业列表信息

func (*MrsClient) ShowMrsFlavors added in v0.1.76 

func (c *MrsClient) ShowMrsFlavors(request *model.ShowMrsFlavorsRequest) (*model.ShowMrsFlavorsResponse, error)

ShowMrsFlavors 查询MRS集群版本可用的规格

查询MRS集群版本可用的规格

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowMrsFlavorsInvoker added in v0.1.76 

func (c *MrsClient) ShowMrsFlavorsInvoker(request *model.ShowMrsFlavorsRequest) *ShowMrsFlavorsInvoker

ShowMrsFlavorsInvoker 查询MRS集群版本可用的规格

func (*MrsClient) ShowMrsVersionList added in v0.1.57 

func (c *MrsClient) ShowMrsVersionList(request *model.ShowMrsVersionListRequest) (*model.ShowMrsVersionListResponse, error)

ShowMrsVersionList 展示MRS版本列表

展示MRS版本列表

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowMrsVersionListInvoker added in v0.1.57 

func (c *MrsClient) ShowMrsVersionListInvoker(request *model.ShowMrsVersionListRequest) *ShowMrsVersionListInvoker

ShowMrsVersionListInvoker 展示MRS版本列表

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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

ShowSqlResultWithJobInvoker 获取SQL结果

func (*MrsClient) ShowSyncIamUser added in v0.1.76 

func (c *MrsClient) ShowSyncIamUser(request *model.ShowSyncIamUserRequest) (*model.ShowSyncIamUserResponse, error)

ShowSyncIamUser 获取已经同步的IAM用户和用户组

获取已经同步的IAM用户和用户组

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowSyncIamUserInvoker added in v0.1.76 

func (c *MrsClient) ShowSyncIamUserInvoker(request *model.ShowSyncIamUserRequest) *ShowSyncIamUserInvoker

ShowSyncIamUserInvoker 获取已经同步的IAM用户和用户组

func (*MrsClient) ShowTagQuota added in v0.1.72 

func (c *MrsClient) ShowTagQuota(request *model.ShowTagQuotaRequest) (*model.ShowTagQuotaResponse, error)

ShowTagQuota 查询标签配额

查询标签配额信息

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowTagQuotaInvoker added in v0.1.72 

func (c *MrsClient) ShowTagQuotaInvoker(request *model.ShowTagQuotaRequest) *ShowTagQuotaInvoker

ShowTagQuotaInvoker 查询标签配额

func (*MrsClient) ShowTagStatus added in v0.1.72 

func (c *MrsClient) ShowTagStatus(request *model.ShowTagStatusRequest) (*model.ShowTagStatusResponse, error)

ShowTagStatus 查询默认标签状态

查询集群默认标签状态

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowTagStatusInvoker added in v0.1.72 

func (c *MrsClient) ShowTagStatusInvoker(request *model.ShowTagStatusRequest) *ShowTagStatusInvoker

ShowTagStatusInvoker 查询默认标签状态

func (*MrsClient) ShrinkCluster added in v0.1.60 

func (c *MrsClient) ShrinkCluster(request *model.ShrinkClusterRequest) (*model.ShrinkClusterResponse, error)

ShrinkCluster 缩容集群

对MRS集群进行缩容。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShrinkClusterInvoker added in v0.1.60 

func (c *MrsClient) ShrinkClusterInvoker(request *model.ShrinkClusterRequest) *ShrinkClusterInvoker

ShrinkClusterInvoker 缩容集群

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 added in v0.0.90 

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

StopJobInvoker 终止作业

func (*MrsClient) SwitchClusterTags added in v0.1.72 

func (c *MrsClient) SwitchClusterTags(request *model.SwitchClusterTagsRequest) (*model.SwitchClusterTagsResponse, error)

SwitchClusterTags 集群操作默认标签

对已有集群启用或关闭集群默认标签。开启后，集群内节点会打上集群默认标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) SwitchClusterTagsInvoker added in v0.1.72 

func (c *MrsClient) SwitchClusterTagsInvoker(request *model.SwitchClusterTagsRequest) *SwitchClusterTagsInvoker

SwitchClusterTagsInvoker 集群操作默认标签

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 added in v0.0.90 

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

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

func (*MrsClient) UpdateAutoScalingPolicy added in v0.1.71 

func (c *MrsClient) UpdateAutoScalingPolicy(request *model.UpdateAutoScalingPolicyRequest) (*model.UpdateAutoScalingPolicyResponse, error)

UpdateAutoScalingPolicy 更新弹性伸缩策略

更新弹性伸缩策略。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) UpdateAutoScalingPolicyInvoker added in v0.1.71 

func (c *MrsClient) UpdateAutoScalingPolicyInvoker(request *model.UpdateAutoScalingPolicyRequest) *UpdateAutoScalingPolicyInvoker

UpdateAutoScalingPolicyInvoker 更新弹性伸缩策略

func (*MrsClient) UpdateClusterName added in v0.1.13 

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

UpdateClusterName 修改集群名称

修改集群名称

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) UpdateClusterNameInvoker added in v0.1.13 

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

UpdateClusterNameInvoker 修改集群名称

func (*MrsClient) UpdateDataConnector added in v0.1.52 

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

UpdateDataConnector 更新数据连接

更新数据连接

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) UpdateDataConnectorInvoker added in v0.1.52 

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

UpdateDataConnectorInvoker 更新数据连接

func (*MrsClient) UpdateSyncIamUser added in v0.1.76 

func (c *MrsClient) UpdateSyncIamUser(request *model.UpdateSyncIamUserRequest) (*model.UpdateSyncIamUserResponse, error)

UpdateSyncIamUser IAM同步

将IAM用户和用户组同步到manager，指定用户的情况下，会将该用户关联的IAM用户组也同步到manager。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) UpdateSyncIamUserInvoker added in v0.1.76 

func (c *MrsClient) UpdateSyncIamUserInvoker(request *model.UpdateSyncIamUserRequest) *UpdateSyncIamUserInvoker

UpdateSyncIamUserInvoker IAM同步

type RunJobFlowInvoker added in v0.1.35 

type RunJobFlowInvoker struct {
	*invoker.BaseInvoker
}

func (*RunJobFlowInvoker) Invoke added in v0.1.35 

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

type ShowAgencyMappingInvoker added in v0.0.90 

type ShowAgencyMappingInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAgencyMappingInvoker) Invoke added in v0.0.90 

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

type ShowAutoScalingPolicyInvoker added in v0.1.13 

type ShowAutoScalingPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAutoScalingPolicyInvoker) Invoke added in v0.1.13 

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

type ShowHdfsFileListInvoker added in v0.0.90 

type ShowHdfsFileListInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowHdfsFileListInvoker) Invoke added in v0.0.90 

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

type ShowJobExeListNewInvoker added in v0.0.90 

type ShowJobExeListNewInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobExeListNewInvoker) Invoke added in v0.0.90 

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

type ShowMrsFlavorsInvoker added in v0.1.76 

type ShowMrsFlavorsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMrsFlavorsInvoker) Invoke added in v0.1.76 

func (i *ShowMrsFlavorsInvoker) Invoke() (*model.ShowMrsFlavorsResponse, error)

type ShowMrsVersionListInvoker added in v0.1.57 

type ShowMrsVersionListInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMrsVersionListInvoker) Invoke added in v0.1.57 

func (i *ShowMrsVersionListInvoker) Invoke() (*model.ShowMrsVersionListResponse, error)

type ShowSingleJobExeInvoker added in v0.0.90 

type ShowSingleJobExeInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSingleJobExeInvoker) Invoke added in v0.0.90 

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

type ShowSqlResultInvoker added in v0.0.90 

type ShowSqlResultInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSqlResultInvoker) Invoke added in v0.0.90 

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

type ShowSqlResultWithJobInvoker added in v0.0.90 

type ShowSqlResultWithJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSqlResultWithJobInvoker) Invoke added in v0.0.90 

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

type ShowSyncIamUserInvoker added in v0.1.76 

type ShowSyncIamUserInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSyncIamUserInvoker) Invoke added in v0.1.76 

func (i *ShowSyncIamUserInvoker) Invoke() (*model.ShowSyncIamUserResponse, error)

type ShowTagQuotaInvoker added in v0.1.72 

type ShowTagQuotaInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTagQuotaInvoker) Invoke added in v0.1.72 

func (i *ShowTagQuotaInvoker) Invoke() (*model.ShowTagQuotaResponse, error)

type ShowTagStatusInvoker added in v0.1.72 

type ShowTagStatusInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTagStatusInvoker) Invoke added in v0.1.72 

func (i *ShowTagStatusInvoker) Invoke() (*model.ShowTagStatusResponse, error)

type ShrinkClusterInvoker added in v0.1.60 

type ShrinkClusterInvoker struct {
	*invoker.BaseInvoker
}

func (*ShrinkClusterInvoker) Invoke added in v0.1.60 

func (i *ShrinkClusterInvoker) Invoke() (*model.ShrinkClusterResponse, error)

type StopJobInvoker added in v0.0.90 

type StopJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StopJobInvoker) Invoke added in v0.0.90 

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

type SwitchClusterTagsInvoker added in v0.1.72 

type SwitchClusterTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*SwitchClusterTagsInvoker) Invoke added in v0.1.72 

func (i *SwitchClusterTagsInvoker) Invoke() (*model.SwitchClusterTagsResponse, error)

type UpdateAgencyMappingInvoker added in v0.0.90 

type UpdateAgencyMappingInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateAgencyMappingInvoker) Invoke added in v0.0.90 

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

type UpdateAutoScalingPolicyInvoker added in v0.1.71 

type UpdateAutoScalingPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateAutoScalingPolicyInvoker) Invoke added in v0.1.71 

func (i *UpdateAutoScalingPolicyInvoker) Invoke() (*model.UpdateAutoScalingPolicyResponse, error)

type UpdateClusterNameInvoker added in v0.1.13 

type UpdateClusterNameInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateClusterNameInvoker) Invoke added in v0.1.13 

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

type UpdateDataConnectorInvoker added in v0.1.52 

type UpdateDataConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateDataConnectorInvoker) Invoke added in v0.1.52 

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

type UpdateSyncIamUserInvoker added in v0.1.76 

type UpdateSyncIamUserInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateSyncIamUserInvoker) Invoke added in v0.1.76 

func (i *UpdateSyncIamUserInvoker) Invoke() (*model.UpdateSyncIamUserResponse, 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.