v2

package
v0.1.104 Latest Latest
Warning

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

 Go to latest Published: Jul 4, 2024 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 GenReqDefForBatchDeleteGroup added in v0.1.36 

func GenReqDefForBatchDeleteGroup() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstanceTopic 

func GenReqDefForBatchDeleteInstanceTopic() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstanceUsers 

func GenReqDefForBatchDeleteInstanceUsers() *def.HttpRequestDef

func GenReqDefForBatchDeleteMessageDiagnosisReports added in v0.1.88 

func GenReqDefForBatchDeleteMessageDiagnosisReports() *def.HttpRequestDef

func GenReqDefForBatchRestartOrDeleteInstances 

func GenReqDefForBatchRestartOrDeleteInstances() *def.HttpRequestDef

func GenReqDefForCloseKafkaManager added in v0.1.41 

func GenReqDefForCloseKafkaManager() *def.HttpRequestDef

func GenReqDefForCreateConnector 

func GenReqDefForCreateConnector() *def.HttpRequestDef

func GenReqDefForCreateConnectorTask added in v0.1.84 

func GenReqDefForCreateConnectorTask() *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 GenReqDefForCreateKafkaConsumerGroup added in v0.1.41 

func GenReqDefForCreateKafkaConsumerGroup() *def.HttpRequestDef

func GenReqDefForCreateKafkaUserClientQuotaTask added in v0.1.68 

func GenReqDefForCreateKafkaUserClientQuotaTask() *def.HttpRequestDef

func GenReqDefForCreateMessageDiagnosisTask added in v0.1.88 

func GenReqDefForCreateMessageDiagnosisTask() *def.HttpRequestDef

func GenReqDefForCreatePostPaidInstance 

func GenReqDefForCreatePostPaidInstance() *def.HttpRequestDef

func GenReqDefForCreateReassignmentTask added in v0.1.24 

func GenReqDefForCreateReassignmentTask() *def.HttpRequestDef

func GenReqDefForDeleteBackgroundTask 

func GenReqDefForDeleteBackgroundTask() *def.HttpRequestDef

func GenReqDefForDeleteConnector added in v0.1.41 

func GenReqDefForDeleteConnector() *def.HttpRequestDef

func GenReqDefForDeleteConnectorTask added in v0.1.84 

func GenReqDefForDeleteConnectorTask() *def.HttpRequestDef

func GenReqDefForDeleteInstance 

func GenReqDefForDeleteInstance() *def.HttpRequestDef

func GenReqDefForDeleteKafkaUserClientQuotaTask added in v0.1.68 

func GenReqDefForDeleteKafkaUserClientQuotaTask() *def.HttpRequestDef

func GenReqDefForListAvailableZones 

func GenReqDefForListAvailableZones() *def.HttpRequestDef

func GenReqDefForListBackgroundTasks 

func GenReqDefForListBackgroundTasks() *def.HttpRequestDef

func GenReqDefForListConnectorTasks added in v0.1.84 

func GenReqDefForListConnectorTasks() *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 GenReqDefForListMessageDiagnosisReports added in v0.1.88 

func GenReqDefForListMessageDiagnosisReports() *def.HttpRequestDef

func GenReqDefForListProducts 

func GenReqDefForListProducts() *def.HttpRequestDef

func GenReqDefForListTopicPartitions added in v0.1.49 

func GenReqDefForListTopicPartitions() *def.HttpRequestDef

func GenReqDefForListTopicProducers added in v0.1.49 

func GenReqDefForListTopicProducers() *def.HttpRequestDef

func GenReqDefForModifyInstanceConfigs added in v0.1.65 

func GenReqDefForModifyInstanceConfigs() *def.HttpRequestDef

func GenReqDefForPauseConnectorTask added in v0.1.84 

func GenReqDefForPauseConnectorTask() *def.HttpRequestDef

func GenReqDefForResetManagerPassword 

func GenReqDefForResetManagerPassword() *def.HttpRequestDef

func GenReqDefForResetMessageOffset 

func GenReqDefForResetMessageOffset() *def.HttpRequestDef

func GenReqDefForResetMessageOffsetWithEngine added in v0.1.76 

func GenReqDefForResetMessageOffsetWithEngine() *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 GenReqDefForRestartConnectorTask added in v0.1.84 

func GenReqDefForRestartConnectorTask() *def.HttpRequestDef

func GenReqDefForRestartManager 

func GenReqDefForRestartManager() *def.HttpRequestDef

