v2

package
v0.1.107 Latest Latest
Warning

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

Go to latest
Published: Jul 25, 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

type BatchDeleteGroupInvoker added in v0.1.36

type BatchDeleteGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteGroupInvoker) Invoke added in v0.1.36

type BatchDeleteInstanceTopicInvoker added in v0.0.90

type BatchDeleteInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteInstanceTopicInvoker) Invoke added in v0.0.90

type BatchDeleteInstanceUsersInvoker added in v0.0.90

type BatchDeleteInstanceUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteInstanceUsersInvoker) Invoke added in v0.0.90

type BatchDeleteMessageDiagnosisReportsInvoker added in v0.1.88

type BatchDeleteMessageDiagnosisReportsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteMessageDiagnosisReportsInvoker) Invoke added in v0.1.88

type BatchRestartOrDeleteInstancesInvoker added in v0.0.90

type BatchRestartOrDeleteInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchRestartOrDeleteInstancesInvoker) Invoke added in v0.0.90

type CloseKafkaManagerInvoker added in v0.1.41

type CloseKafkaManagerInvoker struct {
	*invoker.BaseInvoker
}

func (*CloseKafkaManagerInvoker) Invoke added in v0.1.41

type CreateConnectorInvoker added in v0.0.90

type CreateConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateConnectorInvoker) Invoke added in v0.0.90

type CreateConnectorTaskInvoker added in v0.1.84

type CreateConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateConnectorTaskInvoker) Invoke added in v0.1.84

type CreateInstanceByEngineInvoker added in v0.1.24

type CreateInstanceByEngineInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceByEngineInvoker) Invoke added in v0.1.24

type CreateInstanceTopicInvoker added in v0.0.90

type CreateInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceTopicInvoker) Invoke added in v0.0.90

type CreateInstanceUserInvoker added in v0.0.90

type CreateInstanceUserInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceUserInvoker) Invoke added in v0.0.90

type CreateKafkaConsumerGroupInvoker added in v0.1.41

type CreateKafkaConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateKafkaConsumerGroupInvoker) Invoke added in v0.1.41

type CreateKafkaUserClientQuotaTaskInvoker added in v0.1.68

type CreateKafkaUserClientQuotaTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateKafkaUserClientQuotaTaskInvoker) Invoke added in v0.1.68

type CreateMessageDiagnosisTaskInvoker added in v0.1.88

type CreateMessageDiagnosisTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateMessageDiagnosisTaskInvoker) Invoke added in v0.1.88

type CreatePostPaidInstanceInvoker added in v0.0.90

type CreatePostPaidInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreatePostPaidInstanceInvoker) Invoke added in v0.0.90

type CreateReassignmentTaskInvoker added in v0.1.24

type CreateReassignmentTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateReassignmentTaskInvoker) Invoke added in v0.1.24

type DeleteBackgroundTaskInvoker added in v0.0.90

type DeleteBackgroundTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteBackgroundTaskInvoker) Invoke added in v0.0.90

type DeleteConnectorInvoker added in v0.1.41

type DeleteConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteConnectorInvoker) Invoke added in v0.1.41

type DeleteConnectorTaskInvoker added in v0.1.84

type DeleteConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteConnectorTaskInvoker) Invoke added in v0.1.84

type DeleteInstanceInvoker added in v0.0.90

type DeleteInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteInstanceInvoker) Invoke added in v0.0.90

type DeleteKafkaUserClientQuotaTaskInvoker added in v0.1.68

type DeleteKafkaUserClientQuotaTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteKafkaUserClientQuotaTaskInvoker) Invoke added in v0.1.68

type KafkaClient

type KafkaClient struct {
	HcClient *httpclient.HcHttpClient
}

func NewKafkaClient

func NewKafkaClient(hcClient *httpclient.HcHttpClient) *KafkaClient

func (*KafkaClient) BatchCreateOrDeleteKafkaTag

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type ListBackgroundTasksInvoker added in v0.0.90

type ListBackgroundTasksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListBackgroundTasksInvoker) Invoke added in v0.0.90

type ListConnectorTasksInvoker added in v0.1.84

type ListConnectorTasksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListConnectorTasksInvoker) Invoke added in v0.1.84

type ListEngineProductsInvoker added in v0.0.90

type ListEngineProductsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListEngineProductsInvoker) Invoke added in v0.0.90

