v1

package
v0.1.45 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 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 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 GenReqDefForUpdateClusterScaling added in v0.0.73 

func GenReqDefForUpdateClusterScaling() *def.HttpRequestDef

func MrsClientBuilder 

func MrsClientBuilder() *http_client.HcHttpClientBuilder

Types

type BatchCreateClusterTagsInvoker added in v0.0.90 

type BatchCreateClusterTagsInvoker struct {
	*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) 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) Invoke added in v0.0.90 

func (i *CreateAndExecuteJobInvoker) Invoke() (*model.CreateAndExecuteJobResponse, 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 CreateClusterTagInvoker added in v0.0.90 

type CreateClusterTagInvoker struct {
	*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) 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) 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) 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) Invoke added in v0.0.90 

func (i *DeleteJobExecutionInvoker) Invoke() (*model.DeleteJobExecutionResponse, error)

type ListAllTagsInvoker added in v0.0.90 

type ListAllTagsInvoker struct {
	*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) 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) 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) 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) 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) Invoke added in v0.0.90 

func (i *ListExecuteJobInvoker) Invoke() (*model.ListExecuteJobResponse, error)

type ListHostsInvoker added in v0.0.90 

type ListHostsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListHostsInvoker) Invoke added in v0.0.90 

func (i *ListHostsInvoker) Invoke() (*model.ListHostsResponse, error)

type MrsClient 

type MrsClient struct {
	HcClient *http_client.HcHttpClient
}

func NewMrsClient 

func NewMrsClient(hcClient *http_client.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 added in v0.0.73 

func (c *MrsClient) CreateAndExecuteJob(request *model.CreateAndExecuteJobRequest) (*model.CreateAndExecuteJobResponse, error)

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

func (c *MrsClient) CreateAndExecuteJobInvoker(request *model.CreateAndExecuteJobRequest) *CreateAndExecuteJobInvoker

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

func (c *MrsClient) DeleteJobExecution(request *model.DeleteJobExecutionRequest) (*model.DeleteJobExecutionResponse, error)

DeleteJobExecution 删除作业执行对象（废弃）

如需使用作业管理接口请参考apiv2接口使用，本接口后续不再进行维护。 删除指定的作业执行对象。该接口兼容Sahara。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) DeleteJobExecutionInvoker added in v0.0.90 

func (c *MrsClient) DeleteJobExecutionInvoker(request *model.DeleteJobExecutionRequest) *DeleteJobExecutionInvoker

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

func (c *MrsClient) ListExecuteJob(request *model.ListExecuteJobRequest) (*model.ListExecuteJobResponse, error)

ListExecuteJob 查询作业exe对象列表（废弃）

如需使用作业管理接口请参考apiv2接口使用，本接口后续不再进行维护。 查询所有作业的exe对象列表。该接口不兼容Sahara。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ListExecuteJobInvoker added in v0.0.90 

func (c *MrsClient) ListExecuteJobInvoker(request *model.ListExecuteJobRequest) *ListExecuteJobInvoker

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

func (c *MrsClient) ShowJobExes(request *model.ShowJobExesRequest) (*model.ShowJobExesResponse, error)

ShowJobExes 查询作业exe对象详情（废弃）

如需使用作业管理接口请参考apiv2接口使用，本接口后续不再进行维护。 查询指定作业的exe对象详细信息。该接口不兼容Sahara。

Please refer to HUAWEI cloud API Explorer for details.

func (*MrsClient) ShowJobExesInvoker added in v0.0.90 

func (c *MrsClient) ShowJobExesInvoker(request *model.ShowJobExesRequest) *ShowJobExesInvoker

ShowJobExesInvoker 查询作业exe对象详情（废弃）

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

func (i *ShowJobExesInvoker) Invoke() (*model.ShowJobExesResponse, error)

type UpdateClusterScalingInvoker added in v0.0.90 

type UpdateClusterScalingInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateClusterScalingInvoker) Invoke added in v0.0.90 

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