v2

package
v0.1.32 Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenReqDefForBatchCreateOrDeleteKafkaTag 

func GenReqDefForBatchCreateOrDeleteKafkaTag() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstanceTopic 

func GenReqDefForBatchDeleteInstanceTopic() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstanceUsers 

func GenReqDefForBatchDeleteInstanceUsers() *def.HttpRequestDef

func GenReqDefForBatchRestartOrDeleteInstances 

func GenReqDefForBatchRestartOrDeleteInstances() *def.HttpRequestDef

func GenReqDefForCreateConnector 

func GenReqDefForCreateConnector() *def.HttpRequestDef

func GenReqDefForCreateInstanceByEngine added in v0.1.24 

func GenReqDefForCreateInstanceByEngine() *def.HttpRequestDef

func GenReqDefForCreateInstanceTopic 

func GenReqDefForCreateInstanceTopic() *def.HttpRequestDef

func GenReqDefForCreateInstanceUser 

func GenReqDefForCreateInstanceUser() *def.HttpRequestDef

func GenReqDefForCreatePartition 

func GenReqDefForCreatePartition() *def.HttpRequestDef

func GenReqDefForCreatePostPaidInstance 

func GenReqDefForCreatePostPaidInstance() *def.HttpRequestDef

func GenReqDefForCreateReassignmentTask added in v0.1.24 

func GenReqDefForCreateReassignmentTask() *def.HttpRequestDef

func GenReqDefForCreateSinkTask 

func GenReqDefForCreateSinkTask() *def.HttpRequestDef

func GenReqDefForDeleteBackgroundTask 

func GenReqDefForDeleteBackgroundTask() *def.HttpRequestDef

func GenReqDefForDeleteInstance 

func GenReqDefForDeleteInstance() *def.HttpRequestDef

func GenReqDefForDeleteSinkTask 

func GenReqDefForDeleteSinkTask() *def.HttpRequestDef

func GenReqDefForListAvailableZones 

func GenReqDefForListAvailableZones() *def.HttpRequestDef

func GenReqDefForListBackgroundTasks 

func GenReqDefForListBackgroundTasks() *def.HttpRequestDef

func GenReqDefForListEngineProducts added in v0.0.76 

func GenReqDefForListEngineProducts() *def.HttpRequestDef

func GenReqDefForListInstanceConsumerGroups added in v0.1.2 

func GenReqDefForListInstanceConsumerGroups() *def.HttpRequestDef

func GenReqDefForListInstanceTopics 

func GenReqDefForListInstanceTopics() *def.HttpRequestDef

func GenReqDefForListInstances 

func GenReqDefForListInstances() *def.HttpRequestDef

func GenReqDefForListProducts 

func GenReqDefForListProducts() *def.HttpRequestDef

func GenReqDefForListSinkTasks 

func GenReqDefForListSinkTasks() *def.HttpRequestDef

func GenReqDefForResetManagerPassword 

func GenReqDefForResetManagerPassword() *def.HttpRequestDef

func GenReqDefForResetMessageOffset 

func GenReqDefForResetMessageOffset() *def.HttpRequestDef

func GenReqDefForResetPassword 

func GenReqDefForResetPassword() *def.HttpRequestDef

func GenReqDefForResetUserPasswrod 

func GenReqDefForResetUserPasswrod() *def.HttpRequestDef

func GenReqDefForResizeEngineInstance added in v0.1.24 

func GenReqDefForResizeEngineInstance() *def.HttpRequestDef

func GenReqDefForResizeInstance 

func GenReqDefForResizeInstance() *def.HttpRequestDef

func GenReqDefForRestartManager 

func GenReqDefForRestartManager() *def.HttpRequestDef

func GenReqDefForShowBackgroundTask 

func GenReqDefForShowBackgroundTask() *def.HttpRequestDef

func GenReqDefForShowCesHierarchy 

func GenReqDefForShowCesHierarchy() *def.HttpRequestDef

func GenReqDefForShowCluster 

func GenReqDefForShowCluster() *def.HttpRequestDef

func GenReqDefForShowCoordinators 

func GenReqDefForShowCoordinators() *def.HttpRequestDef

func GenReqDefForShowEngineInstanceExtendProductInfo added in v0.1.24 

func GenReqDefForShowEngineInstanceExtendProductInfo() *def.HttpRequestDef

func GenReqDefForShowGroups 

func GenReqDefForShowGroups() *def.HttpRequestDef

func GenReqDefForShowInstance 

func GenReqDefForShowInstance() *def.HttpRequestDef

func GenReqDefForShowInstanceExtendProductInfo 

func GenReqDefForShowInstanceExtendProductInfo() *def.HttpRequestDef

func GenReqDefForShowInstanceMessages 

func GenReqDefForShowInstanceMessages() *def.HttpRequestDef

func GenReqDefForShowInstanceTopicDetail 

func GenReqDefForShowInstanceTopicDetail() *def.HttpRequestDef

func GenReqDefForShowInstanceUsers 

func GenReqDefForShowInstanceUsers() *def.HttpRequestDef

func GenReqDefForShowKafkaProjectTags 

func GenReqDefForShowKafkaProjectTags() *def.HttpRequestDef

func GenReqDefForShowKafkaTags 

func GenReqDefForShowKafkaTags() *def.HttpRequestDef

func GenReqDefForShowKafkaTopicPartitionDiskusage 

func GenReqDefForShowKafkaTopicPartitionDiskusage() *def.HttpRequestDef

func GenReqDefForShowMaintainWindows 

func GenReqDefForShowMaintainWindows() *def.HttpRequestDef

func GenReqDefForShowMessages 

func GenReqDefForShowMessages() *def.HttpRequestDef

func GenReqDefForShowPartitionBeginningMessage 

func GenReqDefForShowPartitionBeginningMessage() *def.HttpRequestDef

func GenReqDefForShowPartitionEndMessage 

func GenReqDefForShowPartitionEndMessage() *def.HttpRequestDef

func GenReqDefForShowPartitionMessage 

func GenReqDefForShowPartitionMessage() *def.HttpRequestDef

func GenReqDefForShowSinkTaskDetail 

func GenReqDefForShowSinkTaskDetail() *def.HttpRequestDef

func GenReqDefForShowTopicAccessPolicy 

func GenReqDefForShowTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForUpdateInstance 

func GenReqDefForUpdateInstance() *def.HttpRequestDef

func GenReqDefForUpdateInstanceAutoCreateTopic 

func GenReqDefForUpdateInstanceAutoCreateTopic() *def.HttpRequestDef

func GenReqDefForUpdateInstanceCrossVpcIp 

func GenReqDefForUpdateInstanceCrossVpcIp() *def.HttpRequestDef

func GenReqDefForUpdateInstanceTopic 

func GenReqDefForUpdateInstanceTopic() *def.HttpRequestDef

func GenReqDefForUpdateSinkTaskQuota 

func GenReqDefForUpdateSinkTaskQuota() *def.HttpRequestDef

func GenReqDefForUpdateTopicAccessPolicy 

func GenReqDefForUpdateTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForUpdateTopicReplica 

func GenReqDefForUpdateTopicReplica() *def.HttpRequestDef

func KafkaClientBuilder 

func KafkaClientBuilder() *http_client.HcHttpClientBuilder

Types

type BatchCreateOrDeleteKafkaTagInvoker added in v0.0.90 

type BatchCreateOrDeleteKafkaTagInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchCreateOrDeleteKafkaTagInvoker) Invoke added in v0.0.90 