func GenReqDefForResumeConnectorTask added in v0.1.84 

func GenReqDefForResumeConnectorTask() *def.HttpRequestDef

func GenReqDefForSendKafkaMessage added in v0.1.73 

func GenReqDefForSendKafkaMessage() *def.HttpRequestDef

func GenReqDefForShowBackgroundTask 

func GenReqDefForShowBackgroundTask() *def.HttpRequestDef

func GenReqDefForShowCesHierarchy 

func GenReqDefForShowCesHierarchy() *def.HttpRequestDef

func GenReqDefForShowCluster 

func GenReqDefForShowCluster() *def.HttpRequestDef

func GenReqDefForShowConnectorTask added in v0.1.84 

func GenReqDefForShowConnectorTask() *def.HttpRequestDef

func GenReqDefForShowCoordinators 

func GenReqDefForShowCoordinators() *def.HttpRequestDef

func GenReqDefForShowDiagnosisPreCheck added in v0.1.88 

func GenReqDefForShowDiagnosisPreCheck() *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 GenReqDefForShowInstanceConfigs added in v0.1.65 

func GenReqDefForShowInstanceConfigs() *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 GenReqDefForShowKafkaUserClientQuota added in v0.1.68 

func GenReqDefForShowKafkaUserClientQuota() *def.HttpRequestDef

func GenReqDefForShowMaintainWindows 

func GenReqDefForShowMaintainWindows() *def.HttpRequestDef

func GenReqDefForShowMessageDiagnosisReport added in v0.1.88 

func GenReqDefForShowMessageDiagnosisReport() *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 GenReqDefForShowTopicAccessPolicy 

func GenReqDefForShowTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForUpdateInstance 

func GenReqDefForUpdateInstance() *def.HttpRequestDef

func GenReqDefForUpdateInstanceAutoCreateTopic 

func GenReqDefForUpdateInstanceAutoCreateTopic() *def.HttpRequestDef

func GenReqDefForUpdateInstanceConsumerGroup added in v0.1.59 

func GenReqDefForUpdateInstanceConsumerGroup() *def.HttpRequestDef

func GenReqDefForUpdateInstanceCrossVpcIp 

func GenReqDefForUpdateInstanceCrossVpcIp() *def.HttpRequestDef

func GenReqDefForUpdateInstanceTopic 

func GenReqDefForUpdateInstanceTopic() *def.HttpRequestDef

func GenReqDefForUpdateInstanceUser added in v0.1.59 

func GenReqDefForUpdateInstanceUser() *def.HttpRequestDef

func GenReqDefForUpdateKafkaUserClientQuotaTask added in v0.1.68 

func GenReqDefForUpdateKafkaUserClientQuotaTask() *def.HttpRequestDef

func GenReqDefForUpdateTopicAccessPolicy 

func GenReqDefForUpdateTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForUpdateTopicReplica 

func GenReqDefForUpdateTopicReplica() *def.HttpRequestDef

func KafkaClientBuilder 

func KafkaClientBuilder() *httpclient.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 BatchDeleteGroupInvoker added in v0.1.36 

type BatchDeleteGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteGroupInvoker) Invoke added in v0.1.36 

func (i *BatchDeleteGroupInvoker) Invoke() (*model.BatchDeleteGroupResponse, 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 BatchDeleteMessageDiagnosisReportsInvoker added in v0.1.88 

type BatchDeleteMessageDiagnosisReportsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteMessageDiagnosisReportsInvoker) Invoke added in v0.1.88 

func (i *BatchDeleteMessageDiagnosisReportsInvoker) Invoke() (*model.BatchDeleteMessageDiagnosisReportsResponse, 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 CloseKafkaManagerInvoker added in v0.1.41 

type CloseKafkaManagerInvoker struct {
	*invoker.BaseInvoker
}

func (*CloseKafkaManagerInvoker) Invoke added in v0.1.41 

func (i *CloseKafkaManagerInvoker) Invoke() (*model.CloseKafkaManagerResponse, 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 CreateConnectorTaskInvoker added in v0.1.84 

type CreateConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateConnectorTaskInvoker) Invoke added in v0.1.84 

func (i *CreateConnectorTaskInvoker) Invoke() (*model.CreateConnectorTaskResponse, 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 CreateKafkaConsumerGroupInvoker added in v0.1.41 

type CreateKafkaConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateKafkaConsumerGroupInvoker) Invoke added in v0.1.41 

func (i *CreateKafkaConsumerGroupInvoker) Invoke() (*model.CreateKafkaConsumerGroupResponse, error)

type CreateKafkaUserClientQuotaTaskInvoker added in v0.1.68 

type CreateKafkaUserClientQuotaTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateKafkaUserClientQuotaTaskInvoker) Invoke added in v0.1.68 

