v2

package
v0.0.4-beta Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenReqDefForBatchCreateOrDeleteKafkaTag 

func GenReqDefForBatchCreateOrDeleteKafkaTag() *def.HttpRequestDef

func GenReqDefForBatchDeleteGroup 

func GenReqDefForBatchDeleteGroup() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstanceTopic 

func GenReqDefForBatchDeleteInstanceTopic() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstanceUsers 

func GenReqDefForBatchDeleteInstanceUsers() *def.HttpRequestDef

func GenReqDefForBatchRestartOrDeleteInstances 

func GenReqDefForBatchRestartOrDeleteInstances() *def.HttpRequestDef

func GenReqDefForCloseKafkaManager 

func GenReqDefForCloseKafkaManager() *def.HttpRequestDef

func GenReqDefForCreateConnector 

func GenReqDefForCreateConnector() *def.HttpRequestDef

func GenReqDefForCreateDeleteConnectorOrder 

func GenReqDefForCreateDeleteConnectorOrder() *def.HttpRequestDef

func GenReqDefForCreateInstanceByEngine 

func GenReqDefForCreateInstanceByEngine() *def.HttpRequestDef

func GenReqDefForCreateInstanceTopic 

func GenReqDefForCreateInstanceTopic() *def.HttpRequestDef

func GenReqDefForCreateInstanceUser 

func GenReqDefForCreateInstanceUser() *def.HttpRequestDef

func GenReqDefForCreateKafkaConsumerGroup 

func GenReqDefForCreateKafkaConsumerGroup() *def.HttpRequestDef

func GenReqDefForCreatePartition 

func GenReqDefForCreatePartition() *def.HttpRequestDef

func GenReqDefForCreatePostPaidInstance 

func GenReqDefForCreatePostPaidInstance() *def.HttpRequestDef

func GenReqDefForCreateReassignmentTask 

func GenReqDefForCreateReassignmentTask() *def.HttpRequestDef

func GenReqDefForCreateSinkTask 

func GenReqDefForCreateSinkTask() *def.HttpRequestDef

func GenReqDefForDeleteBackgroundTask 

func GenReqDefForDeleteBackgroundTask() *def.HttpRequestDef

func GenReqDefForDeleteConnector 

func GenReqDefForDeleteConnector() *def.HttpRequestDef

func GenReqDefForDeleteInstance 

func GenReqDefForDeleteInstance() *def.HttpRequestDef

func GenReqDefForDeleteSinkTask 

func GenReqDefForDeleteSinkTask() *def.HttpRequestDef

func GenReqDefForListAvailableZones 

func GenReqDefForListAvailableZones() *def.HttpRequestDef

func GenReqDefForListBackgroundTasks 

func GenReqDefForListBackgroundTasks() *def.HttpRequestDef

func GenReqDefForListEngineProducts 

func GenReqDefForListEngineProducts() *def.HttpRequestDef

func GenReqDefForListInstanceConsumerGroups 

func GenReqDefForListInstanceConsumerGroups() *def.HttpRequestDef

func GenReqDefForListInstanceTopics 

func GenReqDefForListInstanceTopics() *def.HttpRequestDef

func GenReqDefForListInstances 

func GenReqDefForListInstances() *def.HttpRequestDef

func GenReqDefForListProducts 

func GenReqDefForListProducts() *def.HttpRequestDef

func GenReqDefForListSinkTasks 

func GenReqDefForListSinkTasks() *def.HttpRequestDef

func GenReqDefForListTopicPartitions 

func GenReqDefForListTopicPartitions() *def.HttpRequestDef

func GenReqDefForListTopicProducers 

func GenReqDefForListTopicProducers() *def.HttpRequestDef

func GenReqDefForResetManagerPassword 

func GenReqDefForResetManagerPassword() *def.HttpRequestDef

func GenReqDefForResetMessageOffset 

func GenReqDefForResetMessageOffset() *def.HttpRequestDef

func GenReqDefForResetPassword 

func GenReqDefForResetPassword() *def.HttpRequestDef

func GenReqDefForResetUserPasswrod 

func GenReqDefForResetUserPasswrod() *def.HttpRequestDef

func GenReqDefForResizeEngineInstance 

func GenReqDefForResizeEngineInstance() *def.HttpRequestDef

func GenReqDefForResizeInstance 

func GenReqDefForResizeInstance() *def.HttpRequestDef

func GenReqDefForRestartManager 

func GenReqDefForRestartManager() *def.HttpRequestDef

func GenReqDefForShowBackgroundTask 

func GenReqDefForShowBackgroundTask() *def.HttpRequestDef

func GenReqDefForShowCesHierarchy 

func GenReqDefForShowCesHierarchy() *def.HttpRequestDef

func GenReqDefForShowCluster 

func GenReqDefForShowCluster() *def.HttpRequestDef

func GenReqDefForShowCoordinators 

func GenReqDefForShowCoordinators() *def.HttpRequestDef