func (i *BatchCreateOrDeleteKafkaTagInvoker) Invoke() (*model.BatchCreateOrDeleteKafkaTagResponse, error)

type BatchDeleteInstanceTopicInvoker added in v0.0.90 

type BatchDeleteInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteInstanceTopicInvoker) Invoke added in v0.0.90 

func (i *BatchDeleteInstanceTopicInvoker) Invoke() (*model.BatchDeleteInstanceTopicResponse, error)

type BatchDeleteInstanceUsersInvoker added in v0.0.90 

type BatchDeleteInstanceUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteInstanceUsersInvoker) Invoke added in v0.0.90 

func (i *BatchDeleteInstanceUsersInvoker) Invoke() (*model.BatchDeleteInstanceUsersResponse, error)

type BatchRestartOrDeleteInstancesInvoker added in v0.0.90 

type BatchRestartOrDeleteInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchRestartOrDeleteInstancesInvoker) Invoke added in v0.0.90 

func (i *BatchRestartOrDeleteInstancesInvoker) Invoke() (*model.BatchRestartOrDeleteInstancesResponse, error)

type CreateConnectorInvoker added in v0.0.90 

type CreateConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateConnectorInvoker) Invoke added in v0.0.90 

func (i *CreateConnectorInvoker) Invoke() (*model.CreateConnectorResponse, error)

type CreateInstanceByEngineInvoker added in v0.1.24 

type CreateInstanceByEngineInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceByEngineInvoker) Invoke added in v0.1.24 

func (i *CreateInstanceByEngineInvoker) Invoke() (*model.CreateInstanceByEngineResponse, error)

type CreateInstanceTopicInvoker added in v0.0.90 

type CreateInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceTopicInvoker) Invoke added in v0.0.90 

func (i *CreateInstanceTopicInvoker) Invoke() (*model.CreateInstanceTopicResponse, error)

type CreateInstanceUserInvoker added in v0.0.90 

type CreateInstanceUserInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceUserInvoker) Invoke added in v0.0.90 

func (i *CreateInstanceUserInvoker) Invoke() (*model.CreateInstanceUserResponse, error)

type CreatePartitionInvoker added in v0.0.90 

type CreatePartitionInvoker struct {
	*invoker.BaseInvoker
}

func (*CreatePartitionInvoker) Invoke added in v0.0.90 

func (i *CreatePartitionInvoker) Invoke() (*model.CreatePartitionResponse, error)

type CreatePostPaidInstanceInvoker added in v0.0.90 

type CreatePostPaidInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreatePostPaidInstanceInvoker) Invoke added in v0.0.90 

func (i *CreatePostPaidInstanceInvoker) Invoke() (*model.CreatePostPaidInstanceResponse, error)

type CreateReassignmentTaskInvoker added in v0.1.24 

type CreateReassignmentTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateReassignmentTaskInvoker) Invoke added in v0.1.24 

func (i *CreateReassignmentTaskInvoker) Invoke() (*model.CreateReassignmentTaskResponse, error)

type CreateSinkTaskInvoker added in v0.0.90 

type CreateSinkTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateSinkTaskInvoker) Invoke added in v0.0.90 

func (i *CreateSinkTaskInvoker) Invoke() (*model.CreateSinkTaskResponse, error)

type DeleteBackgroundTaskInvoker added in v0.0.90 

type DeleteBackgroundTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteBackgroundTaskInvoker) Invoke added in v0.0.90 

func (i *DeleteBackgroundTaskInvoker) Invoke() (*model.DeleteBackgroundTaskResponse, error)

type DeleteInstanceInvoker added in v0.0.90 

type DeleteInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteInstanceInvoker) Invoke added in v0.0.90 

func (i *DeleteInstanceInvoker) Invoke() (*model.DeleteInstanceResponse, error)

type DeleteSinkTaskInvoker added in v0.0.90 

type DeleteSinkTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteSinkTaskInvoker) Invoke added in v0.0.90 

func (i *DeleteSinkTaskInvoker) Invoke() (*model.DeleteSinkTaskResponse, error)

type KafkaClient 

type KafkaClient struct {
	HcClient *http_client.HcHttpClient
}

func NewKafkaClient 

func NewKafkaClient(hcClient *http_client.HcHttpClient) *KafkaClient

func (*KafkaClient) BatchCreateOrDeleteKafkaTag 

func (c *KafkaClient) BatchCreateOrDeleteKafkaTag(request *model.BatchCreateOrDeleteKafkaTagRequest) (*model.BatchCreateOrDeleteKafkaTagResponse, error)

BatchCreateOrDeleteKafkaTag 批量添加或删除实例标签

批量添加或删除实例标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) BatchCreateOrDeleteKafkaTagInvoker added in v0.0.90 

func (c *KafkaClient) BatchCreateOrDeleteKafkaTagInvoker(request *model.BatchCreateOrDeleteKafkaTagRequest) *BatchCreateOrDeleteKafkaTagInvoker

BatchCreateOrDeleteKafkaTagInvoker 批量添加或删除实例标签

func (*KafkaClient) BatchDeleteInstanceTopic 

func (c *KafkaClient) BatchDeleteInstanceTopic(request *model.BatchDeleteInstanceTopicRequest) (*model.BatchDeleteInstanceTopicResponse, error)

BatchDeleteInstanceTopic Kafka实例批量删除Topic

该接口用于向Kafka实例批量删除Topic。批量删除多个消费组时，部分删除成功，部分失败，此时接口返回删除成功，并在返回中显示删除失败的消费组信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) BatchDeleteInstanceTopicInvoker added in v0.0.90 

func (c *KafkaClient) BatchDeleteInstanceTopicInvoker(request *model.BatchDeleteInstanceTopicRequest) *BatchDeleteInstanceTopicInvoker

BatchDeleteInstanceTopicInvoker Kafka实例批量删除Topic

func (*KafkaClient) BatchDeleteInstanceUsers 

func (c *KafkaClient) BatchDeleteInstanceUsers(request *model.BatchDeleteInstanceUsersRequest) (*model.BatchDeleteInstanceUsersResponse, error)

BatchDeleteInstanceUsers 批量删除用户

批量删除Kafka实例的用户。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) BatchDeleteInstanceUsersInvoker added in v0.0.90 

func (c *KafkaClient) BatchDeleteInstanceUsersInvoker(request *model.BatchDeleteInstanceUsersRequest) *BatchDeleteInstanceUsersInvoker

BatchDeleteInstanceUsersInvoker 批量删除用户

func (*KafkaClient) BatchRestartOrDeleteInstances 

func (c *KafkaClient) BatchRestartOrDeleteInstances(request *model.BatchRestartOrDeleteInstancesRequest) (*model.BatchRestartOrDeleteInstancesResponse, error)

BatchRestartOrDeleteInstances 批量重启或删除实例

批量重启或删除实例。

在实例重启过程中，客户端的生产与消费消息等请求会被拒绝。

实例删除后，实例中原有的数据将被删除，且没有备份，请谨慎操作。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) BatchRestartOrDeleteInstancesInvoker added in v0.0.90 

func (c *KafkaClient) BatchRestartOrDeleteInstancesInvoker(request *model.BatchRestartOrDeleteInstancesRequest) *BatchRestartOrDeleteInstancesInvoker

BatchRestartOrDeleteInstancesInvoker 批量重启或删除实例