func (i *CreateKafkaUserClientQuotaTaskInvoker) Invoke() (*model.CreateKafkaUserClientQuotaTaskResponse, error)

type CreateMessageDiagnosisTaskInvoker added in v0.1.88 

type CreateMessageDiagnosisTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateMessageDiagnosisTaskInvoker) Invoke added in v0.1.88 

func (i *CreateMessageDiagnosisTaskInvoker) Invoke() (*model.CreateMessageDiagnosisTaskResponse, 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 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 DeleteConnectorInvoker added in v0.1.41 

type DeleteConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteConnectorInvoker) Invoke added in v0.1.41 

func (i *DeleteConnectorInvoker) Invoke() (*model.DeleteConnectorResponse, error)

type DeleteConnectorTaskInvoker added in v0.1.84 

type DeleteConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteConnectorTaskInvoker) Invoke added in v0.1.84 

func (i *DeleteConnectorTaskInvoker) Invoke() (*model.DeleteConnectorTaskResponse, 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 DeleteKafkaUserClientQuotaTaskInvoker added in v0.1.68 

type DeleteKafkaUserClientQuotaTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteKafkaUserClientQuotaTaskInvoker) Invoke added in v0.1.68 

func (i *DeleteKafkaUserClientQuotaTaskInvoker) Invoke() (*model.DeleteKafkaUserClientQuotaTaskResponse, error)

type KafkaClient 

type KafkaClient struct {
	HcClient *httpclient.HcHttpClient
}

func NewKafkaClient 

func NewKafkaClient(hcClient *httpclient.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) BatchDeleteGroup added in v0.1.36 

func (c *KafkaClient) BatchDeleteGroup(request *model.BatchDeleteGroupRequest) (*model.BatchDeleteGroupResponse, error)

BatchDeleteGroup Kafka实例批量删除消费组

该接口用于向Kafka实例批量删除消费组。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) BatchDeleteGroupInvoker added in v0.1.36 

func (c *KafkaClient) BatchDeleteGroupInvoker(request *model.BatchDeleteGroupRequest) *BatchDeleteGroupInvoker

BatchDeleteGroupInvoker Kafka实例批量删除消费组

func (*KafkaClient) BatchDeleteInstanceTopic 

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

BatchDeleteInstanceTopic Kafka实例批量删除Topic

该接口用于向Kafka实例批量删除Topic。批量删除多个Topic时，部分删除成功，部分失败，此时接口返回删除成功，并在返回中显示删除失败的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) BatchDeleteMessageDiagnosisReports added in v0.1.88 

func (c *KafkaClient) BatchDeleteMessageDiagnosisReports(request *model.BatchDeleteMessageDiagnosisReportsRequest) (*model.BatchDeleteMessageDiagnosisReportsResponse, error)

BatchDeleteMessageDiagnosisReports 批量删除消息积压诊断报告

批量删除消息积压诊断报告

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) BatchDeleteMessageDiagnosisReportsInvoker added in v0.1.88 

func (c *KafkaClient) BatchDeleteMessageDiagnosisReportsInvoker(request *model.BatchDeleteMessageDiagnosisReportsRequest) *BatchDeleteMessageDiagnosisReportsInvoker

BatchDeleteMessageDiagnosisReportsInvoker 批量删除消息积压诊断报告

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) CloseKafkaManager added in v0.1.41 

func (c *KafkaClient) CloseKafkaManager(request *model.CloseKafkaManagerRequest) (*model.CloseKafkaManagerResponse, error)

CloseKafkaManager 关闭Kafka Manager

关闭Kafka Manager，相应的原来开放出的management相关接口也将不可用。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CloseKafkaManagerInvoker added in v0.1.41 

func (c *KafkaClient) CloseKafkaManagerInvoker(request *model.CloseKafkaManagerRequest) *CloseKafkaManagerInvoker

CloseKafkaManagerInvoker 关闭Kafka Manager

func (*KafkaClient) CreateConnector 

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

CreateConnector 开启Smart Connect（按需实例）

开启Smart Connect，提交创建Smart Connect节点任务。

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

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 开启Smart Connect（按需实例）

func (*KafkaClient) CreateConnectorTask added in v0.1.84 