func GenReqDefForShowEngineInstanceExtendProductInfo 

func GenReqDefForShowEngineInstanceExtendProductInfo() *def.HttpRequestDef

func GenReqDefForShowGroups 

func GenReqDefForShowGroups() *def.HttpRequestDef

func GenReqDefForShowInstance 

func GenReqDefForShowInstance() *def.HttpRequestDef

func GenReqDefForShowInstanceExtendProductInfo 

func GenReqDefForShowInstanceExtendProductInfo() *def.HttpRequestDef

func GenReqDefForShowInstanceMessages 

func GenReqDefForShowInstanceMessages() *def.HttpRequestDef

func GenReqDefForShowInstanceTopicDetail 

func GenReqDefForShowInstanceTopicDetail() *def.HttpRequestDef

func GenReqDefForShowInstanceUsers 

func GenReqDefForShowInstanceUsers() *def.HttpRequestDef

func GenReqDefForShowKafkaProjectTags 

func GenReqDefForShowKafkaProjectTags() *def.HttpRequestDef

func GenReqDefForShowKafkaTags 

func GenReqDefForShowKafkaTags() *def.HttpRequestDef

func GenReqDefForShowKafkaTopicPartitionDiskusage 

func GenReqDefForShowKafkaTopicPartitionDiskusage() *def.HttpRequestDef

func GenReqDefForShowMaintainWindows 

func GenReqDefForShowMaintainWindows() *def.HttpRequestDef

func GenReqDefForShowMessages 

func GenReqDefForShowMessages() *def.HttpRequestDef

func GenReqDefForShowPartitionBeginningMessage 

func GenReqDefForShowPartitionBeginningMessage() *def.HttpRequestDef

func GenReqDefForShowPartitionEndMessage 

func GenReqDefForShowPartitionEndMessage() *def.HttpRequestDef

func GenReqDefForShowPartitionMessage 

func GenReqDefForShowPartitionMessage() *def.HttpRequestDef

func GenReqDefForShowSinkTaskDetail 

func GenReqDefForShowSinkTaskDetail() *def.HttpRequestDef

func GenReqDefForShowTopicAccessPolicy 

func GenReqDefForShowTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForUpdateInstance 

func GenReqDefForUpdateInstance() *def.HttpRequestDef

func GenReqDefForUpdateInstanceAutoCreateTopic 

func GenReqDefForUpdateInstanceAutoCreateTopic() *def.HttpRequestDef

func GenReqDefForUpdateInstanceConsumerGroup 

func GenReqDefForUpdateInstanceConsumerGroup() *def.HttpRequestDef

func GenReqDefForUpdateInstanceCrossVpcIp 

func GenReqDefForUpdateInstanceCrossVpcIp() *def.HttpRequestDef

func GenReqDefForUpdateInstanceTopic 

func GenReqDefForUpdateInstanceTopic() *def.HttpRequestDef

func GenReqDefForUpdateInstanceUser 

func GenReqDefForUpdateInstanceUser() *def.HttpRequestDef

func GenReqDefForUpdateSinkTaskQuota 

func GenReqDefForUpdateSinkTaskQuota() *def.HttpRequestDef

func GenReqDefForUpdateTopicAccessPolicy 

func GenReqDefForUpdateTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForUpdateTopicReplica 

func GenReqDefForUpdateTopicReplica() *def.HttpRequestDef

func KafkaClientBuilder 

func KafkaClientBuilder() *http_client.HcHttpClientBuilder

Types

type BatchCreateOrDeleteKafkaTagInvoker 

type BatchCreateOrDeleteKafkaTagInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchCreateOrDeleteKafkaTagInvoker) Invoke 

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

type BatchDeleteGroupInvoker 

type BatchDeleteGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteGroupInvoker) Invoke 

func (i *BatchDeleteGroupInvoker) Invoke() (*model.BatchDeleteGroupResponse, error)

type BatchDeleteInstanceTopicInvoker 

type BatchDeleteInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteInstanceTopicInvoker) Invoke 

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

type BatchDeleteInstanceUsersInvoker 

type BatchDeleteInstanceUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteInstanceUsersInvoker) Invoke 

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

type BatchRestartOrDeleteInstancesInvoker 

type BatchRestartOrDeleteInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchRestartOrDeleteInstancesInvoker) Invoke 

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

type CloseKafkaManagerInvoker 

type CloseKafkaManagerInvoker struct {
	*invoker.BaseInvoker
}

func (*CloseKafkaManagerInvoker) Invoke 

func (i *CloseKafkaManagerInvoker) Invoke() (*model.CloseKafkaManagerResponse, error)

type CreateConnectorInvoker 

type CreateConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateConnectorInvoker) Invoke 

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

type CreateDeleteConnectorOrderInvoker 

type CreateDeleteConnectorOrderInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateDeleteConnectorOrderInvoker) Invoke 