func (*KafkaClient) CreateConnector 

func (c *KafkaClient) CreateConnector(request *model.CreateConnectorRequest) (*model.CreateConnectorResponse, error)

CreateConnector 创建实例的转储节点

创建实例的转储节点。

**当前通过调用API，只支持按需实例创建转储节点。**

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateConnectorInvoker added in v0.0.90 

func (c *KafkaClient) CreateConnectorInvoker(request *model.CreateConnectorRequest) *CreateConnectorInvoker

CreateConnectorInvoker 创建实例的转储节点

func (*KafkaClient) CreateInstanceByEngine added in v0.1.24 

func (c *KafkaClient) CreateInstanceByEngine(request *model.CreateInstanceByEngineRequest) (*model.CreateInstanceByEngineResponse, error)

CreateInstanceByEngine 创建实例

创建实例。

该接口支持创建按需和包周期两种计费方式的实例。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateInstanceByEngineInvoker added in v0.1.24 

func (c *KafkaClient) CreateInstanceByEngineInvoker(request *model.CreateInstanceByEngineRequest) *CreateInstanceByEngineInvoker

CreateInstanceByEngineInvoker 创建实例

func (*KafkaClient) CreateInstanceTopic 

func (c *KafkaClient) CreateInstanceTopic(request *model.CreateInstanceTopicRequest) (*model.CreateInstanceTopicResponse, error)

CreateInstanceTopic Kafka实例创建Topic

该接口用于向Kafka实例创建Topic。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateInstanceTopicInvoker added in v0.0.90 

func (c *KafkaClient) CreateInstanceTopicInvoker(request *model.CreateInstanceTopicRequest) *CreateInstanceTopicInvoker

CreateInstanceTopicInvoker Kafka实例创建Topic

func (*KafkaClient) CreateInstanceUser 

func (c *KafkaClient) CreateInstanceUser(request *model.CreateInstanceUserRequest) (*model.CreateInstanceUserResponse, error)

CreateInstanceUser 创建用户

创建Kafka实例的用户，用户可连接开启SASL的Kafka实例。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateInstanceUserInvoker added in v0.0.90 

func (c *KafkaClient) CreateInstanceUserInvoker(request *model.CreateInstanceUserRequest) *CreateInstanceUserInvoker

CreateInstanceUserInvoker 创建用户

func (*KafkaClient) CreatePartition 

func (c *KafkaClient) CreatePartition(request *model.CreatePartitionRequest) (*model.CreatePartitionResponse, error)

CreatePartition 新增Kafka实例指定Topic分区

新增Kafka实例指定Topic分区。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreatePartitionInvoker added in v0.0.90 

func (c *KafkaClient) CreatePartitionInvoker(request *model.CreatePartitionRequest) *CreatePartitionInvoker

CreatePartitionInvoker 新增Kafka实例指定Topic分区

func (*KafkaClient) CreatePostPaidInstance 

func (c *KafkaClient) CreatePostPaidInstance(request *model.CreatePostPaidInstanceRequest) (*model.CreatePostPaidInstanceResponse, error)

CreatePostPaidInstance 创建实例

[创建按需计费类型的Kafka实例。](tag:hc,hk,hws,hws_hk,ctc,sbc,hk_sbc,cmcc,hws_eu)[创建kafka实例。](tag:otc,ocb,hws_ocb)

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreatePostPaidInstanceInvoker added in v0.0.90 

func (c *KafkaClient) CreatePostPaidInstanceInvoker(request *model.CreatePostPaidInstanceRequest) *CreatePostPaidInstanceInvoker

CreatePostPaidInstanceInvoker 创建实例

func (*KafkaClient) CreateReassignmentTask added in v0.1.24 

func (c *KafkaClient) CreateReassignmentTask(request *model.CreateReassignmentTaskRequest) (*model.CreateReassignmentTaskResponse, error)

CreateReassignmentTask Kafka实例开始分区重平衡任务

该接口用于向Kafka实例提交分区重平衡任务，若成功则返回重平衡任务的job id。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateReassignmentTaskInvoker added in v0.1.24 

func (c *KafkaClient) CreateReassignmentTaskInvoker(request *model.CreateReassignmentTaskRequest) *CreateReassignmentTaskInvoker

CreateReassignmentTaskInvoker Kafka实例开始分区重平衡任务

func (*KafkaClient) CreateSinkTask 

func (c *KafkaClient) CreateSinkTask(request *model.CreateSinkTaskRequest) (*model.CreateSinkTaskResponse, error)

CreateSinkTask 创建转储任务

创建转储任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateSinkTaskInvoker added in v0.0.90 

func (c *KafkaClient) CreateSinkTaskInvoker(request *model.CreateSinkTaskRequest) *CreateSinkTaskInvoker

CreateSinkTaskInvoker 创建转储任务

func (*KafkaClient) DeleteBackgroundTask 

func (c *KafkaClient) DeleteBackgroundTask(request *model.DeleteBackgroundTaskRequest) (*model.DeleteBackgroundTaskResponse, error)

DeleteBackgroundTask 删除后台任务管理中的指定记录

删除后台任务管理中的指定记录。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) DeleteBackgroundTaskInvoker added in v0.0.90 

func (c *KafkaClient) DeleteBackgroundTaskInvoker(request *model.DeleteBackgroundTaskRequest) *DeleteBackgroundTaskInvoker

DeleteBackgroundTaskInvoker 删除后台任务管理中的指定记录

func (*KafkaClient) DeleteInstance 

func (c *KafkaClient) DeleteInstance(request *model.DeleteInstanceRequest) (*model.DeleteInstanceResponse, error)

DeleteInstance 删除指定的实例

删除指定的实例，释放该实例的所有资源。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) DeleteInstanceInvoker added in v0.0.90 

func (c *KafkaClient) DeleteInstanceInvoker(request *model.DeleteInstanceRequest) *DeleteInstanceInvoker

DeleteInstanceInvoker 删除指定的实例

func (*KafkaClient) DeleteSinkTask 

func (c *KafkaClient) DeleteSinkTask(request *model.DeleteSinkTaskRequest) (*model.DeleteSinkTaskResponse, error)

DeleteSinkTask 删除单个转储任务

删除单个转储任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) DeleteSinkTaskInvoker added in v0.0.90 

func (c *KafkaClient) DeleteSinkTaskInvoker(request *model.DeleteSinkTaskRequest) *DeleteSinkTaskInvoker

DeleteSinkTaskInvoker 删除单个转储任务

func (*KafkaClient) ListAvailableZones 

func (c *KafkaClient) ListAvailableZones(request *model.ListAvailableZonesRequest) (*model.ListAvailableZonesResponse, error)

ListAvailableZones 查询可用区信息

在创建实例时，需要配置实例所在的可用区ID，可通过该接口查询可用区的ID。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListAvailableZonesInvoker added in v0.0.90 

func (c *KafkaClient) ListAvailableZonesInvoker(request *model.ListAvailableZonesRequest) *ListAvailableZonesInvoker

ListAvailableZonesInvoker 查询可用区信息

func (*KafkaClient) ListBackgroundTasks 

func (c *KafkaClient) ListBackgroundTasks(request *model.ListBackgroundTasksRequest) (*model.ListBackgroundTasksResponse, error)

ListBackgroundTasks 查询实例的后台任务列表

查询实例的后台任务列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListBackgroundTasksInvoker added in v0.0.90 

