Documentation ¶
Index ¶
- func GenReqDefForBatchCreateOrDeleteKafkaTag() *def.HttpRequestDef
- func GenReqDefForBatchDeleteGroup() *def.HttpRequestDef
- func GenReqDefForBatchDeleteInstanceTopic() *def.HttpRequestDef
- func GenReqDefForBatchDeleteInstanceUsers() *def.HttpRequestDef
- func GenReqDefForBatchDeleteMessageDiagnosisReports() *def.HttpRequestDef
- func GenReqDefForBatchRestartOrDeleteInstances() *def.HttpRequestDef
- func GenReqDefForCloseKafkaManager() *def.HttpRequestDef
- func GenReqDefForCreateConnector() *def.HttpRequestDef
- func GenReqDefForCreateConnectorTask() *def.HttpRequestDef
- func GenReqDefForCreateInstanceByEngine() *def.HttpRequestDef
- func GenReqDefForCreateInstanceTopic() *def.HttpRequestDef
- func GenReqDefForCreateInstanceUser() *def.HttpRequestDef
- func GenReqDefForCreateKafkaConsumerGroup() *def.HttpRequestDef
- func GenReqDefForCreateKafkaUserClientQuotaTask() *def.HttpRequestDef
- func GenReqDefForCreateMessageDiagnosisTask() *def.HttpRequestDef
- func GenReqDefForCreatePostPaidInstance() *def.HttpRequestDef
- func GenReqDefForCreateReassignmentTask() *def.HttpRequestDef
- func GenReqDefForDeleteBackgroundTask() *def.HttpRequestDef
- func GenReqDefForDeleteConnector() *def.HttpRequestDef
- func GenReqDefForDeleteConnectorTask() *def.HttpRequestDef
- func GenReqDefForDeleteInstance() *def.HttpRequestDef
- func GenReqDefForDeleteKafkaUserClientQuotaTask() *def.HttpRequestDef
- func GenReqDefForListAvailableZones() *def.HttpRequestDef
- func GenReqDefForListBackgroundTasks() *def.HttpRequestDef
- func GenReqDefForListConnectorTasks() *def.HttpRequestDef
- func GenReqDefForListEngineProducts() *def.HttpRequestDef
- func GenReqDefForListInstanceConsumerGroups() *def.HttpRequestDef
- func GenReqDefForListInstanceTopics() *def.HttpRequestDef
- func GenReqDefForListInstances() *def.HttpRequestDef
- func GenReqDefForListMessageDiagnosisReports() *def.HttpRequestDef
- func GenReqDefForListProducts() *def.HttpRequestDef
- func GenReqDefForListTopicPartitions() *def.HttpRequestDef
- func GenReqDefForListTopicProducers() *def.HttpRequestDef
- func GenReqDefForModifyInstanceConfigs() *def.HttpRequestDef
- func GenReqDefForPauseConnectorTask() *def.HttpRequestDef
- func GenReqDefForResetManagerPassword() *def.HttpRequestDef
- func GenReqDefForResetMessageOffset() *def.HttpRequestDef
- func GenReqDefForResetMessageOffsetWithEngine() *def.HttpRequestDef
- func GenReqDefForResetPassword() *def.HttpRequestDef
- func GenReqDefForResetUserPasswrod() *def.HttpRequestDef
- func GenReqDefForResizeEngineInstance() *def.HttpRequestDef
- func GenReqDefForResizeInstance() *def.HttpRequestDef
- func GenReqDefForRestartConnectorTask() *def.HttpRequestDef
- func GenReqDefForRestartManager() *def.HttpRequestDef
- func GenReqDefForResumeConnectorTask() *def.HttpRequestDef
- func GenReqDefForSendKafkaMessage() *def.HttpRequestDef
- func GenReqDefForShowBackgroundTask() *def.HttpRequestDef
- func GenReqDefForShowCesHierarchy() *def.HttpRequestDef
- func GenReqDefForShowCluster() *def.HttpRequestDef
- func GenReqDefForShowConnectorTask() *def.HttpRequestDef
- func GenReqDefForShowCoordinators() *def.HttpRequestDef
- func GenReqDefForShowDiagnosisPreCheck() *def.HttpRequestDef
- func GenReqDefForShowEngineInstanceExtendProductInfo() *def.HttpRequestDef
- func GenReqDefForShowGroups() *def.HttpRequestDef
- func GenReqDefForShowInstance() *def.HttpRequestDef
- func GenReqDefForShowInstanceConfigs() *def.HttpRequestDef
- func GenReqDefForShowInstanceExtendProductInfo() *def.HttpRequestDef
- func GenReqDefForShowInstanceMessages() *def.HttpRequestDef
- func GenReqDefForShowInstanceTopicDetail() *def.HttpRequestDef
- func GenReqDefForShowInstanceUsers() *def.HttpRequestDef
- func GenReqDefForShowKafkaProjectTags() *def.HttpRequestDef
- func GenReqDefForShowKafkaTags() *def.HttpRequestDef
- func GenReqDefForShowKafkaTopicPartitionDiskusage() *def.HttpRequestDef
- func GenReqDefForShowKafkaUserClientQuota() *def.HttpRequestDef
- func GenReqDefForShowMaintainWindows() *def.HttpRequestDef
- func GenReqDefForShowMessageDiagnosisReport() *def.HttpRequestDef
- func GenReqDefForShowMessages() *def.HttpRequestDef
- func GenReqDefForShowPartitionBeginningMessage() *def.HttpRequestDef
- func GenReqDefForShowPartitionEndMessage() *def.HttpRequestDef
- func GenReqDefForShowPartitionMessage() *def.HttpRequestDef
- func GenReqDefForShowTopicAccessPolicy() *def.HttpRequestDef
- func GenReqDefForUpdateInstance() *def.HttpRequestDef
- func GenReqDefForUpdateInstanceAutoCreateTopic() *def.HttpRequestDef
- func GenReqDefForUpdateInstanceConsumerGroup() *def.HttpRequestDef
- func GenReqDefForUpdateInstanceCrossVpcIp() *def.HttpRequestDef
- func GenReqDefForUpdateInstanceTopic() *def.HttpRequestDef
- func GenReqDefForUpdateInstanceUser() *def.HttpRequestDef
- func GenReqDefForUpdateKafkaUserClientQuotaTask() *def.HttpRequestDef
- func GenReqDefForUpdateTopicAccessPolicy() *def.HttpRequestDef
- func GenReqDefForUpdateTopicReplica() *def.HttpRequestDef
- func KafkaClientBuilder() *httpclient.HcHttpClientBuilder
- type BatchCreateOrDeleteKafkaTagInvoker
- type BatchDeleteGroupInvoker
- type BatchDeleteInstanceTopicInvoker
- type BatchDeleteInstanceUsersInvoker
- type BatchDeleteMessageDiagnosisReportsInvoker
- type BatchRestartOrDeleteInstancesInvoker
- type CloseKafkaManagerInvoker
- type CreateConnectorInvoker
- type CreateConnectorTaskInvoker
- type CreateInstanceByEngineInvoker
- type CreateInstanceTopicInvoker
- type CreateInstanceUserInvoker
- type CreateKafkaConsumerGroupInvoker
- type CreateKafkaUserClientQuotaTaskInvoker
- type CreateMessageDiagnosisTaskInvoker
- type CreatePostPaidInstanceInvoker
- type CreateReassignmentTaskInvoker
- type DeleteBackgroundTaskInvoker
- type DeleteConnectorInvoker
- type DeleteConnectorTaskInvoker
- type DeleteInstanceInvoker
- type DeleteKafkaUserClientQuotaTaskInvoker
- type KafkaClient
- func (c *KafkaClient) BatchCreateOrDeleteKafkaTag(request *model.BatchCreateOrDeleteKafkaTagRequest) (*model.BatchCreateOrDeleteKafkaTagResponse, error)
- func (c *KafkaClient) BatchCreateOrDeleteKafkaTagInvoker(request *model.BatchCreateOrDeleteKafkaTagRequest) *BatchCreateOrDeleteKafkaTagInvoker
- func (c *KafkaClient) BatchDeleteGroup(request *model.BatchDeleteGroupRequest) (*model.BatchDeleteGroupResponse, error)
- func (c *KafkaClient) BatchDeleteGroupInvoker(request *model.BatchDeleteGroupRequest) *BatchDeleteGroupInvoker
- func (c *KafkaClient) BatchDeleteInstanceTopic(request *model.BatchDeleteInstanceTopicRequest) (*model.BatchDeleteInstanceTopicResponse, error)
- func (c *KafkaClient) BatchDeleteInstanceTopicInvoker(request *model.BatchDeleteInstanceTopicRequest) *BatchDeleteInstanceTopicInvoker
- func (c *KafkaClient) BatchDeleteInstanceUsers(request *model.BatchDeleteInstanceUsersRequest) (*model.BatchDeleteInstanceUsersResponse, error)
- func (c *KafkaClient) BatchDeleteInstanceUsersInvoker(request *model.BatchDeleteInstanceUsersRequest) *BatchDeleteInstanceUsersInvoker
- func (c *KafkaClient) BatchDeleteMessageDiagnosisReports(request *model.BatchDeleteMessageDiagnosisReportsRequest) (*model.BatchDeleteMessageDiagnosisReportsResponse, error)
- func (c *KafkaClient) BatchDeleteMessageDiagnosisReportsInvoker(request *model.BatchDeleteMessageDiagnosisReportsRequest) *BatchDeleteMessageDiagnosisReportsInvoker
- func (c *KafkaClient) BatchRestartOrDeleteInstances(request *model.BatchRestartOrDeleteInstancesRequest) (*model.BatchRestartOrDeleteInstancesResponse, error)
- func (c *KafkaClient) BatchRestartOrDeleteInstancesInvoker(request *model.BatchRestartOrDeleteInstancesRequest) *BatchRestartOrDeleteInstancesInvoker
- func (c *KafkaClient) CloseKafkaManager(request *model.CloseKafkaManagerRequest) (*model.CloseKafkaManagerResponse, error)
- func (c *KafkaClient) CloseKafkaManagerInvoker(request *model.CloseKafkaManagerRequest) *CloseKafkaManagerInvoker
- func (c *KafkaClient) CreateConnector(request *model.CreateConnectorRequest) (*model.CreateConnectorResponse, error)
- func (c *KafkaClient) CreateConnectorInvoker(request *model.CreateConnectorRequest) *CreateConnectorInvoker
- func (c *KafkaClient) CreateConnectorTask(request *model.CreateConnectorTaskRequest) (*model.CreateConnectorTaskResponse, error)
- func (c *KafkaClient) CreateConnectorTaskInvoker(request *model.CreateConnectorTaskRequest) *CreateConnectorTaskInvoker
- func (c *KafkaClient) CreateInstanceByEngine(request *model.CreateInstanceByEngineRequest) (*model.CreateInstanceByEngineResponse, error)
- func (c *KafkaClient) CreateInstanceByEngineInvoker(request *model.CreateInstanceByEngineRequest) *CreateInstanceByEngineInvoker
- func (c *KafkaClient) CreateInstanceTopic(request *model.CreateInstanceTopicRequest) (*model.CreateInstanceTopicResponse, error)
- func (c *KafkaClient) CreateInstanceTopicInvoker(request *model.CreateInstanceTopicRequest) *CreateInstanceTopicInvoker
- func (c *KafkaClient) CreateInstanceUser(request *model.CreateInstanceUserRequest) (*model.CreateInstanceUserResponse, error)
- func (c *KafkaClient) CreateInstanceUserInvoker(request *model.CreateInstanceUserRequest) *CreateInstanceUserInvoker
- func (c *KafkaClient) CreateKafkaConsumerGroup(request *model.CreateKafkaConsumerGroupRequest) (*model.CreateKafkaConsumerGroupResponse, error)
- func (c *KafkaClient) CreateKafkaConsumerGroupInvoker(request *model.CreateKafkaConsumerGroupRequest) *CreateKafkaConsumerGroupInvoker
- func (c *KafkaClient) CreateKafkaUserClientQuotaTask(request *model.CreateKafkaUserClientQuotaTaskRequest) (*model.CreateKafkaUserClientQuotaTaskResponse, error)
- func (c *KafkaClient) CreateKafkaUserClientQuotaTaskInvoker(request *model.CreateKafkaUserClientQuotaTaskRequest) *CreateKafkaUserClientQuotaTaskInvoker
- func (c *KafkaClient) CreateMessageDiagnosisTask(request *model.CreateMessageDiagnosisTaskRequest) (*model.CreateMessageDiagnosisTaskResponse, error)
- func (c *KafkaClient) CreateMessageDiagnosisTaskInvoker(request *model.CreateMessageDiagnosisTaskRequest) *CreateMessageDiagnosisTaskInvoker
- func (c *KafkaClient) CreatePostPaidInstance(request *model.CreatePostPaidInstanceRequest) (*model.CreatePostPaidInstanceResponse, error)
- func (c *KafkaClient) CreatePostPaidInstanceInvoker(request *model.CreatePostPaidInstanceRequest) *CreatePostPaidInstanceInvoker
- func (c *KafkaClient) CreateReassignmentTask(request *model.CreateReassignmentTaskRequest) (*model.CreateReassignmentTaskResponse, error)
- func (c *KafkaClient) CreateReassignmentTaskInvoker(request *model.CreateReassignmentTaskRequest) *CreateReassignmentTaskInvoker
- func (c *KafkaClient) DeleteBackgroundTask(request *model.DeleteBackgroundTaskRequest) (*model.DeleteBackgroundTaskResponse, error)
- func (c *KafkaClient) DeleteBackgroundTaskInvoker(request *model.DeleteBackgroundTaskRequest) *DeleteBackgroundTaskInvoker
- func (c *KafkaClient) DeleteConnector(request *model.DeleteConnectorRequest) (*model.DeleteConnectorResponse, error)
- func (c *KafkaClient) DeleteConnectorInvoker(request *model.DeleteConnectorRequest) *DeleteConnectorInvoker
- func (c *KafkaClient) DeleteConnectorTask(request *model.DeleteConnectorTaskRequest) (*model.DeleteConnectorTaskResponse, error)
- func (c *KafkaClient) DeleteConnectorTaskInvoker(request *model.DeleteConnectorTaskRequest) *DeleteConnectorTaskInvoker
- func (c *KafkaClient) DeleteInstance(request *model.DeleteInstanceRequest) (*model.DeleteInstanceResponse, error)
- func (c *KafkaClient) DeleteInstanceInvoker(request *model.DeleteInstanceRequest) *DeleteInstanceInvoker
- func (c *KafkaClient) DeleteKafkaUserClientQuotaTask(request *model.DeleteKafkaUserClientQuotaTaskRequest) (*model.DeleteKafkaUserClientQuotaTaskResponse, error)
- func (c *KafkaClient) DeleteKafkaUserClientQuotaTaskInvoker(request *model.DeleteKafkaUserClientQuotaTaskRequest) *DeleteKafkaUserClientQuotaTaskInvoker
- func (c *KafkaClient) ListAvailableZones(request *model.ListAvailableZonesRequest) (*model.ListAvailableZonesResponse, error)
- func (c *KafkaClient) ListAvailableZonesInvoker(request *model.ListAvailableZonesRequest) *ListAvailableZonesInvoker
- func (c *KafkaClient) ListBackgroundTasks(request *model.ListBackgroundTasksRequest) (*model.ListBackgroundTasksResponse, error)
- func (c *KafkaClient) ListBackgroundTasksInvoker(request *model.ListBackgroundTasksRequest) *ListBackgroundTasksInvoker
- func (c *KafkaClient) ListConnectorTasks(request *model.ListConnectorTasksRequest) (*model.ListConnectorTasksResponse, error)
- func (c *KafkaClient) ListConnectorTasksInvoker(request *model.ListConnectorTasksRequest) *ListConnectorTasksInvoker
- func (c *KafkaClient) ListEngineProducts(request *model.ListEngineProductsRequest) (*model.ListEngineProductsResponse, error)
- func (c *KafkaClient) ListEngineProductsInvoker(request *model.ListEngineProductsRequest) *ListEngineProductsInvoker
- func (c *KafkaClient) ListInstanceConsumerGroups(request *model.ListInstanceConsumerGroupsRequest) (*model.ListInstanceConsumerGroupsResponse, error)
- func (c *KafkaClient) ListInstanceConsumerGroupsInvoker(request *model.ListInstanceConsumerGroupsRequest) *ListInstanceConsumerGroupsInvoker
- func (c *KafkaClient) ListInstanceTopics(request *model.ListInstanceTopicsRequest) (*model.ListInstanceTopicsResponse, error)
- func (c *KafkaClient) ListInstanceTopicsInvoker(request *model.ListInstanceTopicsRequest) *ListInstanceTopicsInvoker
- func (c *KafkaClient) ListInstances(request *model.ListInstancesRequest) (*model.ListInstancesResponse, error)
- func (c *KafkaClient) ListInstancesInvoker(request *model.ListInstancesRequest) *ListInstancesInvoker
- func (c *KafkaClient) ListMessageDiagnosisReports(request *model.ListMessageDiagnosisReportsRequest) (*model.ListMessageDiagnosisReportsResponse, error)
- func (c *KafkaClient) ListMessageDiagnosisReportsInvoker(request *model.ListMessageDiagnosisReportsRequest) *ListMessageDiagnosisReportsInvoker
- func (c *KafkaClient) ListProducts(request *model.ListProductsRequest) (*model.ListProductsResponse, error)
- func (c *KafkaClient) ListProductsInvoker(request *model.ListProductsRequest) *ListProductsInvoker
- func (c *KafkaClient) ListTopicPartitions(request *model.ListTopicPartitionsRequest) (*model.ListTopicPartitionsResponse, error)
- func (c *KafkaClient) ListTopicPartitionsInvoker(request *model.ListTopicPartitionsRequest) *ListTopicPartitionsInvoker
- func (c *KafkaClient) ListTopicProducers(request *model.ListTopicProducersRequest) (*model.ListTopicProducersResponse, error)
- func (c *KafkaClient) ListTopicProducersInvoker(request *model.ListTopicProducersRequest) *ListTopicProducersInvoker
- func (c *KafkaClient) ModifyInstanceConfigs(request *model.ModifyInstanceConfigsRequest) (*model.ModifyInstanceConfigsResponse, error)
- func (c *KafkaClient) ModifyInstanceConfigsInvoker(request *model.ModifyInstanceConfigsRequest) *ModifyInstanceConfigsInvoker
- func (c *KafkaClient) PauseConnectorTask(request *model.PauseConnectorTaskRequest) (*model.PauseConnectorTaskResponse, error)
- func (c *KafkaClient) PauseConnectorTaskInvoker(request *model.PauseConnectorTaskRequest) *PauseConnectorTaskInvoker
- func (c *KafkaClient) ResetManagerPassword(request *model.ResetManagerPasswordRequest) (*model.ResetManagerPasswordResponse, error)
- func (c *KafkaClient) ResetManagerPasswordInvoker(request *model.ResetManagerPasswordRequest) *ResetManagerPasswordInvoker
- func (c *KafkaClient) ResetMessageOffset(request *model.ResetMessageOffsetRequest) (*model.ResetMessageOffsetResponse, error)
- func (c *KafkaClient) ResetMessageOffsetInvoker(request *model.ResetMessageOffsetRequest) *ResetMessageOffsetInvoker
- func (c *KafkaClient) ResetMessageOffsetWithEngine(request *model.ResetMessageOffsetWithEngineRequest) (*model.ResetMessageOffsetWithEngineResponse, error)
- func (c *KafkaClient) ResetMessageOffsetWithEngineInvoker(request *model.ResetMessageOffsetWithEngineRequest) *ResetMessageOffsetWithEngineInvoker
- func (c *KafkaClient) ResetPassword(request *model.ResetPasswordRequest) (*model.ResetPasswordResponse, error)
- func (c *KafkaClient) ResetPasswordInvoker(request *model.ResetPasswordRequest) *ResetPasswordInvoker
- func (c *KafkaClient) ResetUserPasswrod(request *model.ResetUserPasswrodRequest) (*model.ResetUserPasswrodResponse, error)
- func (c *KafkaClient) ResetUserPasswrodInvoker(request *model.ResetUserPasswrodRequest) *ResetUserPasswrodInvoker
- func (c *KafkaClient) ResizeEngineInstance(request *model.ResizeEngineInstanceRequest) (*model.ResizeEngineInstanceResponse, error)
- func (c *KafkaClient) ResizeEngineInstanceInvoker(request *model.ResizeEngineInstanceRequest) *ResizeEngineInstanceInvoker
- func (c *KafkaClient) ResizeInstance(request *model.ResizeInstanceRequest) (*model.ResizeInstanceResponse, error)
- func (c *KafkaClient) ResizeInstanceInvoker(request *model.ResizeInstanceRequest) *ResizeInstanceInvoker
- func (c *KafkaClient) RestartConnectorTask(request *model.RestartConnectorTaskRequest) (*model.RestartConnectorTaskResponse, error)
- func (c *KafkaClient) RestartConnectorTaskInvoker(request *model.RestartConnectorTaskRequest) *RestartConnectorTaskInvoker
- func (c *KafkaClient) RestartManager(request *model.RestartManagerRequest) (*model.RestartManagerResponse, error)
- func (c *KafkaClient) RestartManagerInvoker(request *model.RestartManagerRequest) *RestartManagerInvoker
- func (c *KafkaClient) ResumeConnectorTask(request *model.ResumeConnectorTaskRequest) (*model.ResumeConnectorTaskResponse, error)
- func (c *KafkaClient) ResumeConnectorTaskInvoker(request *model.ResumeConnectorTaskRequest) *ResumeConnectorTaskInvoker
- func (c *KafkaClient) SendKafkaMessage(request *model.SendKafkaMessageRequest) (*model.SendKafkaMessageResponse, error)
- func (c *KafkaClient) SendKafkaMessageInvoker(request *model.SendKafkaMessageRequest) *SendKafkaMessageInvoker
- func (c *KafkaClient) ShowBackgroundTask(request *model.ShowBackgroundTaskRequest) (*model.ShowBackgroundTaskResponse, error)
- func (c *KafkaClient) ShowBackgroundTaskInvoker(request *model.ShowBackgroundTaskRequest) *ShowBackgroundTaskInvoker
- func (c *KafkaClient) ShowCesHierarchy(request *model.ShowCesHierarchyRequest) (*model.ShowCesHierarchyResponse, error)
- func (c *KafkaClient) ShowCesHierarchyInvoker(request *model.ShowCesHierarchyRequest) *ShowCesHierarchyInvoker
- func (c *KafkaClient) ShowCluster(request *model.ShowClusterRequest) (*model.ShowClusterResponse, error)
- func (c *KafkaClient) ShowClusterInvoker(request *model.ShowClusterRequest) *ShowClusterInvoker
- func (c *KafkaClient) ShowConnectorTask(request *model.ShowConnectorTaskRequest) (*model.ShowConnectorTaskResponse, error)
- func (c *KafkaClient) ShowConnectorTaskInvoker(request *model.ShowConnectorTaskRequest) *ShowConnectorTaskInvoker
- func (c *KafkaClient) ShowCoordinators(request *model.ShowCoordinatorsRequest) (*model.ShowCoordinatorsResponse, error)
- func (c *KafkaClient) ShowCoordinatorsInvoker(request *model.ShowCoordinatorsRequest) *ShowCoordinatorsInvoker
- func (c *KafkaClient) ShowDiagnosisPreCheck(request *model.ShowDiagnosisPreCheckRequest) (*model.ShowDiagnosisPreCheckResponse, error)
- func (c *KafkaClient) ShowDiagnosisPreCheckInvoker(request *model.ShowDiagnosisPreCheckRequest) *ShowDiagnosisPreCheckInvoker
- func (c *KafkaClient) ShowEngineInstanceExtendProductInfo(request *model.ShowEngineInstanceExtendProductInfoRequest) (*model.ShowEngineInstanceExtendProductInfoResponse, error)
- func (c *KafkaClient) ShowEngineInstanceExtendProductInfoInvoker(request *model.ShowEngineInstanceExtendProductInfoRequest) *ShowEngineInstanceExtendProductInfoInvoker
- func (c *KafkaClient) ShowGroups(request *model.ShowGroupsRequest) (*model.ShowGroupsResponse, error)
- func (c *KafkaClient) ShowGroupsInvoker(request *model.ShowGroupsRequest) *ShowGroupsInvoker
- func (c *KafkaClient) ShowInstance(request *model.ShowInstanceRequest) (*model.ShowInstanceResponse, error)
- func (c *KafkaClient) ShowInstanceConfigs(request *model.ShowInstanceConfigsRequest) (*model.ShowInstanceConfigsResponse, error)
- func (c *KafkaClient) ShowInstanceConfigsInvoker(request *model.ShowInstanceConfigsRequest) *ShowInstanceConfigsInvoker
- func (c *KafkaClient) ShowInstanceExtendProductInfo(request *model.ShowInstanceExtendProductInfoRequest) (*model.ShowInstanceExtendProductInfoResponse, error)
- func (c *KafkaClient) ShowInstanceExtendProductInfoInvoker(request *model.ShowInstanceExtendProductInfoRequest) *ShowInstanceExtendProductInfoInvoker
- func (c *KafkaClient) ShowInstanceInvoker(request *model.ShowInstanceRequest) *ShowInstanceInvoker
- func (c *KafkaClient) ShowInstanceMessages(request *model.ShowInstanceMessagesRequest) (*model.ShowInstanceMessagesResponse, error)
- func (c *KafkaClient) ShowInstanceMessagesInvoker(request *model.ShowInstanceMessagesRequest) *ShowInstanceMessagesInvoker
- func (c *KafkaClient) ShowInstanceTopicDetail(request *model.ShowInstanceTopicDetailRequest) (*model.ShowInstanceTopicDetailResponse, error)
- func (c *KafkaClient) ShowInstanceTopicDetailInvoker(request *model.ShowInstanceTopicDetailRequest) *ShowInstanceTopicDetailInvoker
- func (c *KafkaClient) ShowInstanceUsers(request *model.ShowInstanceUsersRequest) (*model.ShowInstanceUsersResponse, error)
- func (c *KafkaClient) ShowInstanceUsersInvoker(request *model.ShowInstanceUsersRequest) *ShowInstanceUsersInvoker
- func (c *KafkaClient) ShowKafkaProjectTags(request *model.ShowKafkaProjectTagsRequest) (*model.ShowKafkaProjectTagsResponse, error)
- func (c *KafkaClient) ShowKafkaProjectTagsInvoker(request *model.ShowKafkaProjectTagsRequest) *ShowKafkaProjectTagsInvoker
- func (c *KafkaClient) ShowKafkaTags(request *model.ShowKafkaTagsRequest) (*model.ShowKafkaTagsResponse, error)
- func (c *KafkaClient) ShowKafkaTagsInvoker(request *model.ShowKafkaTagsRequest) *ShowKafkaTagsInvoker
- func (c *KafkaClient) ShowKafkaTopicPartitionDiskusage(request *model.ShowKafkaTopicPartitionDiskusageRequest) (*model.ShowKafkaTopicPartitionDiskusageResponse, error)
- func (c *KafkaClient) ShowKafkaTopicPartitionDiskusageInvoker(request *model.ShowKafkaTopicPartitionDiskusageRequest) *ShowKafkaTopicPartitionDiskusageInvoker
- func (c *KafkaClient) ShowKafkaUserClientQuota(request *model.ShowKafkaUserClientQuotaRequest) (*model.ShowKafkaUserClientQuotaResponse, error)
- func (c *KafkaClient) ShowKafkaUserClientQuotaInvoker(request *model.ShowKafkaUserClientQuotaRequest) *ShowKafkaUserClientQuotaInvoker
- func (c *KafkaClient) ShowMaintainWindows(request *model.ShowMaintainWindowsRequest) (*model.ShowMaintainWindowsResponse, error)
- func (c *KafkaClient) ShowMaintainWindowsInvoker(request *model.ShowMaintainWindowsRequest) *ShowMaintainWindowsInvoker
- func (c *KafkaClient) ShowMessageDiagnosisReport(request *model.ShowMessageDiagnosisReportRequest) (*model.ShowMessageDiagnosisReportResponse, error)
- func (c *KafkaClient) ShowMessageDiagnosisReportInvoker(request *model.ShowMessageDiagnosisReportRequest) *ShowMessageDiagnosisReportInvoker
- func (c *KafkaClient) ShowMessages(request *model.ShowMessagesRequest) (*model.ShowMessagesResponse, error)
- func (c *KafkaClient) ShowMessagesInvoker(request *model.ShowMessagesRequest) *ShowMessagesInvoker
- func (c *KafkaClient) ShowPartitionBeginningMessage(request *model.ShowPartitionBeginningMessageRequest) (*model.ShowPartitionBeginningMessageResponse, error)
- func (c *KafkaClient) ShowPartitionBeginningMessageInvoker(request *model.ShowPartitionBeginningMessageRequest) *ShowPartitionBeginningMessageInvoker
- func (c *KafkaClient) ShowPartitionEndMessage(request *model.ShowPartitionEndMessageRequest) (*model.ShowPartitionEndMessageResponse, error)
- func (c *KafkaClient) ShowPartitionEndMessageInvoker(request *model.ShowPartitionEndMessageRequest) *ShowPartitionEndMessageInvoker
- func (c *KafkaClient) ShowPartitionMessage(request *model.ShowPartitionMessageRequest) (*model.ShowPartitionMessageResponse, error)
- func (c *KafkaClient) ShowPartitionMessageInvoker(request *model.ShowPartitionMessageRequest) *ShowPartitionMessageInvoker
- func (c *KafkaClient) ShowTopicAccessPolicy(request *model.ShowTopicAccessPolicyRequest) (*model.ShowTopicAccessPolicyResponse, error)
- func (c *KafkaClient) ShowTopicAccessPolicyInvoker(request *model.ShowTopicAccessPolicyRequest) *ShowTopicAccessPolicyInvoker
- func (c *KafkaClient) UpdateInstance(request *model.UpdateInstanceRequest) (*model.UpdateInstanceResponse, error)
- func (c *KafkaClient) UpdateInstanceAutoCreateTopic(request *model.UpdateInstanceAutoCreateTopicRequest) (*model.UpdateInstanceAutoCreateTopicResponse, error)
- func (c *KafkaClient) UpdateInstanceAutoCreateTopicInvoker(request *model.UpdateInstanceAutoCreateTopicRequest) *UpdateInstanceAutoCreateTopicInvoker
- func (c *KafkaClient) UpdateInstanceConsumerGroup(request *model.UpdateInstanceConsumerGroupRequest) (*model.UpdateInstanceConsumerGroupResponse, error)
- func (c *KafkaClient) UpdateInstanceConsumerGroupInvoker(request *model.UpdateInstanceConsumerGroupRequest) *UpdateInstanceConsumerGroupInvoker
- func (c *KafkaClient) UpdateInstanceCrossVpcIp(request *model.UpdateInstanceCrossVpcIpRequest) (*model.UpdateInstanceCrossVpcIpResponse, error)
- func (c *KafkaClient) UpdateInstanceCrossVpcIpInvoker(request *model.UpdateInstanceCrossVpcIpRequest) *UpdateInstanceCrossVpcIpInvoker
- func (c *KafkaClient) UpdateInstanceInvoker(request *model.UpdateInstanceRequest) *UpdateInstanceInvoker
- func (c *KafkaClient) UpdateInstanceTopic(request *model.UpdateInstanceTopicRequest) (*model.UpdateInstanceTopicResponse, error)
- func (c *KafkaClient) UpdateInstanceTopicInvoker(request *model.UpdateInstanceTopicRequest) *UpdateInstanceTopicInvoker
- func (c *KafkaClient) UpdateInstanceUser(request *model.UpdateInstanceUserRequest) (*model.UpdateInstanceUserResponse, error)
- func (c *KafkaClient) UpdateInstanceUserInvoker(request *model.UpdateInstanceUserRequest) *UpdateInstanceUserInvoker
- func (c *KafkaClient) UpdateKafkaUserClientQuotaTask(request *model.UpdateKafkaUserClientQuotaTaskRequest) (*model.UpdateKafkaUserClientQuotaTaskResponse, error)
- func (c *KafkaClient) UpdateKafkaUserClientQuotaTaskInvoker(request *model.UpdateKafkaUserClientQuotaTaskRequest) *UpdateKafkaUserClientQuotaTaskInvoker
- func (c *KafkaClient) UpdateTopicAccessPolicy(request *model.UpdateTopicAccessPolicyRequest) (*model.UpdateTopicAccessPolicyResponse, error)
- func (c *KafkaClient) UpdateTopicAccessPolicyInvoker(request *model.UpdateTopicAccessPolicyRequest) *UpdateTopicAccessPolicyInvoker
- func (c *KafkaClient) UpdateTopicReplica(request *model.UpdateTopicReplicaRequest) (*model.UpdateTopicReplicaResponse, error)
- func (c *KafkaClient) UpdateTopicReplicaInvoker(request *model.UpdateTopicReplicaRequest) *UpdateTopicReplicaInvoker
- type ListAvailableZonesInvoker
- type ListBackgroundTasksInvoker
- type ListConnectorTasksInvoker
- type ListEngineProductsInvoker
- type ListInstanceConsumerGroupsInvoker
- type ListInstanceTopicsInvoker
- type ListInstancesInvoker
- type ListMessageDiagnosisReportsInvoker
- type ListProductsInvoker
- type ListTopicPartitionsInvoker
- type ListTopicProducersInvoker
- type ModifyInstanceConfigsInvoker
- type PauseConnectorTaskInvoker
- type ResetManagerPasswordInvoker
- type ResetMessageOffsetInvoker
- type ResetMessageOffsetWithEngineInvoker
- type ResetPasswordInvoker
- type ResetUserPasswrodInvoker
- type ResizeEngineInstanceInvoker
- type ResizeInstanceInvoker
- type RestartConnectorTaskInvoker
- type RestartManagerInvoker
- type ResumeConnectorTaskInvoker
- type SendKafkaMessageInvoker
- type ShowBackgroundTaskInvoker
- type ShowCesHierarchyInvoker
- type ShowClusterInvoker
- type ShowConnectorTaskInvoker
- type ShowCoordinatorsInvoker
- type ShowDiagnosisPreCheckInvoker
- type ShowEngineInstanceExtendProductInfoInvoker
- type ShowGroupsInvoker
- type ShowInstanceConfigsInvoker
- type ShowInstanceExtendProductInfoInvoker
- type ShowInstanceInvoker
- type ShowInstanceMessagesInvoker
- type ShowInstanceTopicDetailInvoker
- type ShowInstanceUsersInvoker
- type ShowKafkaProjectTagsInvoker
- type ShowKafkaTagsInvoker
- type ShowKafkaTopicPartitionDiskusageInvoker
- type ShowKafkaUserClientQuotaInvoker
- type ShowMaintainWindowsInvoker
- type ShowMessageDiagnosisReportInvoker
- type ShowMessagesInvoker
- type ShowPartitionBeginningMessageInvoker
- type ShowPartitionEndMessageInvoker
- type ShowPartitionMessageInvoker
- type ShowTopicAccessPolicyInvoker
- type UpdateInstanceAutoCreateTopicInvoker
- type UpdateInstanceConsumerGroupInvoker
- type UpdateInstanceCrossVpcIpInvoker
- type UpdateInstanceInvoker
- type UpdateInstanceTopicInvoker
- type UpdateInstanceUserInvoker
- type UpdateKafkaUserClientQuotaTaskInvoker
- type UpdateTopicAccessPolicyInvoker
- type UpdateTopicReplicaInvoker
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)