func (i *CreateDeleteConnectorOrderInvoker) Invoke() (*model.CreateDeleteConnectorOrderResponse, error)

type CreateInstanceByEngineInvoker 

type CreateInstanceByEngineInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceByEngineInvoker) Invoke 

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

type CreateInstanceTopicInvoker 

type CreateInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceTopicInvoker) Invoke 

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

type CreateInstanceUserInvoker 

type CreateInstanceUserInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceUserInvoker) Invoke 

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

type CreateKafkaConsumerGroupInvoker 

type CreateKafkaConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateKafkaConsumerGroupInvoker) Invoke 

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

type CreatePartitionInvoker 

type CreatePartitionInvoker struct {
	*invoker.BaseInvoker
}

func (*CreatePartitionInvoker) Invoke 

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

type CreatePostPaidInstanceInvoker 

type CreatePostPaidInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreatePostPaidInstanceInvoker) Invoke 

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

type CreateReassignmentTaskInvoker 

type CreateReassignmentTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateReassignmentTaskInvoker) Invoke 

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

type CreateSinkTaskInvoker 

type CreateSinkTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateSinkTaskInvoker) Invoke 

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

type DeleteBackgroundTaskInvoker 

type DeleteBackgroundTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteBackgroundTaskInvoker) Invoke 

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

type DeleteConnectorInvoker 

type DeleteConnectorInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteConnectorInvoker) Invoke 

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

type DeleteInstanceInvoker 

type DeleteInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteInstanceInvoker) Invoke 

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

type DeleteSinkTaskInvoker 

type DeleteSinkTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteSinkTaskInvoker) Invoke 

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

type KafkaClient 

type KafkaClient struct {
	HcClient *http_client.HcHttpClient
}

func NewKafkaClient 

func NewKafkaClient(hcClient *http_client.HcHttpClient) *KafkaClient

func (*KafkaClient) BatchCreateOrDeleteKafkaTag 

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

func (*KafkaClient) BatchCreateOrDeleteKafkaTagInvoker 

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

func (*KafkaClient) BatchDeleteGroup 

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

func (*KafkaClient) BatchDeleteGroupInvoker 

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

func (*KafkaClient) BatchDeleteInstanceTopic 

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

func (*KafkaClient) BatchDeleteInstanceTopicInvoker 

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

func (*KafkaClient) BatchDeleteInstanceUsers 

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

func (*KafkaClient) BatchDeleteInstanceUsersInvoker 

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

func (*KafkaClient) BatchRestartOrDeleteInstances 

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

func (*KafkaClient) BatchRestartOrDeleteInstancesInvoker 

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

func (*KafkaClient) CloseKafkaManager 

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

func (*KafkaClient) CloseKafkaManagerInvoker 

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

func (*KafkaClient) CreateConnector 

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

func (*KafkaClient) CreateConnectorInvoker 

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

func (*KafkaClient) CreateDeleteConnectorOrder 

func (c *KafkaClient) CreateDeleteConnectorOrder(request *model.CreateDeleteConnectorOrderRequest) (*model.CreateDeleteConnectorOrderResponse, error)

func (*KafkaClient) CreateDeleteConnectorOrderInvoker 

func (c *KafkaClient) CreateDeleteConnectorOrderInvoker(request *model.CreateDeleteConnectorOrderRequest) *CreateDeleteConnectorOrderInvoker

func (*KafkaClient) CreateInstanceByEngine 

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

func (*KafkaClient) CreateInstanceByEngineInvoker 

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

func (*KafkaClient) CreateInstanceTopic 

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

func (*KafkaClient) CreateInstanceTopicInvoker 

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

func (*KafkaClient) CreateInstanceUser 

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

func (*KafkaClient) CreateInstanceUserInvoker 

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

func (*KafkaClient) CreateKafkaConsumerGroup 

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

func (*KafkaClient) CreateKafkaConsumerGroupInvoker 

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

func (*KafkaClient) CreatePartition 

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

func (*KafkaClient) CreatePartitionInvoker 

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

func (*KafkaClient) CreatePostPaidInstance 

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

func (*KafkaClient) CreatePostPaidInstanceInvoker 

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

func (*KafkaClient) CreateReassignmentTask 

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

func (*KafkaClient) CreateReassignmentTaskInvoker 

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

func (*KafkaClient) CreateSinkTask 

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

func (*KafkaClient) CreateSinkTaskInvoker 

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

func (*KafkaClient) DeleteBackgroundTask 

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

func (*KafkaClient) DeleteBackgroundTaskInvoker 

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

func (*KafkaClient) DeleteConnector 

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

func (*KafkaClient) DeleteConnectorInvoker 

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

func (*KafkaClient) DeleteInstance 

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

func (*KafkaClient) DeleteInstanceInvoker 

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

func (*KafkaClient) DeleteSinkTask 

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

func (*KafkaClient) DeleteSinkTaskInvoker 

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

func (*KafkaClient) GetBatchCreateOrDeleteKafkaTagRequest 