func (c *KafkaClient) ListBackgroundTasksInvoker(request *model.ListBackgroundTasksRequest) *ListBackgroundTasksInvoker

ListBackgroundTasksInvoker 查询实例的后台任务列表

func (*KafkaClient) ListEngineProducts added in v0.0.76 

func (c *KafkaClient) ListEngineProducts(request *model.ListEngineProductsRequest) (*model.ListEngineProductsResponse, error)

ListEngineProducts 查询产品规格列表

查询产品规格列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListEngineProductsInvoker added in v0.0.90 

func (c *KafkaClient) ListEngineProductsInvoker(request *model.ListEngineProductsRequest) *ListEngineProductsInvoker

ListEngineProductsInvoker 查询产品规格列表

func (*KafkaClient) ListInstanceConsumerGroups added in v0.1.2 

func (c *KafkaClient) ListInstanceConsumerGroups(request *model.ListInstanceConsumerGroupsRequest) (*model.ListInstanceConsumerGroupsResponse, error)

ListInstanceConsumerGroups 查询所有消费组

查询所有消费组。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListInstanceConsumerGroupsInvoker added in v0.1.2 

func (c *KafkaClient) ListInstanceConsumerGroupsInvoker(request *model.ListInstanceConsumerGroupsRequest) *ListInstanceConsumerGroupsInvoker

ListInstanceConsumerGroupsInvoker 查询所有消费组

func (*KafkaClient) ListInstanceTopics 

func (c *KafkaClient) ListInstanceTopics(request *model.ListInstanceTopicsRequest) (*model.ListInstanceTopicsResponse, error)

ListInstanceTopics Kafka实例查询Topic

该接口用于查询指定Kafka实例的Topic详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListInstanceTopicsInvoker added in v0.0.90 

func (c *KafkaClient) ListInstanceTopicsInvoker(request *model.ListInstanceTopicsRequest) *ListInstanceTopicsInvoker

ListInstanceTopicsInvoker Kafka实例查询Topic

func (*KafkaClient) ListInstances 

func (c *KafkaClient) ListInstances(request *model.ListInstancesRequest) (*model.ListInstancesResponse, error)

ListInstances 查询所有实例列表

查询租户的实例列表，支持按照条件查询。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListInstancesInvoker added in v0.0.90 

func (c *KafkaClient) ListInstancesInvoker(request *model.ListInstancesRequest) *ListInstancesInvoker

ListInstancesInvoker 查询所有实例列表

func (*KafkaClient) ListProducts 

func (c *KafkaClient) ListProducts(request *model.ListProductsRequest) (*model.ListProductsResponse, error)

ListProducts 查询产品规格列表

在创建kafka实例时，需要配置订购的产品ID（即product_id），可通过该接口查询产品规格。

例如，要订购按需计费、基准带宽为100MB的kafka实例，可从接口响应消息中，查找Hourly的消息体，然后找到bandwidth为100MB的记录对应的product_id，该product_id的值即是创建上述kafka实例时需要配置的产品ID。

同时，unavailable_zones字段表示资源不足的可用区列表，如果为空，则表示所有可用区都有资源，如果不为空，则表示字段值的可用区没有资源。所以必须确保您购买的资源所在的可用区有资源，不在该字段列表内。

[例如，响应消息中bandwidth字段为1200MB的记录，unavailable_zones字段包含cn-east-2b、cn-east-2a和cn-east-2d，表示在华东-上海2的可用区1、可用区2、可用区3都没有该资源。](tag:hc,hws)

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListProductsInvoker added in v0.0.90 

func (c *KafkaClient) ListProductsInvoker(request *model.ListProductsRequest) *ListProductsInvoker

ListProductsInvoker 查询产品规格列表

func (*KafkaClient) ListSinkTasks 

func (c *KafkaClient) ListSinkTasks(request *model.ListSinkTasksRequest) (*model.ListSinkTasksResponse, error)

ListSinkTasks 查询转储任务列表

查询转储任务列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListSinkTasksInvoker added in v0.0.90 

func (c *KafkaClient) ListSinkTasksInvoker(request *model.ListSinkTasksRequest) *ListSinkTasksInvoker

ListSinkTasksInvoker 查询转储任务列表

func (*KafkaClient) ResetManagerPassword 

func (c *KafkaClient) ResetManagerPassword(request *model.ResetManagerPasswordRequest) (*model.ResetManagerPasswordResponse, error)

ResetManagerPassword 重置Manager密码

重置Manager密码。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ResetManagerPasswordInvoker added in v0.0.90 

func (c *KafkaClient) ResetManagerPasswordInvoker(request *model.ResetManagerPasswordRequest) *ResetManagerPasswordInvoker

ResetManagerPasswordInvoker 重置Manager密码

func (*KafkaClient) ResetMessageOffset 

func (c *KafkaClient) ResetMessageOffset(request *model.ResetMessageOffsetRequest) (*model.ResetMessageOffsetResponse, error)

ResetMessageOffset 重置消费组消费进度到指定位置

Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。

> 停止待重置消费组客户端，然后等待一段时间（即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间，默认为1000毫秒）后，服务端才认为此消费组客户端已下线。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ResetMessageOffsetInvoker added in v0.0.90 

func (c *KafkaClient) ResetMessageOffsetInvoker(request *model.ResetMessageOffsetRequest) *ResetMessageOffsetInvoker

ResetMessageOffsetInvoker 重置消费组消费进度到指定位置

func (*KafkaClient) ResetPassword 

func (c *KafkaClient) ResetPassword(request *model.ResetPasswordRequest) (*model.ResetPasswordResponse, error)

ResetPassword 重置密码

重置密码。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ResetPasswordInvoker added in v0.0.90 

func (c *KafkaClient) ResetPasswordInvoker(request *model.ResetPasswordRequest) *ResetPasswordInvoker

ResetPasswordInvoker 重置密码

func (*KafkaClient) ResetUserPasswrod 

func (c *KafkaClient) ResetUserPasswrod(request *model.ResetUserPasswrodRequest) (*model.ResetUserPasswrodResponse, error)

ResetUserPasswrod 重置用户密码

重置用户密码

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ResetUserPasswrodInvoker added in v0.0.90 

func (c *KafkaClient) ResetUserPasswrodInvoker(request *model.ResetUserPasswrodRequest) *ResetUserPasswrodInvoker

ResetUserPasswrodInvoker 重置用户密码

func (*KafkaClient) ResizeEngineInstance added in v0.1.24 

func (c *KafkaClient) ResizeEngineInstance(request *model.ResizeEngineInstanceRequest) (*model.ResizeEngineInstanceResponse, error)

ResizeEngineInstance 实例规格变更

实例规格变更。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ResizeEngineInstanceInvoker added in v0.1.24 

func (c *KafkaClient) ResizeEngineInstanceInvoker(request *model.ResizeEngineInstanceRequest) *ResizeEngineInstanceInvoker

ResizeEngineInstanceInvoker 实例规格变更

func (*KafkaClient) ResizeInstance 

func (c *KafkaClient) ResizeInstance(request *model.ResizeInstanceRequest) (*model.ResizeInstanceResponse, error)

ResizeInstance 实例规格变更

实例规格变更。[当前通过调用API，只支持按需实例进行实例规格变更。](tag:hc,hk,hws,hws_hk,ctc,sbc,hk_sbc,cmcc,hws_eu)

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ResizeInstanceInvoker added in v0.0.90 