func (c *KafkaClient) CreateConnectorTask(request *model.CreateConnectorTaskRequest) (*model.CreateConnectorTaskResponse, error)

CreateConnectorTask 创建Smart Connect任务

创建Smart Connect任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateConnectorTaskInvoker added in v0.1.84 

func (c *KafkaClient) CreateConnectorTaskInvoker(request *model.CreateConnectorTaskRequest) *CreateConnectorTaskInvoker

CreateConnectorTaskInvoker 创建Smart Connect任务

func (*KafkaClient) CreateInstanceByEngine added in v0.1.24 

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

CreateInstanceByEngine 创建实例

创建实例。

[该接口支持创建按需和包周期两种计费方式的实例。](tag:hws,hws_eu,hws_hk,ocb,hws_ocb,ctc,g42,hk_g42,tm,hk_tm,dt)

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实例。 [ 2023年7月15日前创建的Kafka实例，一个实例最多创建20个用户。2023年7月15日及以后创建的Kafka实例，一个实例最多创建500个用户。](tag:hws,hws_hk)

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) CreateKafkaConsumerGroup added in v0.1.41 

func (c *KafkaClient) CreateKafkaConsumerGroup(request *model.CreateKafkaConsumerGroupRequest) (*model.CreateKafkaConsumerGroupResponse, error)

CreateKafkaConsumerGroup 创建消费组

实例创建消费组

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateKafkaConsumerGroupInvoker added in v0.1.41 

func (c *KafkaClient) CreateKafkaConsumerGroupInvoker(request *model.CreateKafkaConsumerGroupRequest) *CreateKafkaConsumerGroupInvoker

CreateKafkaConsumerGroupInvoker 创建消费组

func (*KafkaClient) CreateKafkaUserClientQuotaTask added in v0.1.68 

func (c *KafkaClient) CreateKafkaUserClientQuotaTask(request *model.CreateKafkaUserClientQuotaTaskRequest) (*model.CreateKafkaUserClientQuotaTaskResponse, error)

CreateKafkaUserClientQuotaTask 创建用户/客户端流控配置

该接口用于向Kafka实例提交创建用户、客户端级别的流控任务，若成功则返回流控任务的job_id。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateKafkaUserClientQuotaTaskInvoker added in v0.1.68 

func (c *KafkaClient) CreateKafkaUserClientQuotaTaskInvoker(request *model.CreateKafkaUserClientQuotaTaskRequest) *CreateKafkaUserClientQuotaTaskInvoker

CreateKafkaUserClientQuotaTaskInvoker 创建用户/客户端流控配置

func (*KafkaClient) CreateMessageDiagnosisTask added in v0.1.88 

func (c *KafkaClient) CreateMessageDiagnosisTask(request *model.CreateMessageDiagnosisTaskRequest) (*model.CreateMessageDiagnosisTaskResponse, error)

CreateMessageDiagnosisTask 创建消息积压诊断任务

创建消息积压诊断任务

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) CreateMessageDiagnosisTaskInvoker added in v0.1.88 

func (c *KafkaClient) CreateMessageDiagnosisTaskInvoker(request *model.CreateMessageDiagnosisTaskRequest) *CreateMessageDiagnosisTaskInvoker

CreateMessageDiagnosisTaskInvoker 创建消息积压诊断任务

func (*KafkaClient) CreatePostPaidInstance 

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

CreatePostPaidInstance 创建实例

创建按需计费类型的Kafka实例。

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实例提交分区重平衡任务或计算重平衡预估时间。

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) 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) DeleteConnector added in v0.1.41 

func (c *KafkaClient) DeleteConnector(request *model.DeleteConnectorRequest) (*model.DeleteConnectorResponse, error)

DeleteConnector 关闭Smart Connect（按需实例）

介绍按需实例如何关闭Smart Connect。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) DeleteConnectorInvoker added in v0.1.41 

func (c *KafkaClient) DeleteConnectorInvoker(request *model.DeleteConnectorRequest) *DeleteConnectorInvoker

DeleteConnectorInvoker 关闭Smart Connect（按需实例）

func (*KafkaClient) DeleteConnectorTask added in v0.1.84 

func (c *KafkaClient) DeleteConnectorTask(request *model.DeleteConnectorTaskRequest) (*model.DeleteConnectorTaskResponse, error)

DeleteConnectorTask 删除Smart Connector任务

删除Smart Connector任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) DeleteConnectorTaskInvoker added in v0.1.84 