func (c *KafkaClient) GetBatchCreateOrDeleteKafkaTagRequest() *model.BatchCreateOrDeleteKafkaTagRequest

func (*KafkaClient) GetBatchDeleteGroupRequest 

func (c *KafkaClient) GetBatchDeleteGroupRequest() *model.BatchDeleteGroupRequest

func (*KafkaClient) GetBatchDeleteInstanceTopicRequest 

func (c *KafkaClient) GetBatchDeleteInstanceTopicRequest() *model.BatchDeleteInstanceTopicRequest

func (*KafkaClient) GetBatchDeleteInstanceUsersRequest 

func (c *KafkaClient) GetBatchDeleteInstanceUsersRequest() *model.BatchDeleteInstanceUsersRequest

func (*KafkaClient) GetBatchRestartOrDeleteInstancesRequest 

func (c *KafkaClient) GetBatchRestartOrDeleteInstancesRequest() *model.BatchRestartOrDeleteInstancesRequest

func (*KafkaClient) GetCloseKafkaManagerRequest 

func (c *KafkaClient) GetCloseKafkaManagerRequest() *model.CloseKafkaManagerRequest

func (*KafkaClient) GetCreateConnectorRequest 

func (c *KafkaClient) GetCreateConnectorRequest() *model.CreateConnectorRequest

func (*KafkaClient) GetCreateDeleteConnectorOrderRequest 

func (c *KafkaClient) GetCreateDeleteConnectorOrderRequest() *model.CreateDeleteConnectorOrderRequest

func (*KafkaClient) GetCreateInstanceByEngineRequest 

func (c *KafkaClient) GetCreateInstanceByEngineRequest() *model.CreateInstanceByEngineRequest

func (*KafkaClient) GetCreateInstanceTopicRequest 

func (c *KafkaClient) GetCreateInstanceTopicRequest() *model.CreateInstanceTopicRequest

func (*KafkaClient) GetCreateInstanceUserRequest 

func (c *KafkaClient) GetCreateInstanceUserRequest() *model.CreateInstanceUserRequest

func (*KafkaClient) GetCreateKafkaConsumerGroupRequest 

func (c *KafkaClient) GetCreateKafkaConsumerGroupRequest() *model.CreateKafkaConsumerGroupRequest

func (*KafkaClient) GetCreatePartitionRequest 

func (c *KafkaClient) GetCreatePartitionRequest() *model.CreatePartitionRequest

func (*KafkaClient) GetCreatePostPaidInstanceRequest 

func (c *KafkaClient) GetCreatePostPaidInstanceRequest() *model.CreatePostPaidInstanceRequest

func (*KafkaClient) GetCreateReassignmentTaskRequest 

func (c *KafkaClient) GetCreateReassignmentTaskRequest() *model.CreateReassignmentTaskRequest

func (*KafkaClient) GetCreateSinkTaskRequest 

func (c *KafkaClient) GetCreateSinkTaskRequest() *model.CreateSinkTaskRequest

func (*KafkaClient) GetDeleteBackgroundTaskRequest 

func (c *KafkaClient) GetDeleteBackgroundTaskRequest() *model.DeleteBackgroundTaskRequest

func (*KafkaClient) GetDeleteConnectorRequest 

func (c *KafkaClient) GetDeleteConnectorRequest() *model.DeleteConnectorRequest

func (*KafkaClient) GetDeleteInstanceRequest 

func (c *KafkaClient) GetDeleteInstanceRequest() *model.DeleteInstanceRequest

func (*KafkaClient) GetDeleteSinkTaskRequest 

func (c *KafkaClient) GetDeleteSinkTaskRequest() *model.DeleteSinkTaskRequest

func (*KafkaClient) GetListAvailableZonesRequest 

func (c *KafkaClient) GetListAvailableZonesRequest() *model.ListAvailableZonesRequest

func (*KafkaClient) GetListBackgroundTasksRequest 

func (c *KafkaClient) GetListBackgroundTasksRequest() *model.ListBackgroundTasksRequest

func (*KafkaClient) GetListEngineProductsRequest 

func (c *KafkaClient) GetListEngineProductsRequest() *model.ListEngineProductsRequest

func (*KafkaClient) GetListInstanceConsumerGroupsRequest 

func (c *KafkaClient) GetListInstanceConsumerGroupsRequest() *model.ListInstanceConsumerGroupsRequest

func (*KafkaClient) GetListInstanceTopicsRequest 

func (c *KafkaClient) GetListInstanceTopicsRequest() *model.ListInstanceTopicsRequest

func (*KafkaClient) GetListInstancesRequest 

func (c *KafkaClient) GetListInstancesRequest() *model.ListInstancesRequest

func (*KafkaClient) GetListProductsRequest 

func (c *KafkaClient) GetListProductsRequest() *model.ListProductsRequest

func (*KafkaClient) GetListSinkTasksRequest 