func (c *KafkaClient) ResizeInstanceInvoker(request *model.ResizeInstanceRequest) *ResizeInstanceInvoker

ResizeInstanceInvoker 实例规格变更

func (*KafkaClient) RestartManager 

func (c *KafkaClient) RestartManager(request *model.RestartManagerRequest) (*model.RestartManagerResponse, error)

RestartManager 重启Manager

重启Manager。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) RestartManagerInvoker added in v0.0.90 

func (c *KafkaClient) RestartManagerInvoker(request *model.RestartManagerRequest) *RestartManagerInvoker

RestartManagerInvoker 重启Manager

func (*KafkaClient) ShowBackgroundTask 

func (c *KafkaClient) ShowBackgroundTask(request *model.ShowBackgroundTaskRequest) (*model.ShowBackgroundTaskResponse, error)

ShowBackgroundTask 查询后台任务管理中的指定记录

查询后台任务管理中的指定记录。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowBackgroundTaskInvoker added in v0.0.90 

func (c *KafkaClient) ShowBackgroundTaskInvoker(request *model.ShowBackgroundTaskRequest) *ShowBackgroundTaskInvoker

ShowBackgroundTaskInvoker 查询后台任务管理中的指定记录

func (*KafkaClient) ShowCesHierarchy 

func (c *KafkaClient) ShowCesHierarchy(request *model.ShowCesHierarchyRequest) (*model.ShowCesHierarchyResponse, error)

ShowCesHierarchy 查询实例在CES的监控层级关系

查询实例在CES的监控层级关系。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowCesHierarchyInvoker added in v0.0.90 

func (c *KafkaClient) ShowCesHierarchyInvoker(request *model.ShowCesHierarchyRequest) *ShowCesHierarchyInvoker

ShowCesHierarchyInvoker 查询实例在CES的监控层级关系

func (*KafkaClient) ShowCluster 

func (c *KafkaClient) ShowCluster(request *model.ShowClusterRequest) (*model.ShowClusterResponse, error)

ShowCluster 查询Kafka集群元数据信息

查询Kafka集群元数据信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowClusterInvoker added in v0.0.90 

func (c *KafkaClient) ShowClusterInvoker(request *model.ShowClusterRequest) *ShowClusterInvoker

ShowClusterInvoker 查询Kafka集群元数据信息

func (*KafkaClient) ShowCoordinators 

func (c *KafkaClient) ShowCoordinators(request *model.ShowCoordinatorsRequest) (*model.ShowCoordinatorsResponse, error)

ShowCoordinators 查询Kafka实例的协调器信息

查询Kafka实例的协调器信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowCoordinatorsInvoker added in v0.0.90 

func (c *KafkaClient) ShowCoordinatorsInvoker(request *model.ShowCoordinatorsRequest) *ShowCoordinatorsInvoker

ShowCoordinatorsInvoker 查询Kafka实例的协调器信息

func (*KafkaClient) ShowEngineInstanceExtendProductInfo added in v0.1.24 

func (c *KafkaClient) ShowEngineInstanceExtendProductInfo(request *model.ShowEngineInstanceExtendProductInfoRequest) (*model.ShowEngineInstanceExtendProductInfoResponse, error)

ShowEngineInstanceExtendProductInfo 查询实例的扩容规格列表

查询实例的扩容规格列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowEngineInstanceExtendProductInfoInvoker added in v0.1.24 

func (c *KafkaClient) ShowEngineInstanceExtendProductInfoInvoker(request *model.ShowEngineInstanceExtendProductInfoRequest) *ShowEngineInstanceExtendProductInfoInvoker

ShowEngineInstanceExtendProductInfoInvoker 查询实例的扩容规格列表

func (*KafkaClient) ShowGroups 

func (c *KafkaClient) ShowGroups(request *model.ShowGroupsRequest) (*model.ShowGroupsResponse, error)

ShowGroups 查询消费组信息

查询消费组信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowGroupsInvoker added in v0.0.90 

func (c *KafkaClient) ShowGroupsInvoker(request *model.ShowGroupsRequest) *ShowGroupsInvoker

ShowGroupsInvoker 查询消费组信息

func (*KafkaClient) ShowInstance 

func (c *KafkaClient) ShowInstance(request *model.ShowInstanceRequest) (*model.ShowInstanceResponse, error)

ShowInstance 查询指定实例

查询指定实例的详细信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowInstanceExtendProductInfo 

func (c *KafkaClient) ShowInstanceExtendProductInfo(request *model.ShowInstanceExtendProductInfoRequest) (*model.ShowInstanceExtendProductInfoResponse, error)

ShowInstanceExtendProductInfo 查询实例的扩容规格列表

查询实例的扩容规格列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowInstanceExtendProductInfoInvoker added in v0.0.90 

func (c *KafkaClient) ShowInstanceExtendProductInfoInvoker(request *model.ShowInstanceExtendProductInfoRequest) *ShowInstanceExtendProductInfoInvoker

ShowInstanceExtendProductInfoInvoker 查询实例的扩容规格列表

func (*KafkaClient) ShowInstanceInvoker added in v0.0.90 

func (c *KafkaClient) ShowInstanceInvoker(request *model.ShowInstanceRequest) *ShowInstanceInvoker

ShowInstanceInvoker 查询指定实例

func (*KafkaClient) ShowInstanceMessages 

func (c *KafkaClient) ShowInstanceMessages(request *model.ShowInstanceMessagesRequest) (*model.ShowInstanceMessagesResponse, error)

ShowInstanceMessages 查询消息

查询消息的偏移量和消息内容。 先根据时间戳查询消息的偏移量，再根据偏移量查询消息内容。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowInstanceMessagesInvoker added in v0.0.90 

func (c *KafkaClient) ShowInstanceMessagesInvoker(request *model.ShowInstanceMessagesRequest) *ShowInstanceMessagesInvoker

ShowInstanceMessagesInvoker 查询消息

func (*KafkaClient) ShowInstanceTopicDetail 

func (c *KafkaClient) ShowInstanceTopicDetail(request *model.ShowInstanceTopicDetailRequest) (*model.ShowInstanceTopicDetailResponse, error)

ShowInstanceTopicDetail 查询Kafka实例Topic详细信息(单个实例调用不要超过1s一次)

查询Kafka实例Topic详细信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowInstanceTopicDetailInvoker added in v0.0.90 

func (c *KafkaClient) ShowInstanceTopicDetailInvoker(request *model.ShowInstanceTopicDetailRequest) *ShowInstanceTopicDetailInvoker

ShowInstanceTopicDetailInvoker 查询Kafka实例Topic详细信息(单个实例调用不要超过1s一次)

func (*KafkaClient) ShowInstanceUsers 

func (c *KafkaClient) ShowInstanceUsers(request *model.ShowInstanceUsersRequest) (*model.ShowInstanceUsersResponse, error)

ShowInstanceUsers 查询用户列表

查询用户列表。

Kafka实例开启SASL功能时，才支持多用户管理的功能。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowInstanceUsersInvoker added in v0.0.90 

func (c *KafkaClient) ShowInstanceUsersInvoker(request *model.ShowInstanceUsersRequest) *ShowInstanceUsersInvoker

ShowInstanceUsersInvoker 查询用户列表

func (*KafkaClient) ShowKafkaProjectTags 

func (c *KafkaClient) ShowKafkaProjectTags(request *model.ShowKafkaProjectTagsRequest) (*model.ShowKafkaProjectTagsResponse, error)