func (c *KafkaClient) DeleteConnectorTaskInvoker(request *model.DeleteConnectorTaskRequest) *DeleteConnectorTaskInvoker

DeleteConnectorTaskInvoker 删除Smart Connector任务

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) DeleteKafkaUserClientQuotaTask added in v0.1.68 

func (c *KafkaClient) DeleteKafkaUserClientQuotaTask(request *model.DeleteKafkaUserClientQuotaTaskRequest) (*model.DeleteKafkaUserClientQuotaTaskResponse, error)

DeleteKafkaUserClientQuotaTask 删除用户/客户端流控配置

该接口用于向Kafka实例提交删除用户、客户端级别的流控任务，若成功则返回流控任务的job_id。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) DeleteKafkaUserClientQuotaTaskInvoker added in v0.1.68 

func (c *KafkaClient) DeleteKafkaUserClientQuotaTaskInvoker(request *model.DeleteKafkaUserClientQuotaTaskRequest) *DeleteKafkaUserClientQuotaTaskInvoker

DeleteKafkaUserClientQuotaTaskInvoker 删除用户/客户端流控配置

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) ListConnectorTasks added in v0.1.84 

func (c *KafkaClient) ListConnectorTasks(request *model.ListConnectorTasksRequest) (*model.ListConnectorTasksResponse, error)

ListConnectorTasks 查询Smart Connect任务列表

查询Smart Connect任务列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListConnectorTasksInvoker added in v0.1.84 

func (c *KafkaClient) ListConnectorTasksInvoker(request *model.ListConnectorTasksRequest) *ListConnectorTasksInvoker

ListConnectorTasksInvoker 查询Smart Connect任务列表

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) ListMessageDiagnosisReports added in v0.1.88 

func (c *KafkaClient) ListMessageDiagnosisReports(request *model.ListMessageDiagnosisReportsRequest) (*model.ListMessageDiagnosisReportsResponse, error)

ListMessageDiagnosisReports 查询消息积压诊断报告列表

查询消息积压诊断报告列表

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListMessageDiagnosisReportsInvoker added in v0.1.88 

func (c *KafkaClient) ListMessageDiagnosisReportsInvoker(request *model.ListMessageDiagnosisReportsRequest) *ListMessageDiagnosisReportsInvoker

ListMessageDiagnosisReportsInvoker 查询消息积压诊断报告列表

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: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) ListTopicPartitions added in v0.1.49 

func (c *KafkaClient) ListTopicPartitions(request *model.ListTopicPartitionsRequest) (*model.ListTopicPartitionsResponse, error)

ListTopicPartitions 查询Topic的分区列表

查询Topic的分区列表

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListTopicPartitionsInvoker added in v0.1.49 

func (c *KafkaClient) ListTopicPartitionsInvoker(request *model.ListTopicPartitionsRequest) *ListTopicPartitionsInvoker

ListTopicPartitionsInvoker 查询Topic的分区列表

func (*KafkaClient) ListTopicProducers added in v0.1.49 

func (c *KafkaClient) ListTopicProducers(request *model.ListTopicProducersRequest) (*model.ListTopicProducersResponse, error)

ListTopicProducers 查询Topic的当前生产者列表

查询Topic的当前生产者列表

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ListTopicProducersInvoker added in v0.1.49 

func (c *KafkaClient) ListTopicProducersInvoker(request *model.ListTopicProducersRequest) *ListTopicProducersInvoker

ListTopicProducersInvoker 查询Topic的当前生产者列表

func (*KafkaClient) ModifyInstanceConfigs added in v0.1.65 

func (c *KafkaClient) ModifyInstanceConfigs(request *model.ModifyInstanceConfigsRequest) (*model.ModifyInstanceConfigsResponse, error)

ModifyInstanceConfigs 修改实例配置

修改实例配置。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ModifyInstanceConfigsInvoker added in v0.1.65 

func (c *KafkaClient) ModifyInstanceConfigsInvoker(request *model.ModifyInstanceConfigsRequest) *ModifyInstanceConfigsInvoker

ModifyInstanceConfigsInvoker 修改实例配置

func (*KafkaClient) PauseConnectorTask added in v0.1.84 

func (c *KafkaClient) PauseConnectorTask(request *model.PauseConnectorTaskRequest) (*model.PauseConnectorTaskResponse, error)

PauseConnectorTask 暂停Smart Connect任务

暂停Smart Connect任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) PauseConnectorTaskInvoker added in v0.1.84 