func (c *KafkaClient) GetListSinkTasksRequest() *model.ListSinkTasksRequest

func (*KafkaClient) GetListTopicPartitionsRequest 

func (c *KafkaClient) GetListTopicPartitionsRequest() *model.ListTopicPartitionsRequest

func (*KafkaClient) GetListTopicProducersRequest 

func (c *KafkaClient) GetListTopicProducersRequest() *model.ListTopicProducersRequest

func (*KafkaClient) GetResetManagerPasswordRequest 

func (c *KafkaClient) GetResetManagerPasswordRequest() *model.ResetManagerPasswordRequest

func (*KafkaClient) GetResetMessageOffsetRequest 

func (c *KafkaClient) GetResetMessageOffsetRequest() *model.ResetMessageOffsetRequest

func (*KafkaClient) GetResetPasswordRequest 

func (c *KafkaClient) GetResetPasswordRequest() *model.ResetPasswordRequest

func (*KafkaClient) GetResetUserPasswrodRequest 

func (c *KafkaClient) GetResetUserPasswrodRequest() *model.ResetUserPasswrodRequest

func (*KafkaClient) GetResizeEngineInstanceRequest 

func (c *KafkaClient) GetResizeEngineInstanceRequest() *model.ResizeEngineInstanceRequest

func (*KafkaClient) GetResizeInstanceRequest 

func (c *KafkaClient) GetResizeInstanceRequest() *model.ResizeInstanceRequest

func (*KafkaClient) GetRestartManagerRequest 

func (c *KafkaClient) GetRestartManagerRequest() *model.RestartManagerRequest

func (*KafkaClient) GetShowBackgroundTaskRequest 

func (c *KafkaClient) GetShowBackgroundTaskRequest() *model.ShowBackgroundTaskRequest

func (*KafkaClient) GetShowCesHierarchyRequest 

func (c *KafkaClient) GetShowCesHierarchyRequest() *model.ShowCesHierarchyRequest

func (*KafkaClient) GetShowClusterRequest 

func (c *KafkaClient) GetShowClusterRequest() *model.ShowClusterRequest

func (*KafkaClient) GetShowCoordinatorsRequest 

func (c *KafkaClient) GetShowCoordinatorsRequest() *model.ShowCoordinatorsRequest

func (*KafkaClient) GetShowEngineInstanceExtendProductInfoRequest 

func (c *KafkaClient) GetShowEngineInstanceExtendProductInfoRequest() *model.ShowEngineInstanceExtendProductInfoRequest

func (*KafkaClient) GetShowGroupsRequest 

func (c *KafkaClient) GetShowGroupsRequest() *model.ShowGroupsRequest

func (*KafkaClient) GetShowInstanceExtendProductInfoRequest 

func (c *KafkaClient) GetShowInstanceExtendProductInfoRequest() *model.ShowInstanceExtendProductInfoRequest

func (*KafkaClient) GetShowInstanceMessagesRequest 

func (c *KafkaClient) GetShowInstanceMessagesRequest() *model.ShowInstanceMessagesRequest

func (*KafkaClient) GetShowInstanceRequest 

func (c *KafkaClient) GetShowInstanceRequest() *model.ShowInstanceRequest

func (*KafkaClient) GetShowInstanceTopicDetailRequest 

func (c *KafkaClient) GetShowInstanceTopicDetailRequest() *model.ShowInstanceTopicDetailRequest

func (*KafkaClient) GetShowInstanceUsersRequest 

func (c *KafkaClient) GetShowInstanceUsersRequest() *model.ShowInstanceUsersRequest

func (*KafkaClient) GetShowKafkaProjectTagsRequest 

func (c *KafkaClient) GetShowKafkaProjectTagsRequest() *model.ShowKafkaProjectTagsRequest

func (*KafkaClient) GetShowKafkaTagsRequest 

func (c *KafkaClient) GetShowKafkaTagsRequest() *model.ShowKafkaTagsRequest

func (*KafkaClient) GetShowKafkaTopicPartitionDiskusageRequest 

func (c *KafkaClient) GetShowKafkaTopicPartitionDiskusageRequest() *model.ShowKafkaTopicPartitionDiskusageRequest

func (*KafkaClient) GetShowMaintainWindowsRequest 

func (c *KafkaClient) GetShowMaintainWindowsRequest() *model.ShowMaintainWindowsRequest

func (*KafkaClient) GetShowMessagesRequest 

func (c *KafkaClient) GetShowMessagesRequest() *model.ShowMessagesRequest

func (*KafkaClient) GetShowPartitionBeginningMessageRequest 

func (c *KafkaClient) GetShowPartitionBeginningMessageRequest() *model.ShowPartitionBeginningMessageRequest

func (*KafkaClient) GetShowPartitionEndMessageRequest 

func (c *KafkaClient) GetShowPartitionEndMessageRequest() *model.ShowPartitionEndMessageRequest

func (*KafkaClient) GetShowPartitionMessageRequest 