ShowKafkaProjectTags 查询项目标签

查询项目标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowKafkaProjectTagsInvoker added in v0.0.90 

func (c *KafkaClient) ShowKafkaProjectTagsInvoker(request *model.ShowKafkaProjectTagsRequest) *ShowKafkaProjectTagsInvoker

ShowKafkaProjectTagsInvoker 查询项目标签

func (*KafkaClient) ShowKafkaTags 

func (c *KafkaClient) ShowKafkaTags(request *model.ShowKafkaTagsRequest) (*model.ShowKafkaTagsResponse, error)

ShowKafkaTags 查询实例标签

查询实例标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowKafkaTagsInvoker added in v0.0.90 

func (c *KafkaClient) ShowKafkaTagsInvoker(request *model.ShowKafkaTagsRequest) *ShowKafkaTagsInvoker

ShowKafkaTagsInvoker 查询实例标签

func (*KafkaClient) ShowKafkaTopicPartitionDiskusage 

func (c *KafkaClient) ShowKafkaTopicPartitionDiskusage(request *model.ShowKafkaTopicPartitionDiskusageRequest) (*model.ShowKafkaTopicPartitionDiskusageResponse, error)

ShowKafkaTopicPartitionDiskusage 查询topic的磁盘存储情况

查询topic在Broker上磁盘占用情况。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowKafkaTopicPartitionDiskusageInvoker added in v0.0.90 

func (c *KafkaClient) ShowKafkaTopicPartitionDiskusageInvoker(request *model.ShowKafkaTopicPartitionDiskusageRequest) *ShowKafkaTopicPartitionDiskusageInvoker

ShowKafkaTopicPartitionDiskusageInvoker 查询topic的磁盘存储情况

func (*KafkaClient) ShowMaintainWindows 

func (c *KafkaClient) ShowMaintainWindows(request *model.ShowMaintainWindowsRequest) (*model.ShowMaintainWindowsResponse, error)

ShowMaintainWindows 查询维护时间窗时间段

查询维护时间窗开始时间和结束时间。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowMaintainWindowsInvoker added in v0.0.90 

func (c *KafkaClient) ShowMaintainWindowsInvoker(request *model.ShowMaintainWindowsRequest) *ShowMaintainWindowsInvoker

ShowMaintainWindowsInvoker 查询维护时间窗时间段

func (*KafkaClient) ShowMessages 

func (c *KafkaClient) ShowMessages(request *model.ShowMessagesRequest) (*model.ShowMessagesResponse, error)

ShowMessages 查询分区指定时间段的消息

查询分区指定时间段的消息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowMessagesInvoker added in v0.0.90 

func (c *KafkaClient) ShowMessagesInvoker(request *model.ShowMessagesRequest) *ShowMessagesInvoker

ShowMessagesInvoker 查询分区指定时间段的消息

func (*KafkaClient) ShowPartitionBeginningMessage 

func (c *KafkaClient) ShowPartitionBeginningMessage(request *model.ShowPartitionBeginningMessageRequest) (*model.ShowPartitionBeginningMessageResponse, error)

ShowPartitionBeginningMessage 查询分区最早消息的位置

查询分区最早消息的位置。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowPartitionBeginningMessageInvoker added in v0.0.90 

func (c *KafkaClient) ShowPartitionBeginningMessageInvoker(request *model.ShowPartitionBeginningMessageRequest) *ShowPartitionBeginningMessageInvoker

ShowPartitionBeginningMessageInvoker 查询分区最早消息的位置

func (*KafkaClient) ShowPartitionEndMessage 

func (c *KafkaClient) ShowPartitionEndMessage(request *model.ShowPartitionEndMessageRequest) (*model.ShowPartitionEndMessageResponse, error)

ShowPartitionEndMessage 查询分区最新消息的位置

查询分区最新消息的位置。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowPartitionEndMessageInvoker added in v0.0.90 

func (c *KafkaClient) ShowPartitionEndMessageInvoker(request *model.ShowPartitionEndMessageRequest) *ShowPartitionEndMessageInvoker

ShowPartitionEndMessageInvoker 查询分区最新消息的位置

func (*KafkaClient) ShowPartitionMessage 

func (c *KafkaClient) ShowPartitionMessage(request *model.ShowPartitionMessageRequest) (*model.ShowPartitionMessageResponse, error)

ShowPartitionMessage 查询分区指定偏移量的消息

查询分区指定偏移量的消息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowPartitionMessageInvoker added in v0.0.90 

func (c *KafkaClient) ShowPartitionMessageInvoker(request *model.ShowPartitionMessageRequest) *ShowPartitionMessageInvoker

ShowPartitionMessageInvoker 查询分区指定偏移量的消息

func (*KafkaClient) ShowSinkTaskDetail 

func (c *KafkaClient) ShowSinkTaskDetail(request *model.ShowSinkTaskDetailRequest) (*model.ShowSinkTaskDetailResponse, error)

ShowSinkTaskDetail 查询单个转储任务

查询单个转储任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowSinkTaskDetailInvoker added in v0.0.90 

func (c *KafkaClient) ShowSinkTaskDetailInvoker(request *model.ShowSinkTaskDetailRequest) *ShowSinkTaskDetailInvoker

ShowSinkTaskDetailInvoker 查询单个转储任务

func (*KafkaClient) ShowTopicAccessPolicy 

func (c *KafkaClient) ShowTopicAccessPolicy(request *model.ShowTopicAccessPolicyRequest) (*model.ShowTopicAccessPolicyResponse, error)

ShowTopicAccessPolicy 查询用户权限

查询用户权限。

Kafka实例开启SASL功能时，才支持多用户管理的功能。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowTopicAccessPolicyInvoker added in v0.0.90 

func (c *KafkaClient) ShowTopicAccessPolicyInvoker(request *model.ShowTopicAccessPolicyRequest) *ShowTopicAccessPolicyInvoker

ShowTopicAccessPolicyInvoker 查询用户权限

func (*KafkaClient) UpdateInstance 

func (c *KafkaClient) UpdateInstance(request *model.UpdateInstanceRequest) (*model.UpdateInstanceResponse, error)

UpdateInstance 修改实例信息

修改实例信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateInstanceAutoCreateTopic 

func (c *KafkaClient) UpdateInstanceAutoCreateTopic(request *model.UpdateInstanceAutoCreateTopicRequest) (*model.UpdateInstanceAutoCreateTopicResponse, error)

UpdateInstanceAutoCreateTopic 开启或关闭实例自动创建topic功能

开启或关闭实例自动创建topic功能。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateInstanceAutoCreateTopicInvoker added in v0.0.90 

func (c *KafkaClient) UpdateInstanceAutoCreateTopicInvoker(request *model.UpdateInstanceAutoCreateTopicRequest) *UpdateInstanceAutoCreateTopicInvoker

UpdateInstanceAutoCreateTopicInvoker 开启或关闭实例自动创建topic功能

func (*KafkaClient) UpdateInstanceCrossVpcIp 

func (c *KafkaClient) UpdateInstanceCrossVpcIp(request *model.UpdateInstanceCrossVpcIpRequest) (*model.UpdateInstanceCrossVpcIpResponse, error)

UpdateInstanceCrossVpcIp 修改实例跨VPC访问的内网IP

修改实例跨VPC访问的内网IP。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateInstanceCrossVpcIpInvoker added in v0.0.90 