func (c *KafkaClient) PauseConnectorTaskInvoker(request *model.PauseConnectorTaskRequest) *PauseConnectorTaskInvoker

PauseConnectorTaskInvoker 暂停Smart Connect任务

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) ResetMessageOffsetWithEngine added in v0.1.76 

func (c *KafkaClient) ResetMessageOffsetWithEngine(request *model.ResetMessageOffsetWithEngineRequest) (*model.ResetMessageOffsetWithEngineResponse, error)

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

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

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

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ResetMessageOffsetWithEngineInvoker added in v0.1.76 

func (c *KafkaClient) ResetMessageOffsetWithEngineInvoker(request *model.ResetMessageOffsetWithEngineRequest) *ResetMessageOffsetWithEngineInvoker

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

func (*KafkaClient) ResetPassword 

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

ResetPassword 重置密码

重置密码（只针对开通SSL的实例）。

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 实例扩容

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

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:hws,hws_hk,ctc,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) RestartConnectorTask added in v0.1.84 

func (c *KafkaClient) RestartConnectorTask(request *model.RestartConnectorTaskRequest) (*model.RestartConnectorTaskResponse, error)

RestartConnectorTask 启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务

用于**启动未启动的Smart Connect任务**以及**重启已暂停或者运行中的Smart Connect任务**。注意，重启Smart Connect任务将重置同步进度，并重新开始同步任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) RestartConnectorTaskInvoker added in v0.1.84 

func (c *KafkaClient) RestartConnectorTaskInvoker(request *model.RestartConnectorTaskRequest) *RestartConnectorTaskInvoker

RestartConnectorTaskInvoker 启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务

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) ResumeConnectorTask added in v0.1.84 

func (c *KafkaClient) ResumeConnectorTask(request *model.ResumeConnectorTaskRequest) (*model.ResumeConnectorTaskResponse, error)

ResumeConnectorTask 启动已暂停的Smart Connect任务

启动已暂停的Smart Connect任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ResumeConnectorTaskInvoker added in v0.1.84 

func (c *KafkaClient) ResumeConnectorTaskInvoker(request *model.ResumeConnectorTaskRequest) *ResumeConnectorTaskInvoker

ResumeConnectorTaskInvoker 启动已暂停的Smart Connect任务

func (*KafkaClient) SendKafkaMessage added in v0.1.73 

func (c *KafkaClient) SendKafkaMessage(request *model.SendKafkaMessageRequest) (*model.SendKafkaMessageResponse, error)

SendKafkaMessage Kafka生产消息

在控制台发送指定消息到Kafka实例

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) SendKafkaMessageInvoker added in v0.1.73 

func (c *KafkaClient) SendKafkaMessageInvoker(request *model.SendKafkaMessageRequest) *SendKafkaMessageInvoker

SendKafkaMessageInvoker Kafka生产消息

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) ShowConnectorTask added in v0.1.84 

func (c *KafkaClient) ShowConnectorTask(request *model.ShowConnectorTaskRequest) (*model.ShowConnectorTaskResponse, error)

ShowConnectorTask 查询Smart Connector任务详情

查询Smart Connector任务详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowConnectorTaskInvoker added in v0.1.84 

func (c *KafkaClient) ShowConnectorTaskInvoker(request *model.ShowConnectorTaskRequest) *ShowConnectorTaskInvoker

ShowConnectorTaskInvoker 查询Smart Connector任务详情

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) ShowDiagnosisPreCheck added in v0.1.88 

func (c *KafkaClient) ShowDiagnosisPreCheck(request *model.ShowDiagnosisPreCheckRequest) (*model.ShowDiagnosisPreCheckResponse, error)

ShowDiagnosisPreCheck 消息积压诊断预检查

消息积压诊断预检查

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowDiagnosisPreCheckInvoker added in v0.1.88 

func (c *KafkaClient) ShowDiagnosisPreCheckInvoker(request *model.ShowDiagnosisPreCheckRequest) *ShowDiagnosisPreCheckInvoker

ShowDiagnosisPreCheckInvoker 消息积压诊断预检查

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) ShowInstanceConfigs added in v0.1.65 

func (c *KafkaClient) ShowInstanceConfigs(request *model.ShowInstanceConfigsRequest) (*model.ShowInstanceConfigsResponse, error)

ShowInstanceConfigs 获取实例配置

获取实例配置。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowInstanceConfigsInvoker added in v0.1.65 

func (c *KafkaClient) ShowInstanceConfigsInvoker(request *model.ShowInstanceConfigsRequest) *ShowInstanceConfigsInvoker