func (c *KafkaClient) GetShowPartitionMessageRequest() *model.ShowPartitionMessageRequest

func (*KafkaClient) GetShowSinkTaskDetailRequest 

func (c *KafkaClient) GetShowSinkTaskDetailRequest() *model.ShowSinkTaskDetailRequest

func (*KafkaClient) GetShowTopicAccessPolicyRequest 

func (c *KafkaClient) GetShowTopicAccessPolicyRequest() *model.ShowTopicAccessPolicyRequest

func (*KafkaClient) GetUpdateInstanceAutoCreateTopicRequest 

func (c *KafkaClient) GetUpdateInstanceAutoCreateTopicRequest() *model.UpdateInstanceAutoCreateTopicRequest

func (*KafkaClient) GetUpdateInstanceConsumerGroupRequest 

func (c *KafkaClient) GetUpdateInstanceConsumerGroupRequest() *model.UpdateInstanceConsumerGroupRequest

func (*KafkaClient) GetUpdateInstanceCrossVpcIpRequest 

func (c *KafkaClient) GetUpdateInstanceCrossVpcIpRequest() *model.UpdateInstanceCrossVpcIpRequest

func (*KafkaClient) GetUpdateInstanceRequest 

func (c *KafkaClient) GetUpdateInstanceRequest() *model.UpdateInstanceRequest

func (*KafkaClient) GetUpdateInstanceTopicRequest 

func (c *KafkaClient) GetUpdateInstanceTopicRequest() *model.UpdateInstanceTopicRequest

func (*KafkaClient) GetUpdateInstanceUserRequest 

func (c *KafkaClient) GetUpdateInstanceUserRequest() *model.UpdateInstanceUserRequest

func (*KafkaClient) GetUpdateSinkTaskQuotaRequest 

func (c *KafkaClient) GetUpdateSinkTaskQuotaRequest() *model.UpdateSinkTaskQuotaRequest

func (*KafkaClient) GetUpdateTopicAccessPolicyRequest 

func (c *KafkaClient) GetUpdateTopicAccessPolicyRequest() *model.UpdateTopicAccessPolicyRequest

func (*KafkaClient) GetUpdateTopicReplicaRequest 

func (c *KafkaClient) GetUpdateTopicReplicaRequest() *model.UpdateTopicReplicaRequest

func (*KafkaClient) ListAvailableZones 

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

func (*KafkaClient) ListAvailableZonesInvoker 

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

func (*KafkaClient) ListBackgroundTasks 

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

func (*KafkaClient) ListBackgroundTasksInvoker 

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

func (*KafkaClient) ListEngineProducts 

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

func (*KafkaClient) ListEngineProductsInvoker 

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

func (*KafkaClient) ListInstanceConsumerGroups 

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

func (*KafkaClient) ListInstanceConsumerGroupsInvoker 

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

func (*KafkaClient) ListInstanceTopics 

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

func (*KafkaClient) ListInstanceTopicsInvoker 

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

func (*KafkaClient) ListInstances 

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

func (*KafkaClient) ListInstancesInvoker 

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

func (*KafkaClient) ListProducts 

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

func (*KafkaClient) ListProductsInvoker 

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

func (*KafkaClient) ListSinkTasks 

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

func (*KafkaClient) ListSinkTasksInvoker 

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

func (*KafkaClient) ListTopicPartitions 

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

func (*KafkaClient) ListTopicPartitionsInvoker 

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

func (*KafkaClient) ListTopicProducers 

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

func (*KafkaClient) ListTopicProducersInvoker 

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

func (*KafkaClient) ResetManagerPassword 

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

func (*KafkaClient) ResetManagerPasswordInvoker 

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

func (*KafkaClient) ResetMessageOffset 

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

func (*KafkaClient) ResetMessageOffsetInvoker 

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

func (*KafkaClient) ResetPassword 

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

func (*KafkaClient) ResetPasswordInvoker 

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

func (*KafkaClient) ResetUserPasswrod 

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

func (*KafkaClient) ResetUserPasswrodInvoker 

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

func (*KafkaClient) ResizeEngineInstance 

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

func (*KafkaClient) ResizeEngineInstanceInvoker 

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

func (*KafkaClient) ResizeInstance 

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

func (*KafkaClient) ResizeInstanceInvoker 

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

func (*KafkaClient) RestartManager 

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

func (*KafkaClient) RestartManagerInvoker 

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

func (*KafkaClient) ShowBackgroundTask 

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

func (*KafkaClient) ShowBackgroundTaskInvoker 

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

func (*KafkaClient) ShowCesHierarchy 

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

func (*KafkaClient) ShowCesHierarchyInvoker 

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

func (*KafkaClient) ShowCluster 

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

func (*KafkaClient) ShowClusterInvoker 

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

func (*KafkaClient) ShowCoordinators 

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

func (*KafkaClient) ShowCoordinatorsInvoker 

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

