Documentation ¶
Index ¶
- func GenReqDefForBatchCreateClusterTags() *def.HttpRequestDef
- func GenReqDefForBatchDeleteClusterTags() *def.HttpRequestDef
- func GenReqDefForCreateAndExecuteJob() *def.HttpRequestDef
- func GenReqDefForCreateCluster() *def.HttpRequestDef
- func GenReqDefForCreateClusterTag() *def.HttpRequestDef
- func GenReqDefForCreateScalingPolicy() *def.HttpRequestDef
- func GenReqDefForDeleteCluster() *def.HttpRequestDef
- func GenReqDefForDeleteClusterTag() *def.HttpRequestDef
- func GenReqDefForDeleteJobExecution() *def.HttpRequestDef
- func GenReqDefForListAllTags() *def.HttpRequestDef
- func GenReqDefForListAvailableZones() *def.HttpRequestDef
- func GenReqDefForListClusterTags() *def.HttpRequestDef
- func GenReqDefForListClusters() *def.HttpRequestDef
- func GenReqDefForListClustersByTags() *def.HttpRequestDef
- func GenReqDefForListExecuteJob() *def.HttpRequestDef
- func GenReqDefForListHosts() *def.HttpRequestDef
- func GenReqDefForShowClusterDetails() *def.HttpRequestDef
- func GenReqDefForShowJobExes() *def.HttpRequestDef
- func GenReqDefForShowMrsVersionMetadata() *def.HttpRequestDef
- func GenReqDefForUpdateClusterScaling() *def.HttpRequestDef
- func MrsClientBuilder() *httpclient.HcHttpClientBuilder
- type BatchCreateClusterTagsInvoker
- type BatchDeleteClusterTagsInvoker
- type CreateAndExecuteJobInvoker
- type CreateClusterInvoker
- type CreateClusterTagInvoker
- type CreateScalingPolicyInvoker
- type DeleteClusterInvoker
- type DeleteClusterTagInvoker
- type DeleteJobExecutionInvoker
- type ListAllTagsInvoker
- type ListAvailableZonesInvoker
- type ListClusterTagsInvoker
- type ListClustersByTagsInvoker
- type ListClustersInvoker
- type ListExecuteJobInvoker
- type ListHostsInvoker
- type MrsClient
- func (c *MrsClient) BatchCreateClusterTags(request *model.BatchCreateClusterTagsRequest) (*model.BatchCreateClusterTagsResponse, error)
- func (c *MrsClient) BatchCreateClusterTagsInvoker(request *model.BatchCreateClusterTagsRequest) *BatchCreateClusterTagsInvoker
- func (c *MrsClient) BatchDeleteClusterTags(request *model.BatchDeleteClusterTagsRequest) (*model.BatchDeleteClusterTagsResponse, error)
- func (c *MrsClient) BatchDeleteClusterTagsInvoker(request *model.BatchDeleteClusterTagsRequest) *BatchDeleteClusterTagsInvoker
- func (c *MrsClient) CreateAndExecuteJob(request *model.CreateAndExecuteJobRequest) (*model.CreateAndExecuteJobResponse, error)deprecated
- func (c *MrsClient) CreateAndExecuteJobInvoker(request *model.CreateAndExecuteJobRequest) *CreateAndExecuteJobInvokerdeprecated
- func (c *MrsClient) CreateCluster(request *model.CreateClusterRequest) (*model.CreateClusterResponse, error)
- func (c *MrsClient) CreateClusterInvoker(request *model.CreateClusterRequest) *CreateClusterInvoker
- func (c *MrsClient) CreateClusterTag(request *model.CreateClusterTagRequest) (*model.CreateClusterTagResponse, error)
- func (c *MrsClient) CreateClusterTagInvoker(request *model.CreateClusterTagRequest) *CreateClusterTagInvoker
- func (c *MrsClient) CreateScalingPolicy(request *model.CreateScalingPolicyRequest) (*model.CreateScalingPolicyResponse, error)
- func (c *MrsClient) CreateScalingPolicyInvoker(request *model.CreateScalingPolicyRequest) *CreateScalingPolicyInvoker
- func (c *MrsClient) DeleteCluster(request *model.DeleteClusterRequest) (*model.DeleteClusterResponse, error)
- func (c *MrsClient) DeleteClusterInvoker(request *model.DeleteClusterRequest) *DeleteClusterInvoker
- func (c *MrsClient) DeleteClusterTag(request *model.DeleteClusterTagRequest) (*model.DeleteClusterTagResponse, error)
- func (c *MrsClient) DeleteClusterTagInvoker(request *model.DeleteClusterTagRequest) *DeleteClusterTagInvoker
- func (c *MrsClient) DeleteJobExecution(request *model.DeleteJobExecutionRequest) (*model.DeleteJobExecutionResponse, error)deprecated
- func (c *MrsClient) DeleteJobExecutionInvoker(request *model.DeleteJobExecutionRequest) *DeleteJobExecutionInvokerdeprecated
- func (c *MrsClient) ListAllTags(request *model.ListAllTagsRequest) (*model.ListAllTagsResponse, error)
- func (c *MrsClient) ListAllTagsInvoker(request *model.ListAllTagsRequest) *ListAllTagsInvoker
- func (c *MrsClient) ListAvailableZones(request *model.ListAvailableZonesRequest) (*model.ListAvailableZonesResponse, error)
- func (c *MrsClient) ListAvailableZonesInvoker(request *model.ListAvailableZonesRequest) *ListAvailableZonesInvoker
- func (c *MrsClient) ListClusterTags(request *model.ListClusterTagsRequest) (*model.ListClusterTagsResponse, error)
- func (c *MrsClient) ListClusterTagsInvoker(request *model.ListClusterTagsRequest) *ListClusterTagsInvoker
- func (c *MrsClient) ListClusters(request *model.ListClustersRequest) (*model.ListClustersResponse, error)
- func (c *MrsClient) ListClustersByTags(request *model.ListClustersByTagsRequest) (*model.ListClustersByTagsResponse, error)
- func (c *MrsClient) ListClustersByTagsInvoker(request *model.ListClustersByTagsRequest) *ListClustersByTagsInvoker
- func (c *MrsClient) ListClustersInvoker(request *model.ListClustersRequest) *ListClustersInvoker
- func (c *MrsClient) ListExecuteJob(request *model.ListExecuteJobRequest) (*model.ListExecuteJobResponse, error)deprecated
- func (c *MrsClient) ListExecuteJobInvoker(request *model.ListExecuteJobRequest) *ListExecuteJobInvokerdeprecated
- func (c *MrsClient) ListHosts(request *model.ListHostsRequest) (*model.ListHostsResponse, error)
- func (c *MrsClient) ListHostsInvoker(request *model.ListHostsRequest) *ListHostsInvoker
- func (c *MrsClient) ShowClusterDetails(request *model.ShowClusterDetailsRequest) (*model.ShowClusterDetailsResponse, error)
- func (c *MrsClient) ShowClusterDetailsInvoker(request *model.ShowClusterDetailsRequest) *ShowClusterDetailsInvoker
- func (c *MrsClient) ShowJobExes(request *model.ShowJobExesRequest) (*model.ShowJobExesResponse, error)deprecated
- func (c *MrsClient) ShowJobExesInvoker(request *model.ShowJobExesRequest) *ShowJobExesInvokerdeprecated
- func (c *MrsClient) ShowMrsVersionMetadata(request *model.ShowMrsVersionMetadataRequest) (*model.ShowMrsVersionMetadataResponse, error)
- func (c *MrsClient) ShowMrsVersionMetadataInvoker(request *model.ShowMrsVersionMetadataRequest) *ShowMrsVersionMetadataInvoker
- func (c *MrsClient) UpdateClusterScaling(request *model.UpdateClusterScalingRequest) (*model.UpdateClusterScalingResponse, error)
- func (c *MrsClient) UpdateClusterScalingInvoker(request *model.UpdateClusterScalingRequest) *UpdateClusterScalingInvoker
- type ShowClusterDetailsInvoker
- type ShowJobExesInvoker
- type ShowMrsVersionMetadataInvoker
- type UpdateClusterScalingInvoker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenReqDefForBatchCreateClusterTags ¶
func GenReqDefForBatchCreateClusterTags() *def.HttpRequestDef
func GenReqDefForBatchDeleteClusterTags ¶
func GenReqDefForBatchDeleteClusterTags() *def.HttpRequestDef
func GenReqDefForCreateAndExecuteJob ¶ added in v0.0.73
func GenReqDefForCreateAndExecuteJob() *def.HttpRequestDef
func GenReqDefForCreateCluster ¶
func GenReqDefForCreateCluster() *def.HttpRequestDef
func GenReqDefForCreateClusterTag ¶
func GenReqDefForCreateClusterTag() *def.HttpRequestDef
func GenReqDefForCreateScalingPolicy ¶ added in v0.0.73
func GenReqDefForCreateScalingPolicy() *def.HttpRequestDef
func GenReqDefForDeleteCluster ¶
func GenReqDefForDeleteCluster() *def.HttpRequestDef
func GenReqDefForDeleteClusterTag ¶
func GenReqDefForDeleteClusterTag() *def.HttpRequestDef
func GenReqDefForDeleteJobExecution ¶ added in v0.0.73
func GenReqDefForDeleteJobExecution() *def.HttpRequestDef
func GenReqDefForListAllTags ¶
func GenReqDefForListAllTags() *def.HttpRequestDef
func GenReqDefForListAvailableZones ¶ added in v0.1.43
func GenReqDefForListAvailableZones() *def.HttpRequestDef
func GenReqDefForListClusterTags ¶
func GenReqDefForListClusterTags() *def.HttpRequestDef
func GenReqDefForListClusters ¶ added in v0.0.51
func GenReqDefForListClusters() *def.HttpRequestDef
func GenReqDefForListClustersByTags ¶
func GenReqDefForListClustersByTags() *def.HttpRequestDef
func GenReqDefForListExecuteJob ¶ added in v0.0.73
func GenReqDefForListExecuteJob() *def.HttpRequestDef
func GenReqDefForListHosts ¶ added in v0.0.73
func GenReqDefForListHosts() *def.HttpRequestDef
func GenReqDefForShowClusterDetails ¶ added in v0.0.73
func GenReqDefForShowClusterDetails() *def.HttpRequestDef
func GenReqDefForShowJobExes ¶ added in v0.0.73
func GenReqDefForShowJobExes() *def.HttpRequestDef
func GenReqDefForShowMrsVersionMetadata ¶ added in v0.1.72
func GenReqDefForShowMrsVersionMetadata() *def.HttpRequestDef
func GenReqDefForUpdateClusterScaling ¶ added in v0.0.73
func GenReqDefForUpdateClusterScaling() *def.HttpRequestDef
func MrsClientBuilder ¶
func MrsClientBuilder() *httpclient.HcHttpClientBuilder
Types ¶
type BatchCreateClusterTagsInvoker ¶ added in v0.0.90
type BatchCreateClusterTagsInvoker struct {
*invoker.BaseInvoker
}
func (*BatchCreateClusterTagsInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *BatchCreateClusterTagsInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*BatchCreateClusterTagsInvoker) Invoke ¶ added in v0.0.90
func (i *BatchCreateClusterTagsInvoker) Invoke() (*model.BatchCreateClusterTagsResponse, error)
type BatchDeleteClusterTagsInvoker ¶ added in v0.0.90
type BatchDeleteClusterTagsInvoker struct {
*invoker.BaseInvoker
}
func (*BatchDeleteClusterTagsInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *BatchDeleteClusterTagsInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*BatchDeleteClusterTagsInvoker) Invoke ¶ added in v0.0.90
func (i *BatchDeleteClusterTagsInvoker) Invoke() (*model.BatchDeleteClusterTagsResponse, error)
type CreateAndExecuteJobInvoker ¶ added in v0.0.90
type CreateAndExecuteJobInvoker struct {
*invoker.BaseInvoker
}
func (*CreateAndExecuteJobInvoker) GetBaseInvoker
deprecated
added in
v0.1.118
func (i *CreateAndExecuteJobInvoker) GetBaseInvoker() *invoker.BaseInvoker
Deprecated: This function is deprecated and will be removed in the future versions.
func (*CreateAndExecuteJobInvoker) Invoke
deprecated
added in
v0.0.90
func (i *CreateAndExecuteJobInvoker) Invoke() (*model.CreateAndExecuteJobResponse, error)
Deprecated: This function is deprecated and will be removed in the future versions.
type CreateClusterInvoker ¶ added in v0.0.90
type CreateClusterInvoker struct {
*invoker.BaseInvoker
}
func (*CreateClusterInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *CreateClusterInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*CreateClusterInvoker) Invoke ¶ added in v0.0.90
func (i *CreateClusterInvoker) Invoke() (*model.CreateClusterResponse, error)
type CreateClusterTagInvoker ¶ added in v0.0.90
type CreateClusterTagInvoker struct {
*invoker.BaseInvoker
}
func (*CreateClusterTagInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *CreateClusterTagInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*CreateClusterTagInvoker) Invoke ¶ added in v0.0.90
func (i *CreateClusterTagInvoker) Invoke() (*model.CreateClusterTagResponse, error)
type CreateScalingPolicyInvoker ¶ added in v0.0.90
type CreateScalingPolicyInvoker struct {
*invoker.BaseInvoker
}
func (*CreateScalingPolicyInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *CreateScalingPolicyInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*CreateScalingPolicyInvoker) Invoke ¶ added in v0.0.90
func (i *CreateScalingPolicyInvoker) Invoke() (*model.CreateScalingPolicyResponse, error)
type DeleteClusterInvoker ¶ added in v0.0.90
type DeleteClusterInvoker struct {
*invoker.BaseInvoker
}
func (*DeleteClusterInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *DeleteClusterInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*DeleteClusterInvoker) Invoke ¶ added in v0.0.90
func (i *DeleteClusterInvoker) Invoke() (*model.DeleteClusterResponse, error)
type DeleteClusterTagInvoker ¶ added in v0.0.90
type DeleteClusterTagInvoker struct {
*invoker.BaseInvoker
}
func (*DeleteClusterTagInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *DeleteClusterTagInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*DeleteClusterTagInvoker) Invoke ¶ added in v0.0.90
func (i *DeleteClusterTagInvoker) Invoke() (*model.DeleteClusterTagResponse, error)
type DeleteJobExecutionInvoker ¶ added in v0.0.90
type DeleteJobExecutionInvoker struct {
*invoker.BaseInvoker
}
func (*DeleteJobExecutionInvoker) GetBaseInvoker
deprecated
added in
v0.1.118
func (i *DeleteJobExecutionInvoker) GetBaseInvoker() *invoker.BaseInvoker
Deprecated: This function is deprecated and will be removed in the future versions.
func (*DeleteJobExecutionInvoker) Invoke
deprecated
added in
v0.0.90
func (i *DeleteJobExecutionInvoker) Invoke() (*model.DeleteJobExecutionResponse, error)
Deprecated: This function is deprecated and will be removed in the future versions.
type ListAllTagsInvoker ¶ added in v0.0.90
type ListAllTagsInvoker struct {
*invoker.BaseInvoker
}
func (*ListAllTagsInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *ListAllTagsInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*ListAllTagsInvoker) Invoke ¶ added in v0.0.90
func (i *ListAllTagsInvoker) Invoke() (*model.ListAllTagsResponse, error)
type ListAvailableZonesInvoker ¶ added in v0.1.43
type ListAvailableZonesInvoker struct {
*invoker.BaseInvoker
}
func (*ListAvailableZonesInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *ListAvailableZonesInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*ListAvailableZonesInvoker) Invoke ¶ added in v0.1.43
func (i *ListAvailableZonesInvoker) Invoke() (*model.ListAvailableZonesResponse, error)
type ListClusterTagsInvoker ¶ added in v0.0.90
type ListClusterTagsInvoker struct {
*invoker.BaseInvoker
}
func (*ListClusterTagsInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *ListClusterTagsInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*ListClusterTagsInvoker) Invoke ¶ added in v0.0.90
func (i *ListClusterTagsInvoker) Invoke() (*model.ListClusterTagsResponse, error)
type ListClustersByTagsInvoker ¶ added in v0.0.90
type ListClustersByTagsInvoker struct {
*invoker.BaseInvoker
}
func (*ListClustersByTagsInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *ListClustersByTagsInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*ListClustersByTagsInvoker) Invoke ¶ added in v0.0.90
func (i *ListClustersByTagsInvoker) Invoke() (*model.ListClustersByTagsResponse, error)
type ListClustersInvoker ¶ added in v0.0.90
type ListClustersInvoker struct {
*invoker.BaseInvoker
}
func (*ListClustersInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *ListClustersInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*ListClustersInvoker) Invoke ¶ added in v0.0.90
func (i *ListClustersInvoker) Invoke() (*model.ListClustersResponse, error)
type ListExecuteJobInvoker ¶ added in v0.0.90
type ListExecuteJobInvoker struct {
*invoker.BaseInvoker
}
func (*ListExecuteJobInvoker) GetBaseInvoker
deprecated
added in
v0.1.118
func (i *ListExecuteJobInvoker) GetBaseInvoker() *invoker.BaseInvoker
Deprecated: This function is deprecated and will be removed in the future versions.
func (*ListExecuteJobInvoker) Invoke
deprecated
added in
v0.0.90
func (i *ListExecuteJobInvoker) Invoke() (*model.ListExecuteJobResponse, error)
Deprecated: This function is deprecated and will be removed in the future versions.
type ListHostsInvoker ¶ added in v0.0.90
type ListHostsInvoker struct {
*invoker.BaseInvoker
}
func (*ListHostsInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *ListHostsInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*ListHostsInvoker) Invoke ¶ added in v0.0.90
func (i *ListHostsInvoker) Invoke() (*model.ListHostsResponse, error)
type MrsClient ¶
type MrsClient struct {
HcClient *httpclient.HcHttpClient
}
func NewMrsClient ¶
func NewMrsClient(hcClient *httpclient.HcHttpClient) *MrsClient
func (*MrsClient) BatchCreateClusterTags ¶
func (c *MrsClient) BatchCreateClusterTags(request *model.BatchCreateClusterTagsRequest) (*model.BatchCreateClusterTagsResponse, error)
BatchCreateClusterTags 批量添加集群标签
为指定集群批量添加标签。
一个集群上最多有10个标签。
此接口为幂等接口:
- 创建时,同一个集群不允许重复key,如果数据库存在就覆盖。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) BatchCreateClusterTagsInvoker ¶ added in v0.0.90
func (c *MrsClient) BatchCreateClusterTagsInvoker(request *model.BatchCreateClusterTagsRequest) *BatchCreateClusterTagsInvoker
BatchCreateClusterTagsInvoker 批量添加集群标签
func (*MrsClient) BatchDeleteClusterTags ¶
func (c *MrsClient) BatchDeleteClusterTags(request *model.BatchDeleteClusterTagsRequest) (*model.BatchDeleteClusterTagsResponse, error)
BatchDeleteClusterTags 批量删除集群标签
为指定集群批量删除标签。
一个集群上最多有10个标签。
此接口为幂等接口:
- 删除时,如果删除的标签不存在,默认处理成功,删除时不对标签字符集范围做校验。Key长度36个unicode字符,value为43个unicode字符。删除时tags结构体不能缺失,key不能为空,或者空字符串。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) BatchDeleteClusterTagsInvoker ¶ added in v0.0.90
func (c *MrsClient) BatchDeleteClusterTagsInvoker(request *model.BatchDeleteClusterTagsRequest) *BatchDeleteClusterTagsInvoker
BatchDeleteClusterTagsInvoker 批量删除集群标签
func (*MrsClient) CreateAndExecuteJob
deprecated
added in
v0.0.73
func (c *MrsClient) CreateAndExecuteJob(request *model.CreateAndExecuteJobRequest) (*model.CreateAndExecuteJobResponse, error)
Deprecated: This function is deprecated and will be removed in the future versions. CreateAndExecuteJob 新增作业并执行(废弃)
如需使用作业管理接口请参考apiv2接口使用,本接口后续不再进行维护。 在MRS集群中新增一个作业,并执行作业。该接口不兼容Sahara。 集群ID可参考[查询集群列表](https://support.huaweicloud.com/api-mrs/ListClusters.html)接口获取。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) CreateAndExecuteJobInvoker
deprecated
added in
v0.0.90
func (c *MrsClient) CreateAndExecuteJobInvoker(request *model.CreateAndExecuteJobRequest) *CreateAndExecuteJobInvoker
Deprecated: This function is deprecated and will be removed in the future versions. CreateAndExecuteJobInvoker 新增作业并执行(废弃)
func (*MrsClient) CreateCluster ¶
func (c *MrsClient) CreateCluster(request *model.CreateClusterRequest) (*model.CreateClusterResponse, error)
CreateCluster 创建集群并执行作业
创建一个MRS集群,并在集群中提交一个作业。该接口不兼容Sahara。 支持同一时间并发创建10个集群。 使用接口前,您需要先获取下的资源信息。 - 通过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) CreateClusterTag ¶
func (c *MrsClient) CreateClusterTag(request *model.CreateClusterTagRequest) (*model.CreateClusterTagResponse, error)
CreateClusterTag 给指定集群添加标签
为特定的集群添加一个tag。 一个集群上最多有10个标签,此接口为幂等接口。添加标签时,如果创建的标签已经存在(key相同),则覆盖。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) CreateClusterTagInvoker ¶ added in v0.0.90
func (c *MrsClient) CreateClusterTagInvoker(request *model.CreateClusterTagRequest) *CreateClusterTagInvoker
CreateClusterTagInvoker 给指定集群添加标签
func (*MrsClient) CreateScalingPolicy ¶ added in v0.0.73
func (c *MrsClient) CreateScalingPolicy(request *model.CreateScalingPolicyRequest) (*model.CreateScalingPolicyResponse, error)
CreateScalingPolicy 配置弹性伸缩规则
对弹性伸缩规则进行编辑。
在创建集群并执行作业接口中也可以创建弹性伸缩规则。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) CreateScalingPolicyInvoker ¶ added in v0.0.90
func (c *MrsClient) CreateScalingPolicyInvoker(request *model.CreateScalingPolicyRequest) *CreateScalingPolicyInvoker
CreateScalingPolicyInvoker 配置弹性伸缩规则
func (*MrsClient) DeleteCluster ¶
func (c *MrsClient) DeleteCluster(request *model.DeleteClusterRequest) (*model.DeleteClusterResponse, error)
DeleteCluster 删除集群
数据完成处理分析后或者集群运行异常无法提供服务时可删除集群服务。该接口兼容Sahara。
处于如下状态的集群不允许删除: - scaling-out:扩容中 - scaling-in:缩容中 - starting:启动中 - terminating:删除中 - terminated:已删除 - failed:失败
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) DeleteClusterInvoker ¶ added in v0.0.90
func (c *MrsClient) DeleteClusterInvoker(request *model.DeleteClusterRequest) *DeleteClusterInvoker
DeleteClusterInvoker 删除集群
func (*MrsClient) DeleteClusterTag ¶
func (c *MrsClient) DeleteClusterTag(request *model.DeleteClusterTagRequest) (*model.DeleteClusterTagResponse, error)
DeleteClusterTag 删除指定集群的标签
删除特定集群的标签。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) DeleteClusterTagInvoker ¶ added in v0.0.90
func (c *MrsClient) DeleteClusterTagInvoker(request *model.DeleteClusterTagRequest) *DeleteClusterTagInvoker
DeleteClusterTagInvoker 删除指定集群的标签
func (*MrsClient) DeleteJobExecution
deprecated
added in
v0.0.73
func (c *MrsClient) DeleteJobExecution(request *model.DeleteJobExecutionRequest) (*model.DeleteJobExecutionResponse, error)
Deprecated: This function is deprecated and will be removed in the future versions. DeleteJobExecution 删除作业执行对象(废弃)
如需使用作业管理接口请参考apiv2接口使用,本接口后续不再进行维护。 删除指定的作业执行对象。该接口兼容Sahara。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) DeleteJobExecutionInvoker
deprecated
added in
v0.0.90
func (c *MrsClient) DeleteJobExecutionInvoker(request *model.DeleteJobExecutionRequest) *DeleteJobExecutionInvoker
Deprecated: This function is deprecated and will be removed in the future versions. DeleteJobExecutionInvoker 删除作业执行对象(废弃)
func (*MrsClient) ListAllTags ¶
func (c *MrsClient) ListAllTags(request *model.ListAllTagsRequest) (*model.ListAllTagsResponse, error)
ListAllTags 查询所有标签
查询租户在指定Region下的所有标签集合 。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ListAllTagsInvoker ¶ added in v0.0.90
func (c *MrsClient) ListAllTagsInvoker(request *model.ListAllTagsRequest) *ListAllTagsInvoker
ListAllTagsInvoker 查询所有标签
func (*MrsClient) ListAvailableZones ¶ added in v0.1.43
func (c *MrsClient) ListAvailableZones(request *model.ListAvailableZonesRequest) (*model.ListAvailableZonesResponse, error)
ListAvailableZones 查询可用区信息
在创建集群时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ListAvailableZonesInvoker ¶ added in v0.1.43
func (c *MrsClient) ListAvailableZonesInvoker(request *model.ListAvailableZonesRequest) *ListAvailableZonesInvoker
ListAvailableZonesInvoker 查询可用区信息
func (*MrsClient) ListClusterTags ¶
func (c *MrsClient) ListClusterTags(request *model.ListClusterTagsRequest) (*model.ListClusterTagsResponse, error)
ListClusterTags 查询指定集群的标签
查询指定集群的标签信息。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ListClusterTagsInvoker ¶ added in v0.0.90
func (c *MrsClient) ListClusterTagsInvoker(request *model.ListClusterTagsRequest) *ListClusterTagsInvoker
ListClusterTagsInvoker 查询指定集群的标签
func (*MrsClient) ListClusters ¶ added in v0.0.51
func (c *MrsClient) ListClusters(request *model.ListClustersRequest) (*model.ListClustersResponse, error)
ListClusters 查询集群列表
查看用户创建的集群列表信息。该接口不兼容Sahara。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ListClustersByTags ¶
func (c *MrsClient) ListClustersByTags(request *model.ListClustersByTagsRequest) (*model.ListClustersByTagsResponse, error)
ListClustersByTags 查询特定标签的集群列表
使用标签过滤集群。
集群默认按照创建时间倒序,集群tag也按照创建时间倒序。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ListClustersByTagsInvoker ¶ added in v0.0.90
func (c *MrsClient) ListClustersByTagsInvoker(request *model.ListClustersByTagsRequest) *ListClustersByTagsInvoker
ListClustersByTagsInvoker 查询特定标签的集群列表
func (*MrsClient) ListClustersInvoker ¶ added in v0.0.90
func (c *MrsClient) ListClustersInvoker(request *model.ListClustersRequest) *ListClustersInvoker
ListClustersInvoker 查询集群列表
func (*MrsClient) ListExecuteJob
deprecated
added in
v0.0.73
func (c *MrsClient) ListExecuteJob(request *model.ListExecuteJobRequest) (*model.ListExecuteJobResponse, error)
Deprecated: This function is deprecated and will be removed in the future versions. ListExecuteJob 查询作业exe对象列表(废弃)
如需使用作业管理接口请参考apiv2接口使用,本接口后续不再进行维护。 查询所有作业的exe对象列表。该接口不兼容Sahara。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ListExecuteJobInvoker
deprecated
added in
v0.0.90
func (c *MrsClient) ListExecuteJobInvoker(request *model.ListExecuteJobRequest) *ListExecuteJobInvoker
Deprecated: This function is deprecated and will be removed in the future versions. ListExecuteJobInvoker 查询作业exe对象列表(废弃)
func (*MrsClient) ListHosts ¶ added in v0.0.73
func (c *MrsClient) ListHosts(request *model.ListHostsRequest) (*model.ListHostsResponse, error)
ListHosts 查询主机列表
该接口用于查询输入集群的主机列表详情。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ListHostsInvoker ¶ added in v0.0.90
func (c *MrsClient) ListHostsInvoker(request *model.ListHostsRequest) *ListHostsInvoker
ListHostsInvoker 查询主机列表
func (*MrsClient) ShowClusterDetails ¶ added in v0.0.73
func (c *MrsClient) ShowClusterDetails(request *model.ShowClusterDetailsRequest) (*model.ShowClusterDetailsResponse, error)
ShowClusterDetails 查询集群详情
查看指定集群的详细信息。该接口不兼容Sahara。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ShowClusterDetailsInvoker ¶ added in v0.0.90
func (c *MrsClient) ShowClusterDetailsInvoker(request *model.ShowClusterDetailsRequest) *ShowClusterDetailsInvoker
ShowClusterDetailsInvoker 查询集群详情
func (*MrsClient) ShowJobExes
deprecated
added in
v0.0.73
func (c *MrsClient) ShowJobExes(request *model.ShowJobExesRequest) (*model.ShowJobExesResponse, error)
Deprecated: This function is deprecated and will be removed in the future versions. ShowJobExes 查询作业exe对象详情(废弃)
如需使用作业管理接口请参考apiv2接口使用,本接口后续不再进行维护。 查询指定作业的exe对象详细信息。该接口不兼容Sahara。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ShowJobExesInvoker
deprecated
added in
v0.0.90
func (c *MrsClient) ShowJobExesInvoker(request *model.ShowJobExesRequest) *ShowJobExesInvoker
Deprecated: This function is deprecated and will be removed in the future versions. ShowJobExesInvoker 查询作业exe对象详情(废弃)
func (*MrsClient) ShowMrsVersionMetadata ¶ added in v0.1.72
func (c *MrsClient) ShowMrsVersionMetadata(request *model.ShowMrsVersionMetadataRequest) (*model.ShowMrsVersionMetadataResponse, error)
ShowMrsVersionMetadata 查询对应版本元数据
查询对应版本元数据。如果参数里指定集群id,则可查询集群更新过补丁之后的最新元数据。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) ShowMrsVersionMetadataInvoker ¶ added in v0.1.72
func (c *MrsClient) ShowMrsVersionMetadataInvoker(request *model.ShowMrsVersionMetadataRequest) *ShowMrsVersionMetadataInvoker
ShowMrsVersionMetadataInvoker 查询对应版本元数据
func (*MrsClient) UpdateClusterScaling ¶ added in v0.0.73
func (c *MrsClient) UpdateClusterScaling(request *model.UpdateClusterScalingRequest) (*model.UpdateClusterScalingResponse, error)
UpdateClusterScaling 调整集群节点
创建集群后,扩容/缩容集群Core节点或者Task节点。MRS集群创建成功后不支持调整Master节点数量,即不支持扩缩容Master节点。该接口不兼容Sahara。 处于running状态的集群才允许扩容/缩容,其他状态则不允许扩容/缩容。 集群状态和集群ID可参考[查询集群列表](https://support.huaweicloud.com/api-mrs/ListClusters.html)接口获取。 本章节的接口只支持流式集群、分析集群和混合集群,不支持自定义集群。
Please refer to HUAWEI cloud API Explorer for details.
func (*MrsClient) UpdateClusterScalingInvoker ¶ added in v0.0.90
func (c *MrsClient) UpdateClusterScalingInvoker(request *model.UpdateClusterScalingRequest) *UpdateClusterScalingInvoker
UpdateClusterScalingInvoker 调整集群节点
type ShowClusterDetailsInvoker ¶ added in v0.0.90
type ShowClusterDetailsInvoker struct {
*invoker.BaseInvoker
}
func (*ShowClusterDetailsInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *ShowClusterDetailsInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*ShowClusterDetailsInvoker) Invoke ¶ added in v0.0.90
func (i *ShowClusterDetailsInvoker) Invoke() (*model.ShowClusterDetailsResponse, error)
type ShowJobExesInvoker ¶ added in v0.0.90
type ShowJobExesInvoker struct {
*invoker.BaseInvoker
}
func (*ShowJobExesInvoker) GetBaseInvoker
deprecated
added in
v0.1.118
func (i *ShowJobExesInvoker) GetBaseInvoker() *invoker.BaseInvoker
Deprecated: This function is deprecated and will be removed in the future versions.
func (*ShowJobExesInvoker) Invoke
deprecated
added in
v0.0.90
func (i *ShowJobExesInvoker) Invoke() (*model.ShowJobExesResponse, error)
Deprecated: This function is deprecated and will be removed in the future versions.
type ShowMrsVersionMetadataInvoker ¶ added in v0.1.72
type ShowMrsVersionMetadataInvoker struct {
*invoker.BaseInvoker
}
func (*ShowMrsVersionMetadataInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *ShowMrsVersionMetadataInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*ShowMrsVersionMetadataInvoker) Invoke ¶ added in v0.1.72
func (i *ShowMrsVersionMetadataInvoker) Invoke() (*model.ShowMrsVersionMetadataResponse, error)
type UpdateClusterScalingInvoker ¶ added in v0.0.90
type UpdateClusterScalingInvoker struct {
*invoker.BaseInvoker
}
func (*UpdateClusterScalingInvoker) GetBaseInvoker ¶ added in v0.1.118
func (i *UpdateClusterScalingInvoker) GetBaseInvoker() *invoker.BaseInvoker
func (*UpdateClusterScalingInvoker) Invoke ¶ added in v0.0.90
func (i *UpdateClusterScalingInvoker) Invoke() (*model.UpdateClusterScalingResponse, error)