ShowInstanceConfigsInvoker 获取实例配置

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详细信息

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

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详细信息

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) ShowKafkaUserClientQuota added in v0.1.68 

func (c *KafkaClient) ShowKafkaUserClientQuota(request *model.ShowKafkaUserClientQuotaRequest) (*model.ShowKafkaUserClientQuotaResponse, error)

ShowKafkaUserClientQuota 查询用户/客户端流控配置

该接口用于向Kafka实例查询流控的配置，若成功则返回流控配置的列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowKafkaUserClientQuotaInvoker added in v0.1.68 

func (c *KafkaClient) ShowKafkaUserClientQuotaInvoker(request *model.ShowKafkaUserClientQuotaRequest) *ShowKafkaUserClientQuotaInvoker

ShowKafkaUserClientQuotaInvoker 查询用户/客户端流控配置

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) ShowMessageDiagnosisReport added in v0.1.88 

func (c *KafkaClient) ShowMessageDiagnosisReport(request *model.ShowMessageDiagnosisReportRequest) (*model.ShowMessageDiagnosisReportResponse, error)

ShowMessageDiagnosisReport 查询诊断报告详情

查询诊断报告详情

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) ShowMessageDiagnosisReportInvoker added in v0.1.88 

func (c *KafkaClient) ShowMessageDiagnosisReportInvoker(request *model.ShowMessageDiagnosisReportRequest) *ShowMessageDiagnosisReportInvoker

ShowMessageDiagnosisReportInvoker 查询诊断报告详情

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) 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) UpdateInstanceConsumerGroup added in v0.1.59 

func (c *KafkaClient) UpdateInstanceConsumerGroup(request *model.UpdateInstanceConsumerGroupRequest) (*model.UpdateInstanceConsumerGroupResponse, error)

UpdateInstanceConsumerGroup 编辑消费组

编辑消费组

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateInstanceConsumerGroupInvoker added in v0.1.59 

func (c *KafkaClient) UpdateInstanceConsumerGroupInvoker(request *model.UpdateInstanceConsumerGroupRequest) *UpdateInstanceConsumerGroupInvoker

UpdateInstanceConsumerGroupInvoker 编辑消费组

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) UpdateInstanceUser added in v0.1.59 

func (c *KafkaClient) UpdateInstanceUser(request *model.UpdateInstanceUserRequest) (*model.UpdateInstanceUserResponse, error)

UpdateInstanceUser 修改用户参数

修改用户参数

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateInstanceUserInvoker added in v0.1.59 

func (c *KafkaClient) UpdateInstanceUserInvoker(request *model.UpdateInstanceUserRequest) *UpdateInstanceUserInvoker

UpdateInstanceUserInvoker 修改用户参数

func (*KafkaClient) UpdateKafkaUserClientQuotaTask added in v0.1.68 

func (c *KafkaClient) UpdateKafkaUserClientQuotaTask(request *model.UpdateKafkaUserClientQuotaTaskRequest) (*model.UpdateKafkaUserClientQuotaTaskResponse, error)

UpdateKafkaUserClientQuotaTask 修改用户/客户端流控配置

该接口用于向Kafka实例提交修改用户、客户端级别的流控任务，若成功则返回流控任务的job_id。

Please refer to HUAWEI cloud API Explorer for details.

func (*KafkaClient) UpdateKafkaUserClientQuotaTaskInvoker added in v0.1.68 

func (c *KafkaClient) UpdateKafkaUserClientQuotaTaskInvoker(request *model.UpdateKafkaUserClientQuotaTaskRequest) *UpdateKafkaUserClientQuotaTaskInvoker

UpdateKafkaUserClientQuotaTaskInvoker 修改用户/客户端流控配置

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

type ListConnectorTasksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListConnectorTasksInvoker) Invoke added in v0.1.84 

func (i *ListConnectorTasksInvoker) Invoke() (*model.ListConnectorTasksResponse, 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 ListMessageDiagnosisReportsInvoker added in v0.1.88 

type ListMessageDiagnosisReportsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListMessageDiagnosisReportsInvoker) Invoke added in v0.1.88 

func (i *ListMessageDiagnosisReportsInvoker) Invoke() (*model.ListMessageDiagnosisReportsResponse, 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 ListTopicPartitionsInvoker added in v0.1.49 

type ListTopicPartitionsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTopicPartitionsInvoker) Invoke added in v0.1.49 

func (i *ListTopicPartitionsInvoker) Invoke() (*model.ListTopicPartitionsResponse, error)

type ListTopicProducersInvoker added in v0.1.49 

type ListTopicProducersInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTopicProducersInvoker) Invoke added in v0.1.49 

func (i *ListTopicProducersInvoker) Invoke() (*model.ListTopicProducersResponse, error)

type ModifyInstanceConfigsInvoker added in v0.1.65 

type ModifyInstanceConfigsInvoker struct {
	*invoker.BaseInvoker
}

func (*ModifyInstanceConfigsInvoker) Invoke added in v0.1.65 

func (i *ModifyInstanceConfigsInvoker) Invoke() (*model.ModifyInstanceConfigsResponse, error)

type PauseConnectorTaskInvoker added in v0.1.84 

type PauseConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*PauseConnectorTaskInvoker) Invoke added in v0.1.84 

func (i *PauseConnectorTaskInvoker) Invoke() (*model.PauseConnectorTaskResponse, 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 ResetMessageOffsetWithEngineInvoker added in v0.1.76 

type ResetMessageOffsetWithEngineInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetMessageOffsetWithEngineInvoker) Invoke added in v0.1.76 

func (i *ResetMessageOffsetWithEngineInvoker) Invoke() (*model.ResetMessageOffsetWithEngineResponse, 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 RestartConnectorTaskInvoker added in v0.1.84 

type RestartConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*RestartConnectorTaskInvoker) Invoke added in v0.1.84 

func (i *RestartConnectorTaskInvoker) Invoke() (*model.RestartConnectorTaskResponse, 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 ResumeConnectorTaskInvoker added in v0.1.84 

type ResumeConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ResumeConnectorTaskInvoker) Invoke added in v0.1.84 

func (i *ResumeConnectorTaskInvoker) Invoke() (*model.ResumeConnectorTaskResponse, error)

type SendKafkaMessageInvoker added in v0.1.73 

type SendKafkaMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*SendKafkaMessageInvoker) Invoke added in v0.1.73 

func (i *SendKafkaMessageInvoker) Invoke() (*model.SendKafkaMessageResponse, 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 ShowConnectorTaskInvoker added in v0.1.84 

type ShowConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowConnectorTaskInvoker) Invoke added in v0.1.84 

func (i *ShowConnectorTaskInvoker) Invoke() (*model.ShowConnectorTaskResponse, 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 ShowDiagnosisPreCheckInvoker added in v0.1.88 

type ShowDiagnosisPreCheckInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDiagnosisPreCheckInvoker) Invoke added in v0.1.88 

func (i *ShowDiagnosisPreCheckInvoker) Invoke() (*model.ShowDiagnosisPreCheckResponse, 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 ShowInstanceConfigsInvoker added in v0.1.65 

type ShowInstanceConfigsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceConfigsInvoker) Invoke added in v0.1.65 

func (i *ShowInstanceConfigsInvoker) Invoke() (*model.ShowInstanceConfigsResponse, 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 ShowKafkaUserClientQuotaInvoker added in v0.1.68 

type ShowKafkaUserClientQuotaInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaUserClientQuotaInvoker) Invoke added in v0.1.68 

func (i *ShowKafkaUserClientQuotaInvoker) Invoke() (*model.ShowKafkaUserClientQuotaResponse, 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 ShowMessageDiagnosisReportInvoker added in v0.1.88 

type ShowMessageDiagnosisReportInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMessageDiagnosisReportInvoker) Invoke added in v0.1.88 

func (i *ShowMessageDiagnosisReportInvoker) Invoke() (*model.ShowMessageDiagnosisReportResponse, 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 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 UpdateInstanceConsumerGroupInvoker added in v0.1.59 

type UpdateInstanceConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceConsumerGroupInvoker) Invoke added in v0.1.59 

func (i *UpdateInstanceConsumerGroupInvoker) Invoke() (*model.UpdateInstanceConsumerGroupResponse, 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 UpdateInstanceUserInvoker added in v0.1.59 

type UpdateInstanceUserInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceUserInvoker) Invoke added in v0.1.59 

func (i *UpdateInstanceUserInvoker) Invoke() (*model.UpdateInstanceUserResponse, error)

type UpdateKafkaUserClientQuotaTaskInvoker added in v0.1.68 

type UpdateKafkaUserClientQuotaTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateKafkaUserClientQuotaTaskInvoker) Invoke added in v0.1.68 

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