func (c *KafkaClient) UpdateInstanceCrossVpcIpInvoker(request *model.UpdateInstanceCrossVpcIpRequest) *UpdateInstanceCrossVpcIpInvoker

UpdateInstanceCrossVpcIpInvoker 修改实例跨VPC访问的内网IP

func (*KafkaClient) UpdateInstanceInvoker added in v0.0.90 

func (c *KafkaClient) UpdateInstanceInvoker(request *model.UpdateInstanceRequest) *UpdateInstanceInvoker

UpdateInstanceInvoker 修改实例信息

func (*KafkaClient) UpdateInstanceTopic 

func (c *KafkaClient) UpdateInstanceTopic(request *model.UpdateInstanceTopicRequest) (*model.UpdateInstanceTopicResponse, error)

UpdateInstanceTopic 修改Kafka实例Topic

修改Kafka实例Topic

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateInstanceTopicInvoker added in v0.0.90 

func (c *KafkaClient) UpdateInstanceTopicInvoker(request *model.UpdateInstanceTopicRequest) *UpdateInstanceTopicInvoker

UpdateInstanceTopicInvoker 修改Kafka实例Topic

func (*KafkaClient) UpdateSinkTaskQuota 

func (c *KafkaClient) UpdateSinkTaskQuota(request *model.UpdateSinkTaskQuotaRequest) (*model.UpdateSinkTaskQuotaResponse, error)

UpdateSinkTaskQuota 修改转储任务的配额

修改转储任务的配额。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateSinkTaskQuotaInvoker added in v0.0.90 

func (c *KafkaClient) UpdateSinkTaskQuotaInvoker(request *model.UpdateSinkTaskQuotaRequest) *UpdateSinkTaskQuotaInvoker

UpdateSinkTaskQuotaInvoker 修改转储任务的配额

func (*KafkaClient) UpdateTopicAccessPolicy 

func (c *KafkaClient) UpdateTopicAccessPolicy(request *model.UpdateTopicAccessPolicyRequest) (*model.UpdateTopicAccessPolicyResponse, error)

UpdateTopicAccessPolicy 设置用户权限

设置用户权限。

Kafka实例开启SASL功能时，才支持多用户管理的功能。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateTopicAccessPolicyInvoker added in v0.0.90 

func (c *KafkaClient) UpdateTopicAccessPolicyInvoker(request *model.UpdateTopicAccessPolicyRequest) *UpdateTopicAccessPolicyInvoker

UpdateTopicAccessPolicyInvoker 设置用户权限

func (*KafkaClient) UpdateTopicReplica 

func (c *KafkaClient) UpdateTopicReplica(request *model.UpdateTopicReplicaRequest) (*model.UpdateTopicReplicaResponse, error)

UpdateTopicReplica 修改Kafka实例Topic分区的副本

修改Kafka实例Topic分区的副本。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateTopicReplicaInvoker added in v0.0.90 

func (c *KafkaClient) UpdateTopicReplicaInvoker(request *model.UpdateTopicReplicaRequest) *UpdateTopicReplicaInvoker

UpdateTopicReplicaInvoker 修改Kafka实例Topic分区的副本

type ListAvailableZonesInvoker added in v0.0.90 

type ListAvailableZonesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAvailableZonesInvoker) Invoke added in v0.0.90 

func (i *ListAvailableZonesInvoker) Invoke() (*model.ListAvailableZonesResponse, error)

type ListBackgroundTasksInvoker added in v0.0.90 

type ListBackgroundTasksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListBackgroundTasksInvoker) Invoke added in v0.0.90 

func (i *ListBackgroundTasksInvoker) Invoke() (*model.ListBackgroundTasksResponse, error)

type ListEngineProductsInvoker added in v0.0.90 

type ListEngineProductsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListEngineProductsInvoker) Invoke added in v0.0.90 

func (i *ListEngineProductsInvoker) Invoke() (*model.ListEngineProductsResponse, error)

type ListInstanceConsumerGroupsInvoker added in v0.1.2 

type ListInstanceConsumerGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstanceConsumerGroupsInvoker) Invoke added in v0.1.2 

func (i *ListInstanceConsumerGroupsInvoker) Invoke() (*model.ListInstanceConsumerGroupsResponse, error)

type ListInstanceTopicsInvoker added in v0.0.90 

type ListInstanceTopicsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstanceTopicsInvoker) Invoke added in v0.0.90 

func (i *ListInstanceTopicsInvoker) Invoke() (*model.ListInstanceTopicsResponse, error)

type ListInstancesInvoker added in v0.0.90 

type ListInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstancesInvoker) Invoke added in v0.0.90 

func (i *ListInstancesInvoker) Invoke() (*model.ListInstancesResponse, error)

type ListProductsInvoker added in v0.0.90 

type ListProductsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListProductsInvoker) Invoke added in v0.0.90 

func (i *ListProductsInvoker) Invoke() (*model.ListProductsResponse, error)

type ListSinkTasksInvoker added in v0.0.90 

type ListSinkTasksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListSinkTasksInvoker) Invoke added in v0.0.90 

func (i *ListSinkTasksInvoker) Invoke() (*model.ListSinkTasksResponse, error)

type ResetManagerPasswordInvoker added in v0.0.90 

type ResetManagerPasswordInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetManagerPasswordInvoker) Invoke added in v0.0.90 

func (i *ResetManagerPasswordInvoker) Invoke() (*model.ResetManagerPasswordResponse, error)

type ResetMessageOffsetInvoker added in v0.0.90 

type ResetMessageOffsetInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetMessageOffsetInvoker) Invoke added in v0.0.90 

func (i *ResetMessageOffsetInvoker) Invoke() (*model.ResetMessageOffsetResponse, error)

type ResetPasswordInvoker added in v0.0.90 

type ResetPasswordInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetPasswordInvoker) Invoke added in v0.0.90 

func (i *ResetPasswordInvoker) Invoke() (*model.ResetPasswordResponse, error)

type ResetUserPasswrodInvoker added in v0.0.90 

type ResetUserPasswrodInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetUserPasswrodInvoker) Invoke added in v0.0.90 

func (i *ResetUserPasswrodInvoker) Invoke() (*model.ResetUserPasswrodResponse, error)

type ResizeEngineInstanceInvoker added in v0.1.24 

type ResizeEngineInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ResizeEngineInstanceInvoker) Invoke added in v0.1.24 

func (i *ResizeEngineInstanceInvoker) Invoke() (*model.ResizeEngineInstanceResponse, error)

type ResizeInstanceInvoker added in v0.0.90 

type ResizeInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ResizeInstanceInvoker) Invoke added in v0.0.90 

func (i *ResizeInstanceInvoker) Invoke() (*model.ResizeInstanceResponse, error)

type RestartManagerInvoker added in v0.0.90 

type RestartManagerInvoker struct {
	*invoker.BaseInvoker
}

func (*RestartManagerInvoker) Invoke added in v0.0.90 

func (i *RestartManagerInvoker) Invoke() (*model.RestartManagerResponse, error)

type ShowBackgroundTaskInvoker added in v0.0.90 

type ShowBackgroundTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowBackgroundTaskInvoker) Invoke added in v0.0.90 

func (i *ShowBackgroundTaskInvoker) Invoke() (*model.ShowBackgroundTaskResponse, error)

type ShowCesHierarchyInvoker added in v0.0.90 

type ShowCesHierarchyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowCesHierarchyInvoker) Invoke added in v0.0.90 