func (*KafkaClient) ShowEngineInstanceExtendProductInfo 

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

func (*KafkaClient) ShowEngineInstanceExtendProductInfoInvoker 

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

func (*KafkaClient) ShowGroups 

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

func (*KafkaClient) ShowGroupsInvoker 

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

func (*KafkaClient) ShowInstance 

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

func (*KafkaClient) ShowInstanceExtendProductInfo 

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

func (*KafkaClient) ShowInstanceExtendProductInfoInvoker 

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

func (*KafkaClient) ShowInstanceInvoker 

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

func (*KafkaClient) ShowInstanceMessages 

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

func (*KafkaClient) ShowInstanceMessagesInvoker 

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

func (*KafkaClient) ShowInstanceTopicDetail 

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

func (*KafkaClient) ShowInstanceTopicDetailInvoker 

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

func (*KafkaClient) ShowInstanceUsers 

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

func (*KafkaClient) ShowInstanceUsersInvoker 

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

func (*KafkaClient) ShowKafkaProjectTags 

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

func (*KafkaClient) ShowKafkaProjectTagsInvoker 

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

func (*KafkaClient) ShowKafkaTags 

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

func (*KafkaClient) ShowKafkaTagsInvoker 

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

func (*KafkaClient) ShowKafkaTopicPartitionDiskusage 

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

func (*KafkaClient) ShowKafkaTopicPartitionDiskusageInvoker 

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

func (*KafkaClient) ShowMaintainWindows 

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

func (*KafkaClient) ShowMaintainWindowsInvoker 

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

func (*KafkaClient) ShowMessages 

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

func (*KafkaClient) ShowMessagesInvoker 

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

func (*KafkaClient) ShowPartitionBeginningMessage 

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

func (*KafkaClient) ShowPartitionBeginningMessageInvoker 

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

func (*KafkaClient) ShowPartitionEndMessage 

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

func (*KafkaClient) ShowPartitionEndMessageInvoker 

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

func (*KafkaClient) ShowPartitionMessage 

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

func (*KafkaClient) ShowPartitionMessageInvoker 

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

func (*KafkaClient) ShowSinkTaskDetail 

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

func (*KafkaClient) ShowSinkTaskDetailInvoker 

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

func (*KafkaClient) ShowTopicAccessPolicy 

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

func (*KafkaClient) ShowTopicAccessPolicyInvoker 

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

func (*KafkaClient) UpdateInstance 

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

func (*KafkaClient) UpdateInstanceAutoCreateTopic 

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

func (*KafkaClient) UpdateInstanceAutoCreateTopicInvoker 

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

func (*KafkaClient) UpdateInstanceConsumerGroup 

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

func (*KafkaClient) UpdateInstanceConsumerGroupInvoker 

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

func (*KafkaClient) UpdateInstanceCrossVpcIp 

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

func (*KafkaClient) UpdateInstanceCrossVpcIpInvoker 

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

func (*KafkaClient) UpdateInstanceInvoker 

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

func (*KafkaClient) UpdateInstanceTopic 

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

func (*KafkaClient) UpdateInstanceTopicInvoker 

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

func (*KafkaClient) UpdateInstanceUser 

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

func (*KafkaClient) UpdateInstanceUserInvoker 

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

func (*KafkaClient) UpdateSinkTaskQuota 

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

func (*KafkaClient) UpdateSinkTaskQuotaInvoker 

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

func (*KafkaClient) UpdateTopicAccessPolicy 

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

func (*KafkaClient) UpdateTopicAccessPolicyInvoker 

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

func (*KafkaClient) UpdateTopicReplica 

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

func (*KafkaClient) UpdateTopicReplicaInvoker 

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

type ListAvailableZonesInvoker 

type ListAvailableZonesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAvailableZonesInvoker) Invoke 

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

type ListBackgroundTasksInvoker 

type ListBackgroundTasksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListBackgroundTasksInvoker) Invoke 

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

type ListEngineProductsInvoker 

type ListEngineProductsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListEngineProductsInvoker) Invoke 

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

type ListInstanceConsumerGroupsInvoker 

type ListInstanceConsumerGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstanceConsumerGroupsInvoker) Invoke 

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

type ListInstanceTopicsInvoker 

type ListInstanceTopicsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstanceTopicsInvoker) Invoke 

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

type ListInstancesInvoker 

type ListInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstancesInvoker) Invoke 

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

type ListProductsInvoker 

type ListProductsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListProductsInvoker) Invoke 

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

type ListSinkTasksInvoker 

type ListSinkTasksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListSinkTasksInvoker) Invoke 

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

type ListTopicPartitionsInvoker 

type ListTopicPartitionsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTopicPartitionsInvoker) Invoke 

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

type ListTopicProducersInvoker 

type ListTopicProducersInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTopicProducersInvoker) Invoke 

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

type ResetManagerPasswordInvoker 

type ResetManagerPasswordInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetManagerPasswordInvoker) Invoke 

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