type ListInstanceConsumerGroupsInvoker added in v0.1.2

type ListInstanceConsumerGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstanceConsumerGroupsInvoker) Invoke added in v0.1.2

type ListInstanceTopicsInvoker added in v0.0.90

type ListInstanceTopicsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstanceTopicsInvoker) Invoke added in v0.0.90

type ListInstancesInvoker added in v0.0.90

type ListInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstancesInvoker) Invoke added in v0.0.90

type ListMessageDiagnosisReportsInvoker added in v0.1.88

type ListMessageDiagnosisReportsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListMessageDiagnosisReportsInvoker) Invoke added in v0.1.88

type ListProductsInvoker added in v0.0.90

type ListProductsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListProductsInvoker) Invoke added in v0.0.90

type ListTopicPartitionsInvoker added in v0.1.49

type ListTopicPartitionsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTopicPartitionsInvoker) Invoke added in v0.1.49

type ListTopicProducersInvoker added in v0.1.49

type ListTopicProducersInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTopicProducersInvoker) Invoke added in v0.1.49

type ModifyInstanceConfigsInvoker added in v0.1.65

type ModifyInstanceConfigsInvoker struct {
	*invoker.BaseInvoker
}

func (*ModifyInstanceConfigsInvoker) Invoke added in v0.1.65

type PauseConnectorTaskInvoker added in v0.1.84

type PauseConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*PauseConnectorTaskInvoker) Invoke added in v0.1.84

type ResetManagerPasswordInvoker added in v0.0.90

type ResetManagerPasswordInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetManagerPasswordInvoker) Invoke added in v0.0.90

type ResetMessageOffsetInvoker added in v0.0.90

type ResetMessageOffsetInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetMessageOffsetInvoker) Invoke added in v0.0.90

type ResetMessageOffsetWithEngineInvoker added in v0.1.76

type ResetMessageOffsetWithEngineInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetMessageOffsetWithEngineInvoker) Invoke added in v0.1.76

type ResetPasswordInvoker added in v0.0.90

type ResetPasswordInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetPasswordInvoker) Invoke added in v0.0.90

type ResetUserPasswrodInvoker added in v0.0.90

type ResetUserPasswrodInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetUserPasswrodInvoker) Invoke added in v0.0.90

type ResizeEngineInstanceInvoker added in v0.1.24

type ResizeEngineInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ResizeEngineInstanceInvoker) Invoke added in v0.1.24

type ResizeInstanceInvoker added in v0.0.90

type ResizeInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ResizeInstanceInvoker) Invoke added in v0.0.90

type RestartConnectorTaskInvoker added in v0.1.84

type RestartConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*RestartConnectorTaskInvoker) Invoke added in v0.1.84

type RestartManagerInvoker added in v0.0.90

type RestartManagerInvoker struct {
	*invoker.BaseInvoker
}

func (*RestartManagerInvoker) Invoke added in v0.0.90

type ResumeConnectorTaskInvoker added in v0.1.84

type ResumeConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ResumeConnectorTaskInvoker) Invoke added in v0.1.84

type SendKafkaMessageInvoker added in v0.1.73

type SendKafkaMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*SendKafkaMessageInvoker) Invoke added in v0.1.73

type ShowBackgroundTaskInvoker added in v0.0.90

type ShowBackgroundTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowBackgroundTaskInvoker) Invoke added in v0.0.90

type ShowCesHierarchyInvoker added in v0.0.90

type ShowCesHierarchyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowCesHierarchyInvoker) Invoke added in v0.0.90

type ShowClusterInvoker added in v0.0.90

type ShowClusterInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowClusterInvoker) Invoke added in v0.0.90

type ShowConnectorTaskInvoker added in v0.1.84

type ShowConnectorTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowConnectorTaskInvoker) Invoke added in v0.1.84

type ShowCoordinatorsInvoker added in v0.0.90

type ShowCoordinatorsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowCoordinatorsInvoker) Invoke added in v0.0.90

type ShowDiagnosisPreCheckInvoker added in v0.1.88

type ShowDiagnosisPreCheckInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDiagnosisPreCheckInvoker) Invoke added in v0.1.88

type ShowEngineInstanceExtendProductInfoInvoker added in v0.1.24

type ShowEngineInstanceExtendProductInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowEngineInstanceExtendProductInfoInvoker) Invoke added in v0.1.24