func (i *ShowCesHierarchyInvoker) Invoke() (*model.ShowCesHierarchyResponse, error)

type ShowClusterInvoker added in v0.0.90 

type ShowClusterInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowClusterInvoker) Invoke added in v0.0.90 

func (i *ShowClusterInvoker) Invoke() (*model.ShowClusterResponse, error)

type ShowCoordinatorsInvoker added in v0.0.90 

type ShowCoordinatorsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowCoordinatorsInvoker) Invoke added in v0.0.90 

func (i *ShowCoordinatorsInvoker) Invoke() (*model.ShowCoordinatorsResponse, error)

type ShowEngineInstanceExtendProductInfoInvoker added in v0.1.24 

type ShowEngineInstanceExtendProductInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowEngineInstanceExtendProductInfoInvoker) Invoke added in v0.1.24 

func (i *ShowEngineInstanceExtendProductInfoInvoker) Invoke() (*model.ShowEngineInstanceExtendProductInfoResponse, error)

type ShowGroupsInvoker added in v0.0.90 

type ShowGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowGroupsInvoker) Invoke added in v0.0.90 

func (i *ShowGroupsInvoker) Invoke() (*model.ShowGroupsResponse, error)

type ShowInstanceExtendProductInfoInvoker added in v0.0.90 

type ShowInstanceExtendProductInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceExtendProductInfoInvoker) Invoke added in v0.0.90 

func (i *ShowInstanceExtendProductInfoInvoker) Invoke() (*model.ShowInstanceExtendProductInfoResponse, error)

type ShowInstanceInvoker added in v0.0.90 

type ShowInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceInvoker) Invoke added in v0.0.90 

func (i *ShowInstanceInvoker) Invoke() (*model.ShowInstanceResponse, error)

type ShowInstanceMessagesInvoker added in v0.0.90 

type ShowInstanceMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceMessagesInvoker) Invoke added in v0.0.90 

func (i *ShowInstanceMessagesInvoker) Invoke() (*model.ShowInstanceMessagesResponse, error)

type ShowInstanceTopicDetailInvoker added in v0.0.90 

type ShowInstanceTopicDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceTopicDetailInvoker) Invoke added in v0.0.90 

func (i *ShowInstanceTopicDetailInvoker) Invoke() (*model.ShowInstanceTopicDetailResponse, error)

type ShowInstanceUsersInvoker added in v0.0.90 

type ShowInstanceUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceUsersInvoker) Invoke added in v0.0.90 

func (i *ShowInstanceUsersInvoker) Invoke() (*model.ShowInstanceUsersResponse, error)

type ShowKafkaProjectTagsInvoker added in v0.0.90 

type ShowKafkaProjectTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaProjectTagsInvoker) Invoke added in v0.0.90 

func (i *ShowKafkaProjectTagsInvoker) Invoke() (*model.ShowKafkaProjectTagsResponse, error)

type ShowKafkaTagsInvoker added in v0.0.90 

type ShowKafkaTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaTagsInvoker) Invoke added in v0.0.90 

func (i *ShowKafkaTagsInvoker) Invoke() (*model.ShowKafkaTagsResponse, error)

type ShowKafkaTopicPartitionDiskusageInvoker added in v0.0.90 

type ShowKafkaTopicPartitionDiskusageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaTopicPartitionDiskusageInvoker) Invoke added in v0.0.90 

func (i *ShowKafkaTopicPartitionDiskusageInvoker) Invoke() (*model.ShowKafkaTopicPartitionDiskusageResponse, error)

type ShowMaintainWindowsInvoker added in v0.0.90 

type ShowMaintainWindowsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMaintainWindowsInvoker) Invoke added in v0.0.90 

func (i *ShowMaintainWindowsInvoker) Invoke() (*model.ShowMaintainWindowsResponse, error)

type ShowMessagesInvoker added in v0.0.90 

type ShowMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMessagesInvoker) Invoke added in v0.0.90 

func (i *ShowMessagesInvoker) Invoke() (*model.ShowMessagesResponse, error)

type ShowPartitionBeginningMessageInvoker added in v0.0.90 

type ShowPartitionBeginningMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionBeginningMessageInvoker) Invoke added in v0.0.90 

func (i *ShowPartitionBeginningMessageInvoker) Invoke() (*model.ShowPartitionBeginningMessageResponse, error)

type ShowPartitionEndMessageInvoker added in v0.0.90 

type ShowPartitionEndMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionEndMessageInvoker) Invoke added in v0.0.90 

func (i *ShowPartitionEndMessageInvoker) Invoke() (*model.ShowPartitionEndMessageResponse, error)

type ShowPartitionMessageInvoker added in v0.0.90 

type ShowPartitionMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionMessageInvoker) Invoke added in v0.0.90 

func (i *ShowPartitionMessageInvoker) Invoke() (*model.ShowPartitionMessageResponse, error)

type ShowSinkTaskDetailInvoker added in v0.0.90 

type ShowSinkTaskDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSinkTaskDetailInvoker) Invoke added in v0.0.90 

func (i *ShowSinkTaskDetailInvoker) Invoke() (*model.ShowSinkTaskDetailResponse, error)

type ShowTopicAccessPolicyInvoker added in v0.0.90 

type ShowTopicAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTopicAccessPolicyInvoker) Invoke added in v0.0.90 

func (i *ShowTopicAccessPolicyInvoker) Invoke() (*model.ShowTopicAccessPolicyResponse, error)

type UpdateInstanceAutoCreateTopicInvoker added in v0.0.90 

type UpdateInstanceAutoCreateTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceAutoCreateTopicInvoker) Invoke added in v0.0.90 

func (i *UpdateInstanceAutoCreateTopicInvoker) Invoke() (*model.UpdateInstanceAutoCreateTopicResponse, error)

type UpdateInstanceCrossVpcIpInvoker added in v0.0.90 

type UpdateInstanceCrossVpcIpInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceCrossVpcIpInvoker) Invoke added in v0.0.90 

func (i *UpdateInstanceCrossVpcIpInvoker) Invoke() (*model.UpdateInstanceCrossVpcIpResponse, error)

type UpdateInstanceInvoker added in v0.0.90 

type UpdateInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceInvoker) Invoke added in v0.0.90 

func (i *UpdateInstanceInvoker) Invoke() (*model.UpdateInstanceResponse, error)

type UpdateInstanceTopicInvoker added in v0.0.90 

type UpdateInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceTopicInvoker) Invoke added in v0.0.90 

func (i *UpdateInstanceTopicInvoker) Invoke() (*model.UpdateInstanceTopicResponse, error)

type UpdateSinkTaskQuotaInvoker added in v0.0.90 

type UpdateSinkTaskQuotaInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateSinkTaskQuotaInvoker) Invoke added in v0.0.90 

func (i *UpdateSinkTaskQuotaInvoker) Invoke() (*model.UpdateSinkTaskQuotaResponse, error)

type UpdateTopicAccessPolicyInvoker added in v0.0.90 

type UpdateTopicAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTopicAccessPolicyInvoker) Invoke added in v0.0.90 

func (i *UpdateTopicAccessPolicyInvoker) Invoke() (*model.UpdateTopicAccessPolicyResponse, error)

type UpdateTopicReplicaInvoker added in v0.0.90 

type UpdateTopicReplicaInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTopicReplicaInvoker) Invoke added in v0.0.90 

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