type ResetMessageOffsetInvoker 

type ResetMessageOffsetInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetMessageOffsetInvoker) Invoke 

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

type ResetPasswordInvoker 

type ResetPasswordInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetPasswordInvoker) Invoke 

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

type ResetUserPasswrodInvoker 

type ResetUserPasswrodInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetUserPasswrodInvoker) Invoke 

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

type ResizeEngineInstanceInvoker 

type ResizeEngineInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ResizeEngineInstanceInvoker) Invoke 

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

type ResizeInstanceInvoker 

type ResizeInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ResizeInstanceInvoker) Invoke 

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

type RestartManagerInvoker 

type RestartManagerInvoker struct {
	*invoker.BaseInvoker
}

func (*RestartManagerInvoker) Invoke 

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

type ShowBackgroundTaskInvoker 

type ShowBackgroundTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowBackgroundTaskInvoker) Invoke 

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

type ShowCesHierarchyInvoker 

type ShowCesHierarchyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowCesHierarchyInvoker) Invoke 

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

type ShowClusterInvoker 

type ShowClusterInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowClusterInvoker) Invoke 

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

type ShowCoordinatorsInvoker 

type ShowCoordinatorsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowCoordinatorsInvoker) Invoke 

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

type ShowEngineInstanceExtendProductInfoInvoker 

type ShowEngineInstanceExtendProductInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowEngineInstanceExtendProductInfoInvoker) Invoke 

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

type ShowGroupsInvoker 

type ShowGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowGroupsInvoker) Invoke 

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

type ShowInstanceExtendProductInfoInvoker 

type ShowInstanceExtendProductInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceExtendProductInfoInvoker) Invoke 

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

type ShowInstanceInvoker 

type ShowInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceInvoker) Invoke 

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

type ShowInstanceMessagesInvoker 

type ShowInstanceMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceMessagesInvoker) Invoke 

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

type ShowInstanceTopicDetailInvoker 

type ShowInstanceTopicDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceTopicDetailInvoker) Invoke 

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

type ShowInstanceUsersInvoker 

type ShowInstanceUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceUsersInvoker) Invoke 

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

type ShowKafkaProjectTagsInvoker 

type ShowKafkaProjectTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaProjectTagsInvoker) Invoke 

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

type ShowKafkaTagsInvoker 

type ShowKafkaTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaTagsInvoker) Invoke 

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

type ShowKafkaTopicPartitionDiskusageInvoker 

type ShowKafkaTopicPartitionDiskusageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowKafkaTopicPartitionDiskusageInvoker) Invoke 

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

type ShowMaintainWindowsInvoker 

type ShowMaintainWindowsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMaintainWindowsInvoker) Invoke 

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

type ShowMessagesInvoker 

type ShowMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMessagesInvoker) Invoke 

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

type ShowPartitionBeginningMessageInvoker 

type ShowPartitionBeginningMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionBeginningMessageInvoker) Invoke 

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

type ShowPartitionEndMessageInvoker 

type ShowPartitionEndMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionEndMessageInvoker) Invoke 

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

type ShowPartitionMessageInvoker 

type ShowPartitionMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionMessageInvoker) Invoke 

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

type ShowSinkTaskDetailInvoker 

type ShowSinkTaskDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSinkTaskDetailInvoker) Invoke 

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

type ShowTopicAccessPolicyInvoker 

type ShowTopicAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTopicAccessPolicyInvoker) Invoke 

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

type UpdateInstanceAutoCreateTopicInvoker 

type UpdateInstanceAutoCreateTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceAutoCreateTopicInvoker) Invoke 

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

type UpdateInstanceConsumerGroupInvoker 

type UpdateInstanceConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceConsumerGroupInvoker) Invoke 

func (i *UpdateInstanceConsumerGroupInvoker) Invoke() (*model.UpdateInstanceConsumerGroupResponse, error)

type UpdateInstanceCrossVpcIpInvoker 

type UpdateInstanceCrossVpcIpInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceCrossVpcIpInvoker) Invoke 

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

type UpdateInstanceInvoker 

type UpdateInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceInvoker) Invoke 

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

type UpdateInstanceTopicInvoker 

type UpdateInstanceTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceTopicInvoker) Invoke 

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

type UpdateInstanceUserInvoker 

type UpdateInstanceUserInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceUserInvoker) Invoke 

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

type UpdateSinkTaskQuotaInvoker 

type UpdateSinkTaskQuotaInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateSinkTaskQuotaInvoker) Invoke 

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

type UpdateTopicAccessPolicyInvoker 

type UpdateTopicAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTopicAccessPolicyInvoker) Invoke 

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

type UpdateTopicReplicaInvoker 

type UpdateTopicReplicaInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTopicReplicaInvoker) Invoke 

func (i *UpdateTopicReplicaInvoker) Invoke() (*model.UpdateTopicReplicaResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.