type ShowGroupsInvoker added in v0.0.90

type ShowGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowGroupsInvoker) Invoke added in v0.0.90

type ShowInstanceConfigsInvoker added in v0.1.65

type ShowInstanceConfigsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceConfigsInvoker) Invoke added in v0.1.65

type ShowInstanceExtendProductInfoInvoker added in v0.0.90

type ShowInstanceExtendProductInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceExtendProductInfoInvoker) Invoke added in v0.0.90

type ShowInstanceInvoker added in v0.0.90

type ShowInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceInvoker) Invoke added in v0.0.90

type ShowInstanceMessagesInvoker added in v0.0.90

type ShowInstanceMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceMessagesInvoker) Invoke added in v0.0.90

type ShowInstanceTopicDetailInvoker added in v0.0.90

type ShowInstanceTopicDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceTopicDetailInvoker) Invoke added in v0.0.90

type ShowInstanceUsersInvoker added in v0.0.90

type ShowInstanceUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceUsersInvoker) Invoke added in v0.0.90

type ShowKafkaProjectTagsInvoker added in v0.0.90

type ShowKafkaProjectTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaProjectTagsInvoker) Invoke added in v0.0.90

type ShowKafkaTagsInvoker added in v0.0.90

type ShowKafkaTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaTagsInvoker) Invoke added in v0.0.90

type ShowKafkaTopicPartitionDiskusageInvoker added in v0.0.90

type ShowKafkaTopicPartitionDiskusageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaTopicPartitionDiskusageInvoker) Invoke added in v0.0.90

type ShowKafkaUserClientQuotaInvoker added in v0.1.68

type ShowKafkaUserClientQuotaInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaUserClientQuotaInvoker) Invoke added in v0.1.68

type ShowMaintainWindowsInvoker added in v0.0.90

type ShowMaintainWindowsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMaintainWindowsInvoker) Invoke added in v0.0.90

type ShowMessageDiagnosisReportInvoker added in v0.1.88

type ShowMessageDiagnosisReportInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMessageDiagnosisReportInvoker) Invoke added in v0.1.88

type ShowMessagesInvoker added in v0.0.90

type ShowMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMessagesInvoker) Invoke added in v0.0.90

type ShowPartitionBeginningMessageInvoker added in v0.0.90

type ShowPartitionBeginningMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionBeginningMessageInvoker) Invoke added in v0.0.90

type ShowPartitionEndMessageInvoker added in v0.0.90

type ShowPartitionEndMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionEndMessageInvoker) Invoke added in v0.0.90

type ShowPartitionMessageInvoker added in v0.0.90

type ShowPartitionMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionMessageInvoker) Invoke added in v0.0.90

type ShowTopicAccessPolicyInvoker added in v0.0.90

type ShowTopicAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTopicAccessPolicyInvoker) Invoke added in v0.0.90

type UpdateInstanceAutoCreateTopicInvoker added in v0.0.90

type UpdateInstanceAutoCreateTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceAutoCreateTopicInvoker) Invoke added in v0.0.90

type UpdateInstanceConsumerGroupInvoker added in v0.1.59

type UpdateInstanceConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceConsumerGroupInvoker) Invoke added in v0.1.59

type UpdateInstanceCrossVpcIpInvoker added in v0.0.90

type UpdateInstanceCrossVpcIpInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceCrossVpcIpInvoker) Invoke added in v0.0.90

type UpdateInstanceInvoker added in v0.0.90

type UpdateInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceInvoker) Invoke added in v0.0.90

type UpdateInstanceTopicInvoker added in v0.0.90

type UpdateInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceTopicInvoker) Invoke added in v0.0.90

type UpdateInstanceUserInvoker added in v0.1.59

type UpdateInstanceUserInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceUserInvoker) Invoke added in v0.1.59

type UpdateKafkaUserClientQuotaTaskInvoker added in v0.1.68

type UpdateKafkaUserClientQuotaTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateKafkaUserClientQuotaTaskInvoker) Invoke added in v0.1.68

type UpdateTopicAccessPolicyInvoker added in v0.0.90

type UpdateTopicAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTopicAccessPolicyInvoker) Invoke added in v0.0.90

type UpdateTopicReplicaInvoker added in v0.0.90

type UpdateTopicReplicaInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTopicReplicaInvoker) Invoke added in v0.0.90

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL