alikafka

package

v1.63.53 Latest Latest Go to latest Published: Nov 19, 2024 License: Apache-2.0 Imports: 6 Imported by: 10

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/aliyun/alibaba-cloud-sdk-go

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func GetEndpointMap() map[string]string
func GetEndpointType() string
func SetClientProperty(client *Client, propertyName string, propertyValue interface{})
func SetEndpointDataToClient(client *Client)
type AllowedIpListInGetAllowedIpList
type AllowedList
type ChangeResourceGroupRequest
- func CreateChangeResourceGroupRequest() (request *ChangeResourceGroupRequest)
type ChangeResourceGroupResponse
- func CreateChangeResourceGroupResponse() (response *ChangeResourceGroupResponse)
type Client
- func NewClient() (client *Client, err error)
- func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
- func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)
- func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
- func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
- func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
- func NewClientWithRamRoleArnAndPolicy(regionId string, ...) (client *Client, err error)
- func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
- func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
- func (client *Client) ChangeResourceGroup(request *ChangeResourceGroupRequest) (response *ChangeResourceGroupResponse, err error)
- func (client *Client) ChangeResourceGroupWithCallback(request *ChangeResourceGroupRequest, ...) <-chan int
- func (client *Client) ChangeResourceGroupWithChan(request *ChangeResourceGroupRequest) (<-chan *ChangeResourceGroupResponse, <-chan error)
- func (client *Client) ConvertPostPayOrder(request *ConvertPostPayOrderRequest) (response *ConvertPostPayOrderResponse, err error)
- func (client *Client) ConvertPostPayOrderWithCallback(request *ConvertPostPayOrderRequest, ...) <-chan int
- func (client *Client) ConvertPostPayOrderWithChan(request *ConvertPostPayOrderRequest) (<-chan *ConvertPostPayOrderResponse, <-chan error)
- func (client *Client) CreateAcl(request *CreateAclRequest) (response *CreateAclResponse, err error)
- func (client *Client) CreateAclWithCallback(request *CreateAclRequest, ...) <-chan int
- func (client *Client) CreateAclWithChan(request *CreateAclRequest) (<-chan *CreateAclResponse, <-chan error)
- func (client *Client) CreateConsumerGroup(request *CreateConsumerGroupRequest) (response *CreateConsumerGroupResponse, err error)
- func (client *Client) CreateConsumerGroupWithCallback(request *CreateConsumerGroupRequest, ...) <-chan int
- func (client *Client) CreateConsumerGroupWithChan(request *CreateConsumerGroupRequest) (<-chan *CreateConsumerGroupResponse, <-chan error)
- func (client *Client) CreatePostPayOrder(request *CreatePostPayOrderRequest) (response *CreatePostPayOrderResponse, err error)
- func (client *Client) CreatePostPayOrderWithCallback(request *CreatePostPayOrderRequest, ...) <-chan int
- func (client *Client) CreatePostPayOrderWithChan(request *CreatePostPayOrderRequest) (<-chan *CreatePostPayOrderResponse, <-chan error)
- func (client *Client) CreatePrePayOrder(request *CreatePrePayOrderRequest) (response *CreatePrePayOrderResponse, err error)
- func (client *Client) CreatePrePayOrderWithCallback(request *CreatePrePayOrderRequest, ...) <-chan int
- func (client *Client) CreatePrePayOrderWithChan(request *CreatePrePayOrderRequest) (<-chan *CreatePrePayOrderResponse, <-chan error)
- func (client *Client) CreateSaslUser(request *CreateSaslUserRequest) (response *CreateSaslUserResponse, err error)
- func (client *Client) CreateSaslUserWithCallback(request *CreateSaslUserRequest, ...) <-chan int
- func (client *Client) CreateSaslUserWithChan(request *CreateSaslUserRequest) (<-chan *CreateSaslUserResponse, <-chan error)
- func (client *Client) CreateTopic(request *CreateTopicRequest) (response *CreateTopicResponse, err error)
- func (client *Client) CreateTopicWithCallback(request *CreateTopicRequest, ...) <-chan int
- func (client *Client) CreateTopicWithChan(request *CreateTopicRequest) (<-chan *CreateTopicResponse, <-chan error)
- func (client *Client) DeleteAcl(request *DeleteAclRequest) (response *DeleteAclResponse, err error)
- func (client *Client) DeleteAclWithCallback(request *DeleteAclRequest, ...) <-chan int
- func (client *Client) DeleteAclWithChan(request *DeleteAclRequest) (<-chan *DeleteAclResponse, <-chan error)
- func (client *Client) DeleteConsumerGroup(request *DeleteConsumerGroupRequest) (response *DeleteConsumerGroupResponse, err error)
- func (client *Client) DeleteConsumerGroupWithCallback(request *DeleteConsumerGroupRequest, ...) <-chan int
- func (client *Client) DeleteConsumerGroupWithChan(request *DeleteConsumerGroupRequest) (<-chan *DeleteConsumerGroupResponse, <-chan error)
- func (client *Client) DeleteInstance(request *DeleteInstanceRequest) (response *DeleteInstanceResponse, err error)
- func (client *Client) DeleteInstanceWithCallback(request *DeleteInstanceRequest, ...) <-chan int
- func (client *Client) DeleteInstanceWithChan(request *DeleteInstanceRequest) (<-chan *DeleteInstanceResponse, <-chan error)
- func (client *Client) DeleteSaslUser(request *DeleteSaslUserRequest) (response *DeleteSaslUserResponse, err error)
- func (client *Client) DeleteSaslUserWithCallback(request *DeleteSaslUserRequest, ...) <-chan int
- func (client *Client) DeleteSaslUserWithChan(request *DeleteSaslUserRequest) (<-chan *DeleteSaslUserResponse, <-chan error)
- func (client *Client) DeleteTopic(request *DeleteTopicRequest) (response *DeleteTopicResponse, err error)
- func (client *Client) DeleteTopicWithCallback(request *DeleteTopicRequest, ...) <-chan int
- func (client *Client) DeleteTopicWithChan(request *DeleteTopicRequest) (<-chan *DeleteTopicResponse, <-chan error)
- func (client *Client) DescribeAcls(request *DescribeAclsRequest) (response *DescribeAclsResponse, err error)
- func (client *Client) DescribeAclsWithCallback(request *DescribeAclsRequest, ...) <-chan int
- func (client *Client) DescribeAclsWithChan(request *DescribeAclsRequest) (<-chan *DescribeAclsResponse, <-chan error)
- func (client *Client) DescribeSaslUsers(request *DescribeSaslUsersRequest) (response *DescribeSaslUsersResponse, err error)
- func (client *Client) DescribeSaslUsersWithCallback(request *DescribeSaslUsersRequest, ...) <-chan int
- func (client *Client) DescribeSaslUsersWithChan(request *DescribeSaslUsersRequest) (<-chan *DescribeSaslUsersResponse, <-chan error)
- func (client *Client) EnableAutoGroupCreation(request *EnableAutoGroupCreationRequest) (response *EnableAutoGroupCreationResponse, err error)
- func (client *Client) EnableAutoGroupCreationWithCallback(request *EnableAutoGroupCreationRequest, ...) <-chan int
- func (client *Client) EnableAutoGroupCreationWithChan(request *EnableAutoGroupCreationRequest) (<-chan *EnableAutoGroupCreationResponse, <-chan error)
- func (client *Client) EnableAutoTopicCreation(request *EnableAutoTopicCreationRequest) (response *EnableAutoTopicCreationResponse, err error)
- func (client *Client) EnableAutoTopicCreationWithCallback(request *EnableAutoTopicCreationRequest, ...) <-chan int
- func (client *Client) EnableAutoTopicCreationWithChan(request *EnableAutoTopicCreationRequest) (<-chan *EnableAutoTopicCreationResponse, <-chan error)
- func (client *Client) GetAllInstanceIdList(request *GetAllInstanceIdListRequest) (response *GetAllInstanceIdListResponse, err error)
- func (client *Client) GetAllInstanceIdListWithCallback(request *GetAllInstanceIdListRequest, ...) <-chan int
- func (client *Client) GetAllInstanceIdListWithChan(request *GetAllInstanceIdListRequest) (<-chan *GetAllInstanceIdListResponse, <-chan error)
- func (client *Client) GetAllowedIpList(request *GetAllowedIpListRequest) (response *GetAllowedIpListResponse, err error)
- func (client *Client) GetAllowedIpListWithCallback(request *GetAllowedIpListRequest, ...) <-chan int
- func (client *Client) GetAllowedIpListWithChan(request *GetAllowedIpListRequest) (<-chan *GetAllowedIpListResponse, <-chan error)
- func (client *Client) GetConsumerList(request *GetConsumerListRequest) (response *GetConsumerListResponse, err error)
- func (client *Client) GetConsumerListWithCallback(request *GetConsumerListRequest, ...) <-chan int
- func (client *Client) GetConsumerListWithChan(request *GetConsumerListRequest) (<-chan *GetConsumerListResponse, <-chan error)
- func (client *Client) GetConsumerProgress(request *GetConsumerProgressRequest) (response *GetConsumerProgressResponse, err error)
- func (client *Client) GetConsumerProgressWithCallback(request *GetConsumerProgressRequest, ...) <-chan int
- func (client *Client) GetConsumerProgressWithChan(request *GetConsumerProgressRequest) (<-chan *GetConsumerProgressResponse, <-chan error)
- func (client *Client) GetInstanceList(request *GetInstanceListRequest) (response *GetInstanceListResponse, err error)
- func (client *Client) GetInstanceListWithCallback(request *GetInstanceListRequest, ...) <-chan int
- func (client *Client) GetInstanceListWithChan(request *GetInstanceListRequest) (<-chan *GetInstanceListResponse, <-chan error)
- func (client *Client) GetQuotaTip(request *GetQuotaTipRequest) (response *GetQuotaTipResponse, err error)
- func (client *Client) GetQuotaTipWithCallback(request *GetQuotaTipRequest, ...) <-chan int
- func (client *Client) GetQuotaTipWithChan(request *GetQuotaTipRequest) (<-chan *GetQuotaTipResponse, <-chan error)
- func (client *Client) GetTopicList(request *GetTopicListRequest) (response *GetTopicListResponse, err error)
- func (client *Client) GetTopicListWithCallback(request *GetTopicListRequest, ...) <-chan int
- func (client *Client) GetTopicListWithChan(request *GetTopicListRequest) (<-chan *GetTopicListResponse, <-chan error)
- func (client *Client) GetTopicStatus(request *GetTopicStatusRequest) (response *GetTopicStatusResponse, err error)
- func (client *Client) GetTopicStatusWithCallback(request *GetTopicStatusRequest, ...) <-chan int
- func (client *Client) GetTopicStatusWithChan(request *GetTopicStatusRequest) (<-chan *GetTopicStatusResponse, <-chan error)
- func (client *Client) GetTopicSubscribeStatus(request *GetTopicSubscribeStatusRequest) (response *GetTopicSubscribeStatusResponse, err error)
- func (client *Client) GetTopicSubscribeStatusWithCallback(request *GetTopicSubscribeStatusRequest, ...) <-chan int
- func (client *Client) GetTopicSubscribeStatusWithChan(request *GetTopicSubscribeStatusRequest) (<-chan *GetTopicSubscribeStatusResponse, <-chan error)
- func (client *Client) ListTagResources(request *ListTagResourcesRequest) (response *ListTagResourcesResponse, err error)
- func (client *Client) ListTagResourcesWithCallback(request *ListTagResourcesRequest, ...) <-chan int
- func (client *Client) ListTagResourcesWithChan(request *ListTagResourcesRequest) (<-chan *ListTagResourcesResponse, <-chan error)
- func (client *Client) ModifyInstanceName(request *ModifyInstanceNameRequest) (response *ModifyInstanceNameResponse, err error)
- func (client *Client) ModifyInstanceNameWithCallback(request *ModifyInstanceNameRequest, ...) <-chan int
- func (client *Client) ModifyInstanceNameWithChan(request *ModifyInstanceNameRequest) (<-chan *ModifyInstanceNameResponse, <-chan error)
- func (client *Client) ModifyPartitionNum(request *ModifyPartitionNumRequest) (response *ModifyPartitionNumResponse, err error)
- func (client *Client) ModifyPartitionNumWithCallback(request *ModifyPartitionNumRequest, ...) <-chan int
- func (client *Client) ModifyPartitionNumWithChan(request *ModifyPartitionNumRequest) (<-chan *ModifyPartitionNumResponse, <-chan error)
- func (client *Client) ModifyTopicRemark(request *ModifyTopicRemarkRequest) (response *ModifyTopicRemarkResponse, err error)
- func (client *Client) ModifyTopicRemarkWithCallback(request *ModifyTopicRemarkRequest, ...) <-chan int
- func (client *Client) ModifyTopicRemarkWithChan(request *ModifyTopicRemarkRequest) (<-chan *ModifyTopicRemarkResponse, <-chan error)
- func (client *Client) QueryMessage(request *QueryMessageRequest) (response *QueryMessageResponse, err error)
- func (client *Client) QueryMessageWithCallback(request *QueryMessageRequest, ...) <-chan int
- func (client *Client) QueryMessageWithChan(request *QueryMessageRequest) (<-chan *QueryMessageResponse, <-chan error)
- func (client *Client) ReleaseInstance(request *ReleaseInstanceRequest) (response *ReleaseInstanceResponse, err error)
- func (client *Client) ReleaseInstanceWithCallback(request *ReleaseInstanceRequest, ...) <-chan int
- func (client *Client) ReleaseInstanceWithChan(request *ReleaseInstanceRequest) (<-chan *ReleaseInstanceResponse, <-chan error)
- func (client *Client) ReopenInstance(request *ReopenInstanceRequest) (response *ReopenInstanceResponse, err error)
- func (client *Client) ReopenInstanceWithCallback(request *ReopenInstanceRequest, ...) <-chan int
- func (client *Client) ReopenInstanceWithChan(request *ReopenInstanceRequest) (<-chan *ReopenInstanceResponse, <-chan error)
- func (client *Client) StartInstance(request *StartInstanceRequest) (response *StartInstanceResponse, err error)
- func (client *Client) StartInstanceWithCallback(request *StartInstanceRequest, ...) <-chan int
- func (client *Client) StartInstanceWithChan(request *StartInstanceRequest) (<-chan *StartInstanceResponse, <-chan error)
- func (client *Client) StopInstance(request *StopInstanceRequest) (response *StopInstanceResponse, err error)
- func (client *Client) StopInstanceWithCallback(request *StopInstanceRequest, ...) <-chan int
- func (client *Client) StopInstanceWithChan(request *StopInstanceRequest) (<-chan *StopInstanceResponse, <-chan error)
- func (client *Client) TagResources(request *TagResourcesRequest) (response *TagResourcesResponse, err error)
- func (client *Client) TagResourcesWithCallback(request *TagResourcesRequest, ...) <-chan int
- func (client *Client) TagResourcesWithChan(request *TagResourcesRequest) (<-chan *TagResourcesResponse, <-chan error)
- func (client *Client) UntagResources(request *UntagResourcesRequest) (response *UntagResourcesResponse, err error)
- func (client *Client) UntagResourcesWithCallback(request *UntagResourcesRequest, ...) <-chan int
- func (client *Client) UntagResourcesWithChan(request *UntagResourcesRequest) (<-chan *UntagResourcesResponse, <-chan error)
- func (client *Client) UpdateAllowedIp(request *UpdateAllowedIpRequest) (response *UpdateAllowedIpResponse, err error)
- func (client *Client) UpdateAllowedIpWithCallback(request *UpdateAllowedIpRequest, ...) <-chan int
- func (client *Client) UpdateAllowedIpWithChan(request *UpdateAllowedIpRequest) (<-chan *UpdateAllowedIpResponse, <-chan error)
- func (client *Client) UpdateConsumerOffset(request *UpdateConsumerOffsetRequest) (response *UpdateConsumerOffsetResponse, err error)
- func (client *Client) UpdateConsumerOffsetWithCallback(request *UpdateConsumerOffsetRequest, ...) <-chan int
- func (client *Client) UpdateConsumerOffsetWithChan(request *UpdateConsumerOffsetRequest) (<-chan *UpdateConsumerOffsetResponse, <-chan error)
- func (client *Client) UpdateInstanceConfig(request *UpdateInstanceConfigRequest) (response *UpdateInstanceConfigResponse, err error)
- func (client *Client) UpdateInstanceConfigWithCallback(request *UpdateInstanceConfigRequest, ...) <-chan int
- func (client *Client) UpdateInstanceConfigWithChan(request *UpdateInstanceConfigRequest) (<-chan *UpdateInstanceConfigResponse, <-chan error)
- func (client *Client) UpdateTopicConfig(request *UpdateTopicConfigRequest) (response *UpdateTopicConfigResponse, err error)
- func (client *Client) UpdateTopicConfigWithCallback(request *UpdateTopicConfigRequest, ...) <-chan int
- func (client *Client) UpdateTopicConfigWithChan(request *UpdateTopicConfigRequest) (<-chan *UpdateTopicConfigResponse, <-chan error)
- func (client *Client) UpgradeInstanceVersion(request *UpgradeInstanceVersionRequest) (response *UpgradeInstanceVersionResponse, err error)
- func (client *Client) UpgradeInstanceVersionWithCallback(request *UpgradeInstanceVersionRequest, ...) <-chan int
- func (client *Client) UpgradeInstanceVersionWithChan(request *UpgradeInstanceVersionRequest) (<-chan *UpgradeInstanceVersionResponse, <-chan error)
- func (client *Client) UpgradePostPayOrder(request *UpgradePostPayOrderRequest) (response *UpgradePostPayOrderResponse, err error)
- func (client *Client) UpgradePostPayOrderWithCallback(request *UpgradePostPayOrderRequest, ...) <-chan int
- func (client *Client) UpgradePostPayOrderWithChan(request *UpgradePostPayOrderRequest) (<-chan *UpgradePostPayOrderResponse, <-chan error)
- func (client *Client) UpgradePrePayOrder(request *UpgradePrePayOrderRequest) (response *UpgradePrePayOrderResponse, err error)
- func (client *Client) UpgradePrePayOrderWithCallback(request *UpgradePrePayOrderRequest, ...) <-chan int
- func (client *Client) UpgradePrePayOrderWithChan(request *UpgradePrePayOrderRequest) (<-chan *UpgradePrePayOrderResponse, <-chan error)
type ConfluentConfig
type ConsumerGroups
type ConsumerList
type ConsumerProgress
type ConsumerVO
type ConvertPostPayOrderRequest
- func CreateConvertPostPayOrderRequest() (request *ConvertPostPayOrderRequest)
type ConvertPostPayOrderResponse
- func CreateConvertPostPayOrderResponse() (response *ConvertPostPayOrderResponse)
type CreateAclRequest
- func CreateCreateAclRequest() (request *CreateAclRequest)
type CreateAclResponse
- func CreateCreateAclResponse() (response *CreateAclResponse)
type CreateConsumerGroupRequest
- func CreateCreateConsumerGroupRequest() (request *CreateConsumerGroupRequest)
type CreateConsumerGroupResponse
- func CreateCreateConsumerGroupResponse() (response *CreateConsumerGroupResponse)
type CreateConsumerGroupTag
type CreatePostPayOrderRequest
- func CreateCreatePostPayOrderRequest() (request *CreatePostPayOrderRequest)
type CreatePostPayOrderResponse
- func CreateCreatePostPayOrderResponse() (response *CreatePostPayOrderResponse)
type CreatePostPayOrderTag
type CreatePrePayOrderConfluentConfig
type CreatePrePayOrderRequest
- func CreateCreatePrePayOrderRequest() (request *CreatePrePayOrderRequest)
type CreatePrePayOrderResponse
- func CreateCreatePrePayOrderResponse() (response *CreatePrePayOrderResponse)
type CreatePrePayOrderTag
type CreateSaslUserRequest
- func CreateCreateSaslUserRequest() (request *CreateSaslUserRequest)
type CreateSaslUserResponse
- func CreateCreateSaslUserResponse() (response *CreateSaslUserResponse)
type CreateTopicRequest
- func CreateCreateTopicRequest() (request *CreateTopicRequest)
type CreateTopicResponse
- func CreateCreateTopicResponse() (response *CreateTopicResponse)
type CreateTopicTag
type DeleteAclRequest
- func CreateDeleteAclRequest() (request *DeleteAclRequest)
type DeleteAclResponse
- func CreateDeleteAclResponse() (response *DeleteAclResponse)
type DeleteConsumerGroupRequest
- func CreateDeleteConsumerGroupRequest() (request *DeleteConsumerGroupRequest)
type DeleteConsumerGroupResponse
- func CreateDeleteConsumerGroupResponse() (response *DeleteConsumerGroupResponse)
type DeleteInstanceRequest
- func CreateDeleteInstanceRequest() (request *DeleteInstanceRequest)
type DeleteInstanceResponse
- func CreateDeleteInstanceResponse() (response *DeleteInstanceResponse)
type DeleteSaslUserRequest
- func CreateDeleteSaslUserRequest() (request *DeleteSaslUserRequest)
type DeleteSaslUserResponse
- func CreateDeleteSaslUserResponse() (response *DeleteSaslUserResponse)
type DeleteTopicRequest
- func CreateDeleteTopicRequest() (request *DeleteTopicRequest)
type DeleteTopicResponse
- func CreateDeleteTopicResponse() (response *DeleteTopicResponse)
type DescribeAclsRequest
- func CreateDescribeAclsRequest() (request *DescribeAclsRequest)
type DescribeAclsResponse
- func CreateDescribeAclsResponse() (response *DescribeAclsResponse)
type DescribeSaslUsersRequest
- func CreateDescribeSaslUsersRequest() (request *DescribeSaslUsersRequest)
type DescribeSaslUsersResponse
- func CreateDescribeSaslUsersResponse() (response *DescribeSaslUsersResponse)
type EnableAutoGroupCreationRequest
- func CreateEnableAutoGroupCreationRequest() (request *EnableAutoGroupCreationRequest)
type EnableAutoGroupCreationResponse
- func CreateEnableAutoGroupCreationResponse() (response *EnableAutoGroupCreationResponse)
type EnableAutoTopicCreationRequest
- func CreateEnableAutoTopicCreationRequest() (request *EnableAutoTopicCreationRequest)
type EnableAutoTopicCreationResponse
- func CreateEnableAutoTopicCreationResponse() (response *EnableAutoTopicCreationResponse)
type GetAllInstanceIdListRequest
- func CreateGetAllInstanceIdListRequest() (request *GetAllInstanceIdListRequest)
type GetAllInstanceIdListResponse
- func CreateGetAllInstanceIdListResponse() (response *GetAllInstanceIdListResponse)
type GetAllowedIpListRequest
- func CreateGetAllowedIpListRequest() (request *GetAllowedIpListRequest)
type GetAllowedIpListResponse
- func CreateGetAllowedIpListResponse() (response *GetAllowedIpListResponse)
type GetConsumerListRequest
- func CreateGetConsumerListRequest() (request *GetConsumerListRequest)
type GetConsumerListResponse
- func CreateGetConsumerListResponse() (response *GetConsumerListResponse)
type GetConsumerProgressRequest
- func CreateGetConsumerProgressRequest() (request *GetConsumerProgressRequest)
type GetConsumerProgressResponse
- func CreateGetConsumerProgressResponse() (response *GetConsumerProgressResponse)
type GetInstanceListRequest
- func CreateGetInstanceListRequest() (request *GetInstanceListRequest)
type GetInstanceListResponse
- func CreateGetInstanceListResponse() (response *GetInstanceListResponse)
type GetInstanceListTag
type GetQuotaTipRequest
- func CreateGetQuotaTipRequest() (request *GetQuotaTipRequest)
type GetQuotaTipResponse
- func CreateGetQuotaTipResponse() (response *GetQuotaTipResponse)
type GetTopicListRequest
- func CreateGetTopicListRequest() (request *GetTopicListRequest)
type GetTopicListResponse
- func CreateGetTopicListResponse() (response *GetTopicListResponse)
type GetTopicStatusRequest
- func CreateGetTopicStatusRequest() (request *GetTopicStatusRequest)
type GetTopicStatusResponse
- func CreateGetTopicStatusResponse() (response *GetTopicStatusResponse)
type GetTopicSubscribeStatusRequest
- func CreateGetTopicSubscribeStatusRequest() (request *GetTopicSubscribeStatusRequest)
type GetTopicSubscribeStatusResponse
- func CreateGetTopicSubscribeStatusResponse() (response *GetTopicSubscribeStatusResponse)
type IPListVO
type InstanceList
type InstanceVO
type InternetList
type KafkaAclList
type KafkaAclVO
type ListTagResourcesRequest
- func CreateListTagResourcesRequest() (request *ListTagResourcesRequest)
type ListTagResourcesResponse
- func CreateListTagResourcesResponse() (response *ListTagResourcesResponse)
type ListTagResourcesTag
type MessageList
type MessageVO
type ModifyInstanceNameRequest
- func CreateModifyInstanceNameRequest() (request *ModifyInstanceNameRequest)
type ModifyInstanceNameResponse
- func CreateModifyInstanceNameResponse() (response *ModifyInstanceNameResponse)
type ModifyPartitionNumRequest
- func CreateModifyPartitionNumRequest() (request *ModifyPartitionNumRequest)
type ModifyPartitionNumResponse
- func CreateModifyPartitionNumResponse() (response *ModifyPartitionNumResponse)
type ModifyTopicRemarkRequest
- func CreateModifyTopicRemarkRequest() (request *ModifyTopicRemarkRequest)
type ModifyTopicRemarkResponse
- func CreateModifyTopicRemarkResponse() (response *ModifyTopicRemarkResponse)
type OffsetList
type OffsetListItem
type OffsetTable
type OffsetTableItem
type QueryMessageRequest
- func CreateQueryMessageRequest() (request *QueryMessageRequest)
type QueryMessageResponse
- func CreateQueryMessageResponse() (response *QueryMessageResponse)
type QuotaData
type RebalanceInfoList
type RebalanceInfoListItem
type ReleaseInstanceRequest
- func CreateReleaseInstanceRequest() (request *ReleaseInstanceRequest)
type ReleaseInstanceResponse
- func CreateReleaseInstanceResponse() (response *ReleaseInstanceResponse)
type ReopenInstanceRequest
- func CreateReopenInstanceRequest() (request *ReopenInstanceRequest)
type ReopenInstanceResponse
- func CreateReopenInstanceResponse() (response *ReopenInstanceResponse)
type SaslUserList
type SaslUserVO
type StartInstanceRequest
- func CreateStartInstanceRequest() (request *StartInstanceRequest)
type StartInstanceResponse
- func CreateStartInstanceResponse() (response *StartInstanceResponse)
type StopInstanceRequest
- func CreateStopInstanceRequest() (request *StopInstanceRequest)
type StopInstanceResponse
- func CreateStopInstanceResponse() (response *StopInstanceResponse)
type TagResource
type TagResources
type TagResourcesRequest
- func CreateTagResourcesRequest() (request *TagResourcesRequest)
type TagResourcesResponse
- func CreateTagResourcesResponse() (response *TagResourcesResponse)
type TagResourcesTag
type TagVO
type TagsInGetConsumerList
type TagsInGetInstanceList
type TagsInGetTopicList
type TopicListInGetConsumerProgress
type TopicListInGetTopicList
type TopicListItem
type TopicStatus
type TopicSubscribeStatus
type TopicVO
type UntagResourcesRequest
- func CreateUntagResourcesRequest() (request *UntagResourcesRequest)
type UntagResourcesResponse
- func CreateUntagResourcesResponse() (response *UntagResourcesResponse)
type UpdateAllowedIpRequest
- func CreateUpdateAllowedIpRequest() (request *UpdateAllowedIpRequest)
type UpdateAllowedIpResponse
- func CreateUpdateAllowedIpResponse() (response *UpdateAllowedIpResponse)
type UpdateConsumerOffsetOffsets
type UpdateConsumerOffsetRequest
- func CreateUpdateConsumerOffsetRequest() (request *UpdateConsumerOffsetRequest)
type UpdateConsumerOffsetResponse
- func CreateUpdateConsumerOffsetResponse() (response *UpdateConsumerOffsetResponse)
type UpdateInstanceConfigRequest
- func CreateUpdateInstanceConfigRequest() (request *UpdateInstanceConfigRequest)
type UpdateInstanceConfigResponse
- func CreateUpdateInstanceConfigResponse() (response *UpdateInstanceConfigResponse)
type UpdateTopicConfigRequest
- func CreateUpdateTopicConfigRequest() (request *UpdateTopicConfigRequest)
type UpdateTopicConfigResponse
- func CreateUpdateTopicConfigResponse() (response *UpdateTopicConfigResponse)
type UpgradeInstanceVersionRequest
- func CreateUpgradeInstanceVersionRequest() (request *UpgradeInstanceVersionRequest)
type UpgradeInstanceVersionResponse
- func CreateUpgradeInstanceVersionResponse() (response *UpgradeInstanceVersionResponse)
type UpgradePostPayOrderRequest
- func CreateUpgradePostPayOrderRequest() (request *UpgradePostPayOrderRequest)
type UpgradePostPayOrderResponse
- func CreateUpgradePostPayOrderResponse() (response *UpgradePostPayOrderResponse)
type UpgradePostPayOrderServerlessConfig
type UpgradePrePayOrderConfluentConfig
type UpgradePrePayOrderRequest
- func CreateUpgradePrePayOrderRequest() (request *UpgradePrePayOrderRequest)
type UpgradePrePayOrderResponse
- func CreateUpgradePrePayOrderResponse() (response *UpgradePrePayOrderResponse)
type UpgradeServiceDetailInfo
type VpcList

Constants ¶

This section is empty.

Variables ¶

View Source

var EndpointMap map[string]string

EndpointMap Endpoint Data

View Source

var EndpointType = "regional"

EndpointType regional or central

Functions ¶

func GetEndpointMap ¶

func GetEndpointMap() map[string]string

GetEndpointMap Get Endpoint Data Map

func GetEndpointType ¶

func GetEndpointType() string

GetEndpointType Get Endpoint Type Value

func SetClientProperty ¶

func SetClientProperty(client *Client, propertyName string, propertyValue interface{})

SetClientProperty Set Property by Reflect

func SetEndpointDataToClient ¶

func SetEndpointDataToClient(client *Client)

SetEndpointDataToClient Set EndpointMap and ENdpointType

Types ¶

type AllowedIpListInGetAllowedIpList ¶ added in v1.61.349

type AllowedIpListInGetAllowedIpList struct {
	IPVO []string `json:"IPVO" xml:"IPVO"`
}

AllowedIpListInGetAllowedIpList is a nested struct in alikafka response

type AllowedList ¶ added in v1.61.349

type AllowedList struct {
	DeployType   int        `json:"DeployType" xml:"DeployType"`
	VpcList      []IPListVO `json:"VpcList" xml:"VpcList"`
	InternetList []IPListVO `json:"InternetList" xml:"InternetList"`
}

AllowedList is a nested struct in alikafka response

type ChangeResourceGroupRequest ¶ added in v1.61.1694

type ChangeResourceGroupRequest struct {
	*requests.RpcRequest
	ResourceId         string `position:"Query" name:"ResourceId"`
	NewResourceGroupId string `position:"Query" name:"NewResourceGroupId"`
}

ChangeResourceGroupRequest is the request struct for api ChangeResourceGroup

func CreateChangeResourceGroupRequest ¶ added in v1.61.1694

func CreateChangeResourceGroupRequest() (request *ChangeResourceGroupRequest)

CreateChangeResourceGroupRequest creates a request to invoke ChangeResourceGroup API

type ChangeResourceGroupResponse ¶ added in v1.61.1694

type ChangeResourceGroupResponse struct {
	*responses.BaseResponse
	Code               int    `json:"Code" xml:"Code"`
	Message            string `json:"Message" xml:"Message"`
	RequestId          string `json:"RequestId" xml:"RequestId"`
	Success            int64  `json:"Success" xml:"Success"`
	NewResourceGroupId string `json:"NewResourceGroupId" xml:"NewResourceGroupId"`
}

ChangeResourceGroupResponse is the response struct for api ChangeResourceGroup

func CreateChangeResourceGroupResponse ¶ added in v1.61.1694

func CreateChangeResourceGroupResponse() (response *ChangeResourceGroupResponse)

CreateChangeResourceGroupResponse creates a response to parse from ChangeResourceGroup response

type Client ¶

type Client struct {
	sdk.Client
}

Client is the sdk client struct, each func corresponds to an OpenAPI

func NewClient ¶

func NewClient() (client *Client, err error)

NewClient creates a sdk client with environment variables

func NewClientWithAccessKey ¶

func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)

NewClientWithAccessKey is a shortcut to create sdk client with accesskey usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithEcsRamRole ¶

func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)

NewClientWithEcsRamRole is a shortcut to create sdk client with ecs ram role usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithOptions ¶

func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)

NewClientWithOptions creates a sdk client with regionId/sdkConfig/credential this is the common api to create a sdk client

func NewClientWithProvider ¶

func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)

NewClientWithProvider creates a sdk client with providers usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRamRoleArn ¶

func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)

NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRamRoleArnAndPolicy ¶

func NewClientWithRamRoleArnAndPolicy(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName, policy string) (client *Client, err error)

NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn and policy usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithRsaKeyPair ¶

func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)

NewClientWithRsaKeyPair is a shortcut to create sdk client with rsa key pair usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func NewClientWithStsToken ¶

func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)

NewClientWithStsToken is a shortcut to create sdk client with sts token usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md

func (*Client) ChangeResourceGroup ¶ added in v1.61.1694

func (client *Client) ChangeResourceGroup(request *ChangeResourceGroupRequest) (response *ChangeResourceGroupResponse, err error)

ChangeResourceGroup invokes the alikafka.ChangeResourceGroup API synchronously

func (*Client) ChangeResourceGroupWithCallback ¶ added in v1.61.1694

func (client *Client) ChangeResourceGroupWithCallback(request *ChangeResourceGroupRequest, callback func(response *ChangeResourceGroupResponse, err error)) <-chan int

ChangeResourceGroupWithCallback invokes the alikafka.ChangeResourceGroup API asynchronously

func (*Client) ChangeResourceGroupWithChan ¶ added in v1.61.1694

func (client *Client) ChangeResourceGroupWithChan(request *ChangeResourceGroupRequest) (<-chan *ChangeResourceGroupResponse, <-chan error)

ChangeResourceGroupWithChan invokes the alikafka.ChangeResourceGroup API asynchronously

func (*Client) ConvertPostPayOrder ¶

func (client *Client) ConvertPostPayOrder(request *ConvertPostPayOrderRequest) (response *ConvertPostPayOrderResponse, err error)

ConvertPostPayOrder invokes the alikafka.ConvertPostPayOrder API synchronously

func (*Client) ConvertPostPayOrderWithCallback ¶

func (client *Client) ConvertPostPayOrderWithCallback(request *ConvertPostPayOrderRequest, callback func(response *ConvertPostPayOrderResponse, err error)) <-chan int

ConvertPostPayOrderWithCallback invokes the alikafka.ConvertPostPayOrder API asynchronously

func (*Client) ConvertPostPayOrderWithChan ¶

func (client *Client) ConvertPostPayOrderWithChan(request *ConvertPostPayOrderRequest) (<-chan *ConvertPostPayOrderResponse, <-chan error)

ConvertPostPayOrderWithChan invokes the alikafka.ConvertPostPayOrder API asynchronously

func (*Client) CreateAcl ¶ added in v1.60.294

func (client *Client) CreateAcl(request *CreateAclRequest) (response *CreateAclResponse, err error)

CreateAcl invokes the alikafka.CreateAcl API synchronously

func (*Client) CreateAclWithCallback ¶ added in v1.60.294

func (client *Client) CreateAclWithCallback(request *CreateAclRequest, callback func(response *CreateAclResponse, err error)) <-chan int

CreateAclWithCallback invokes the alikafka.CreateAcl API asynchronously

func (*Client) CreateAclWithChan ¶ added in v1.60.294

func (client *Client) CreateAclWithChan(request *CreateAclRequest) (<-chan *CreateAclResponse, <-chan error)

CreateAclWithChan invokes the alikafka.CreateAcl API asynchronously

func (*Client) CreateConsumerGroup ¶

func (client *Client) CreateConsumerGroup(request *CreateConsumerGroupRequest) (response *CreateConsumerGroupResponse, err error)

CreateConsumerGroup invokes the alikafka.CreateConsumerGroup API synchronously

func (*Client) CreateConsumerGroupWithCallback ¶

func (client *Client) CreateConsumerGroupWithCallback(request *CreateConsumerGroupRequest, callback func(response *CreateConsumerGroupResponse, err error)) <-chan int

CreateConsumerGroupWithCallback invokes the alikafka.CreateConsumerGroup API asynchronously

func (*Client) CreateConsumerGroupWithChan ¶

func (client *Client) CreateConsumerGroupWithChan(request *CreateConsumerGroupRequest) (<-chan *CreateConsumerGroupResponse, <-chan error)

CreateConsumerGroupWithChan invokes the alikafka.CreateConsumerGroup API asynchronously

func (*Client) CreatePostPayOrder ¶

func (client *Client) CreatePostPayOrder(request *CreatePostPayOrderRequest) (response *CreatePostPayOrderResponse, err error)

CreatePostPayOrder invokes the alikafka.CreatePostPayOrder API synchronously

func (*Client) CreatePostPayOrderWithCallback ¶

func (client *Client) CreatePostPayOrderWithCallback(request *CreatePostPayOrderRequest, callback func(response *CreatePostPayOrderResponse, err error)) <-chan int

CreatePostPayOrderWithCallback invokes the alikafka.CreatePostPayOrder API asynchronously

func (*Client) CreatePostPayOrderWithChan ¶

func (client *Client) CreatePostPayOrderWithChan(request *CreatePostPayOrderRequest) (<-chan *CreatePostPayOrderResponse, <-chan error)

CreatePostPayOrderWithChan invokes the alikafka.CreatePostPayOrder API asynchronously

func (*Client) CreatePrePayOrder ¶ added in v1.60.294

func (client *Client) CreatePrePayOrder(request *CreatePrePayOrderRequest) (response *CreatePrePayOrderResponse, err error)

CreatePrePayOrder invokes the alikafka.CreatePrePayOrder API synchronously

func (*Client) CreatePrePayOrderWithCallback ¶ added in v1.60.294

func (client *Client) CreatePrePayOrderWithCallback(request *CreatePrePayOrderRequest, callback func(response *CreatePrePayOrderResponse, err error)) <-chan int

CreatePrePayOrderWithCallback invokes the alikafka.CreatePrePayOrder API asynchronously

func (*Client) CreatePrePayOrderWithChan ¶ added in v1.60.294

func (client *Client) CreatePrePayOrderWithChan(request *CreatePrePayOrderRequest) (<-chan *CreatePrePayOrderResponse, <-chan error)

CreatePrePayOrderWithChan invokes the alikafka.CreatePrePayOrder API asynchronously

func (*Client) CreateSaslUser ¶ added in v1.60.294

func (client *Client) CreateSaslUser(request *CreateSaslUserRequest) (response *CreateSaslUserResponse, err error)

CreateSaslUser invokes the alikafka.CreateSaslUser API synchronously

func (*Client) CreateSaslUserWithCallback ¶ added in v1.60.294

func (client *Client) CreateSaslUserWithCallback(request *CreateSaslUserRequest, callback func(response *CreateSaslUserResponse, err error)) <-chan int

CreateSaslUserWithCallback invokes the alikafka.CreateSaslUser API asynchronously

func (*Client) CreateSaslUserWithChan ¶ added in v1.60.294

func (client *Client) CreateSaslUserWithChan(request *CreateSaslUserRequest) (<-chan *CreateSaslUserResponse, <-chan error)

CreateSaslUserWithChan invokes the alikafka.CreateSaslUser API asynchronously

func (*Client) CreateTopic ¶

func (client *Client) CreateTopic(request *CreateTopicRequest) (response *CreateTopicResponse, err error)

CreateTopic invokes the alikafka.CreateTopic API synchronously

func (*Client) CreateTopicWithCallback ¶

func (client *Client) CreateTopicWithCallback(request *CreateTopicRequest, callback func(response *CreateTopicResponse, err error)) <-chan int

CreateTopicWithCallback invokes the alikafka.CreateTopic API asynchronously

func (*Client) CreateTopicWithChan ¶

func (client *Client) CreateTopicWithChan(request *CreateTopicRequest) (<-chan *CreateTopicResponse, <-chan error)

CreateTopicWithChan invokes the alikafka.CreateTopic API asynchronously

func (*Client) DeleteAcl ¶ added in v1.60.294

func (client *Client) DeleteAcl(request *DeleteAclRequest) (response *DeleteAclResponse, err error)

DeleteAcl invokes the alikafka.DeleteAcl API synchronously

func (*Client) DeleteAclWithCallback ¶ added in v1.60.294

func (client *Client) DeleteAclWithCallback(request *DeleteAclRequest, callback func(response *DeleteAclResponse, err error)) <-chan int

DeleteAclWithCallback invokes the alikafka.DeleteAcl API asynchronously

func (*Client) DeleteAclWithChan ¶ added in v1.60.294

func (client *Client) DeleteAclWithChan(request *DeleteAclRequest) (<-chan *DeleteAclResponse, <-chan error)

DeleteAclWithChan invokes the alikafka.DeleteAcl API asynchronously

func (*Client) DeleteConsumerGroup ¶

func (client *Client) DeleteConsumerGroup(request *DeleteConsumerGroupRequest) (response *DeleteConsumerGroupResponse, err error)

DeleteConsumerGroup invokes the alikafka.DeleteConsumerGroup API synchronously

func (*Client) DeleteConsumerGroupWithCallback ¶

func (client *Client) DeleteConsumerGroupWithCallback(request *DeleteConsumerGroupRequest, callback func(response *DeleteConsumerGroupResponse, err error)) <-chan int

DeleteConsumerGroupWithCallback invokes the alikafka.DeleteConsumerGroup API asynchronously

func (*Client) DeleteConsumerGroupWithChan ¶

func (client *Client) DeleteConsumerGroupWithChan(request *DeleteConsumerGroupRequest) (<-chan *DeleteConsumerGroupResponse, <-chan error)

DeleteConsumerGroupWithChan invokes the alikafka.DeleteConsumerGroup API asynchronously

func (*Client) DeleteInstance ¶ added in v1.60.294

func (client *Client) DeleteInstance(request *DeleteInstanceRequest) (response *DeleteInstanceResponse, err error)

DeleteInstance invokes the alikafka.DeleteInstance API synchronously

func (*Client) DeleteInstanceWithCallback ¶ added in v1.60.294

func (client *Client) DeleteInstanceWithCallback(request *DeleteInstanceRequest, callback func(response *DeleteInstanceResponse, err error)) <-chan int

DeleteInstanceWithCallback invokes the alikafka.DeleteInstance API asynchronously

func (*Client) DeleteInstanceWithChan ¶ added in v1.60.294

func (client *Client) DeleteInstanceWithChan(request *DeleteInstanceRequest) (<-chan *DeleteInstanceResponse, <-chan error)

DeleteInstanceWithChan invokes the alikafka.DeleteInstance API asynchronously

func (*Client) DeleteSaslUser ¶ added in v1.60.294

func (client *Client) DeleteSaslUser(request *DeleteSaslUserRequest) (response *DeleteSaslUserResponse, err error)

DeleteSaslUser invokes the alikafka.DeleteSaslUser API synchronously

func (*Client) DeleteSaslUserWithCallback ¶ added in v1.60.294

func (client *Client) DeleteSaslUserWithCallback(request *DeleteSaslUserRequest, callback func(response *DeleteSaslUserResponse, err error)) <-chan int

DeleteSaslUserWithCallback invokes the alikafka.DeleteSaslUser API asynchronously

func (*Client) DeleteSaslUserWithChan ¶ added in v1.60.294

func (client *Client) DeleteSaslUserWithChan(request *DeleteSaslUserRequest) (<-chan *DeleteSaslUserResponse, <-chan error)

DeleteSaslUserWithChan invokes the alikafka.DeleteSaslUser API asynchronously

func (*Client) DeleteTopic ¶

func (client *Client) DeleteTopic(request *DeleteTopicRequest) (response *DeleteTopicResponse, err error)

DeleteTopic invokes the alikafka.DeleteTopic API synchronously

func (*Client) DeleteTopicWithCallback ¶

func (client *Client) DeleteTopicWithCallback(request *DeleteTopicRequest, callback func(response *DeleteTopicResponse, err error)) <-chan int

DeleteTopicWithCallback invokes the alikafka.DeleteTopic API asynchronously

func (*Client) DeleteTopicWithChan ¶

func (client *Client) DeleteTopicWithChan(request *DeleteTopicRequest) (<-chan *DeleteTopicResponse, <-chan error)

DeleteTopicWithChan invokes the alikafka.DeleteTopic API asynchronously

func (*Client) DescribeAcls ¶ added in v1.60.294

func (client *Client) DescribeAcls(request *DescribeAclsRequest) (response *DescribeAclsResponse, err error)

DescribeAcls invokes the alikafka.DescribeAcls API synchronously

func (*Client) DescribeAclsWithCallback ¶ added in v1.60.294

func (client *Client) DescribeAclsWithCallback(request *DescribeAclsRequest, callback func(response *DescribeAclsResponse, err error)) <-chan int

DescribeAclsWithCallback invokes the alikafka.DescribeAcls API asynchronously

func (*Client) DescribeAclsWithChan ¶ added in v1.60.294

func (client *Client) DescribeAclsWithChan(request *DescribeAclsRequest) (<-chan *DescribeAclsResponse, <-chan error)

DescribeAclsWithChan invokes the alikafka.DescribeAcls API asynchronously

func (*Client) DescribeSaslUsers ¶ added in v1.60.294

func (client *Client) DescribeSaslUsers(request *DescribeSaslUsersRequest) (response *DescribeSaslUsersResponse, err error)

DescribeSaslUsers invokes the alikafka.DescribeSaslUsers API synchronously

func (*Client) DescribeSaslUsersWithCallback ¶ added in v1.60.294

func (client *Client) DescribeSaslUsersWithCallback(request *DescribeSaslUsersRequest, callback func(response *DescribeSaslUsersResponse, err error)) <-chan int

DescribeSaslUsersWithCallback invokes the alikafka.DescribeSaslUsers API asynchronously

func (*Client) DescribeSaslUsersWithChan ¶ added in v1.60.294

func (client *Client) DescribeSaslUsersWithChan(request *DescribeSaslUsersRequest) (<-chan *DescribeSaslUsersResponse, <-chan error)

DescribeSaslUsersWithChan invokes the alikafka.DescribeSaslUsers API asynchronously

func (*Client) EnableAutoGroupCreation ¶ added in v1.62.711

func (client *Client) EnableAutoGroupCreation(request *EnableAutoGroupCreationRequest) (response *EnableAutoGroupCreationResponse, err error)

EnableAutoGroupCreation invokes the alikafka.EnableAutoGroupCreation API synchronously

func (*Client) EnableAutoGroupCreationWithCallback ¶ added in v1.62.711

func (client *Client) EnableAutoGroupCreationWithCallback(request *EnableAutoGroupCreationRequest, callback func(response *EnableAutoGroupCreationResponse, err error)) <-chan int

EnableAutoGroupCreationWithCallback invokes the alikafka.EnableAutoGroupCreation API asynchronously

func (*Client) EnableAutoGroupCreationWithChan ¶ added in v1.62.711

func (client *Client) EnableAutoGroupCreationWithChan(request *EnableAutoGroupCreationRequest) (<-chan *EnableAutoGroupCreationResponse, <-chan error)

EnableAutoGroupCreationWithChan invokes the alikafka.EnableAutoGroupCreation API asynchronously

func (*Client) EnableAutoTopicCreation ¶ added in v1.62.711

func (client *Client) EnableAutoTopicCreation(request *EnableAutoTopicCreationRequest) (response *EnableAutoTopicCreationResponse, err error)

EnableAutoTopicCreation invokes the alikafka.EnableAutoTopicCreation API synchronously

func (*Client) EnableAutoTopicCreationWithCallback ¶ added in v1.62.711

func (client *Client) EnableAutoTopicCreationWithCallback(request *EnableAutoTopicCreationRequest, callback func(response *EnableAutoTopicCreationResponse, err error)) <-chan int

EnableAutoTopicCreationWithCallback invokes the alikafka.EnableAutoTopicCreation API asynchronously

func (*Client) EnableAutoTopicCreationWithChan ¶ added in v1.62.711

func (client *Client) EnableAutoTopicCreationWithChan(request *EnableAutoTopicCreationRequest) (<-chan *EnableAutoTopicCreationResponse, <-chan error)

EnableAutoTopicCreationWithChan invokes the alikafka.EnableAutoTopicCreation API asynchronously

func (*Client) GetAllInstanceIdList ¶ added in v1.61.1694

func (client *Client) GetAllInstanceIdList(request *GetAllInstanceIdListRequest) (response *GetAllInstanceIdListResponse, err error)

GetAllInstanceIdList invokes the alikafka.GetAllInstanceIdList API synchronously

func (*Client) GetAllInstanceIdListWithCallback ¶ added in v1.61.1694

func (client *Client) GetAllInstanceIdListWithCallback(request *GetAllInstanceIdListRequest, callback func(response *GetAllInstanceIdListResponse, err error)) <-chan int

GetAllInstanceIdListWithCallback invokes the alikafka.GetAllInstanceIdList API asynchronously

func (*Client) GetAllInstanceIdListWithChan ¶ added in v1.61.1694

func (client *Client) GetAllInstanceIdListWithChan(request *GetAllInstanceIdListRequest) (<-chan *GetAllInstanceIdListResponse, <-chan error)

GetAllInstanceIdListWithChan invokes the alikafka.GetAllInstanceIdList API asynchronously

func (*Client) GetAllowedIpList ¶ added in v1.61.349

func (client *Client) GetAllowedIpList(request *GetAllowedIpListRequest) (response *GetAllowedIpListResponse, err error)

GetAllowedIpList invokes the alikafka.GetAllowedIpList API synchronously

func (*Client) GetAllowedIpListWithCallback ¶ added in v1.61.349

func (client *Client) GetAllowedIpListWithCallback(request *GetAllowedIpListRequest, callback func(response *GetAllowedIpListResponse, err error)) <-chan int

GetAllowedIpListWithCallback invokes the alikafka.GetAllowedIpList API asynchronously

func (*Client) GetAllowedIpListWithChan ¶ added in v1.61.349

func (client *Client) GetAllowedIpListWithChan(request *GetAllowedIpListRequest) (<-chan *GetAllowedIpListResponse, <-chan error)

GetAllowedIpListWithChan invokes the alikafka.GetAllowedIpList API asynchronously

func (*Client) GetConsumerList ¶

func (client *Client) GetConsumerList(request *GetConsumerListRequest) (response *GetConsumerListResponse, err error)

GetConsumerList invokes the alikafka.GetConsumerList API synchronously

func (*Client) GetConsumerListWithCallback ¶

func (client *Client) GetConsumerListWithCallback(request *GetConsumerListRequest, callback func(response *GetConsumerListResponse, err error)) <-chan int

GetConsumerListWithCallback invokes the alikafka.GetConsumerList API asynchronously

func (*Client) GetConsumerListWithChan ¶

func (client *Client) GetConsumerListWithChan(request *GetConsumerListRequest) (<-chan *GetConsumerListResponse, <-chan error)

GetConsumerListWithChan invokes the alikafka.GetConsumerList API asynchronously

func (*Client) GetConsumerProgress ¶

func (client *Client) GetConsumerProgress(request *GetConsumerProgressRequest) (response *GetConsumerProgressResponse, err error)

GetConsumerProgress invokes the alikafka.GetConsumerProgress API synchronously

func (*Client) GetConsumerProgressWithCallback ¶

func (client *Client) GetConsumerProgressWithCallback(request *GetConsumerProgressRequest, callback func(response *GetConsumerProgressResponse, err error)) <-chan int

GetConsumerProgressWithCallback invokes the alikafka.GetConsumerProgress API asynchronously

func (*Client) GetConsumerProgressWithChan ¶

func (client *Client) GetConsumerProgressWithChan(request *GetConsumerProgressRequest) (<-chan *GetConsumerProgressResponse, <-chan error)

GetConsumerProgressWithChan invokes the alikafka.GetConsumerProgress API asynchronously

func (*Client) GetInstanceList ¶

func (client *Client) GetInstanceList(request *GetInstanceListRequest) (response *GetInstanceListResponse, err error)

GetInstanceList invokes the alikafka.GetInstanceList API synchronously

func (*Client) GetInstanceListWithCallback ¶

func (client *Client) GetInstanceListWithCallback(request *GetInstanceListRequest, callback func(response *GetInstanceListResponse, err error)) <-chan int

GetInstanceListWithCallback invokes the alikafka.GetInstanceList API asynchronously

func (*Client) GetInstanceListWithChan ¶

func (client *Client) GetInstanceListWithChan(request *GetInstanceListRequest) (<-chan *GetInstanceListResponse, <-chan error)

GetInstanceListWithChan invokes the alikafka.GetInstanceList API asynchronously

func (*Client) GetQuotaTip ¶ added in v1.62.80

func (client *Client) GetQuotaTip(request *GetQuotaTipRequest) (response *GetQuotaTipResponse, err error)

GetQuotaTip invokes the alikafka.GetQuotaTip API synchronously

func (*Client) GetQuotaTipWithCallback ¶ added in v1.62.80

func (client *Client) GetQuotaTipWithCallback(request *GetQuotaTipRequest, callback func(response *GetQuotaTipResponse, err error)) <-chan int

GetQuotaTipWithCallback invokes the alikafka.GetQuotaTip API asynchronously

func (*Client) GetQuotaTipWithChan ¶ added in v1.62.80

func (client *Client) GetQuotaTipWithChan(request *GetQuotaTipRequest) (<-chan *GetQuotaTipResponse, <-chan error)

GetQuotaTipWithChan invokes the alikafka.GetQuotaTip API asynchronously

func (*Client) GetTopicList ¶

func (client *Client) GetTopicList(request *GetTopicListRequest) (response *GetTopicListResponse, err error)

GetTopicList invokes the alikafka.GetTopicList API synchronously

func (*Client) GetTopicListWithCallback ¶

func (client *Client) GetTopicListWithCallback(request *GetTopicListRequest, callback func(response *GetTopicListResponse, err error)) <-chan int

GetTopicListWithCallback invokes the alikafka.GetTopicList API asynchronously

func (*Client) GetTopicListWithChan ¶

func (client *Client) GetTopicListWithChan(request *GetTopicListRequest) (<-chan *GetTopicListResponse, <-chan error)

GetTopicListWithChan invokes the alikafka.GetTopicList API asynchronously

func (*Client) GetTopicStatus ¶

func (client *Client) GetTopicStatus(request *GetTopicStatusRequest) (response *GetTopicStatusResponse, err error)

GetTopicStatus invokes the alikafka.GetTopicStatus API synchronously

func (*Client) GetTopicStatusWithCallback ¶

func (client *Client) GetTopicStatusWithCallback(request *GetTopicStatusRequest, callback func(response *GetTopicStatusResponse, err error)) <-chan int

GetTopicStatusWithCallback invokes the alikafka.GetTopicStatus API asynchronously

func (*Client) GetTopicStatusWithChan ¶

func (client *Client) GetTopicStatusWithChan(request *GetTopicStatusRequest) (<-chan *GetTopicStatusResponse, <-chan error)

GetTopicStatusWithChan invokes the alikafka.GetTopicStatus API asynchronously

func (*Client) GetTopicSubscribeStatus ¶ added in v1.62.711

func (client *Client) GetTopicSubscribeStatus(request *GetTopicSubscribeStatusRequest) (response *GetTopicSubscribeStatusResponse, err error)

GetTopicSubscribeStatus invokes the alikafka.GetTopicSubscribeStatus API synchronously

func (*Client) GetTopicSubscribeStatusWithCallback ¶ added in v1.62.711

func (client *Client) GetTopicSubscribeStatusWithCallback(request *GetTopicSubscribeStatusRequest, callback func(response *GetTopicSubscribeStatusResponse, err error)) <-chan int

GetTopicSubscribeStatusWithCallback invokes the alikafka.GetTopicSubscribeStatus API asynchronously

func (*Client) GetTopicSubscribeStatusWithChan ¶ added in v1.62.711

func (client *Client) GetTopicSubscribeStatusWithChan(request *GetTopicSubscribeStatusRequest) (<-chan *GetTopicSubscribeStatusResponse, <-chan error)

GetTopicSubscribeStatusWithChan invokes the alikafka.GetTopicSubscribeStatus API asynchronously

func (*Client) ListTagResources ¶

func (client *Client) ListTagResources(request *ListTagResourcesRequest) (response *ListTagResourcesResponse, err error)

ListTagResources invokes the alikafka.ListTagResources API synchronously

func (*Client) ListTagResourcesWithCallback ¶

func (client *Client) ListTagResourcesWithCallback(request *ListTagResourcesRequest, callback func(response *ListTagResourcesResponse, err error)) <-chan int

ListTagResourcesWithCallback invokes the alikafka.ListTagResources API asynchronously

func (*Client) ListTagResourcesWithChan ¶

func (client *Client) ListTagResourcesWithChan(request *ListTagResourcesRequest) (<-chan *ListTagResourcesResponse, <-chan error)

ListTagResourcesWithChan invokes the alikafka.ListTagResources API asynchronously

func (*Client) ModifyInstanceName ¶

func (client *Client) ModifyInstanceName(request *ModifyInstanceNameRequest) (response *ModifyInstanceNameResponse, err error)

ModifyInstanceName invokes the alikafka.ModifyInstanceName API synchronously

func (*Client) ModifyInstanceNameWithCallback ¶

func (client *Client) ModifyInstanceNameWithCallback(request *ModifyInstanceNameRequest, callback func(response *ModifyInstanceNameResponse, err error)) <-chan int

ModifyInstanceNameWithCallback invokes the alikafka.ModifyInstanceName API asynchronously

func (*Client) ModifyInstanceNameWithChan ¶

func (client *Client) ModifyInstanceNameWithChan(request *ModifyInstanceNameRequest) (<-chan *ModifyInstanceNameResponse, <-chan error)

ModifyInstanceNameWithChan invokes the alikafka.ModifyInstanceName API asynchronously

func (*Client) ModifyPartitionNum ¶ added in v1.60.334

func (client *Client) ModifyPartitionNum(request *ModifyPartitionNumRequest) (response *ModifyPartitionNumResponse, err error)

ModifyPartitionNum invokes the alikafka.ModifyPartitionNum API synchronously

func (*Client) ModifyPartitionNumWithCallback ¶ added in v1.60.334

func (client *Client) ModifyPartitionNumWithCallback(request *ModifyPartitionNumRequest, callback func(response *ModifyPartitionNumResponse, err error)) <-chan int

ModifyPartitionNumWithCallback invokes the alikafka.ModifyPartitionNum API asynchronously

func (*Client) ModifyPartitionNumWithChan ¶ added in v1.60.334

func (client *Client) ModifyPartitionNumWithChan(request *ModifyPartitionNumRequest) (<-chan *ModifyPartitionNumResponse, <-chan error)

ModifyPartitionNumWithChan invokes the alikafka.ModifyPartitionNum API asynchronously

func (*Client) ModifyTopicRemark ¶ added in v1.60.334

func (client *Client) ModifyTopicRemark(request *ModifyTopicRemarkRequest) (response *ModifyTopicRemarkResponse, err error)

ModifyTopicRemark invokes the alikafka.ModifyTopicRemark API synchronously

func (*Client) ModifyTopicRemarkWithCallback ¶ added in v1.60.334

func (client *Client) ModifyTopicRemarkWithCallback(request *ModifyTopicRemarkRequest, callback func(response *ModifyTopicRemarkResponse, err error)) <-chan int

ModifyTopicRemarkWithCallback invokes the alikafka.ModifyTopicRemark API asynchronously

func (*Client) ModifyTopicRemarkWithChan ¶ added in v1.60.334

func (client *Client) ModifyTopicRemarkWithChan(request *ModifyTopicRemarkRequest) (<-chan *ModifyTopicRemarkResponse, <-chan error)

ModifyTopicRemarkWithChan invokes the alikafka.ModifyTopicRemark API asynchronously

func (*Client) QueryMessage ¶ added in v1.62.711

func (client *Client) QueryMessage(request *QueryMessageRequest) (response *QueryMessageResponse, err error)

QueryMessage invokes the alikafka.QueryMessage API synchronously

func (*Client) QueryMessageWithCallback ¶ added in v1.62.711

func (client *Client) QueryMessageWithCallback(request *QueryMessageRequest, callback func(response *QueryMessageResponse, err error)) <-chan int

QueryMessageWithCallback invokes the alikafka.QueryMessage API asynchronously

func (*Client) QueryMessageWithChan ¶ added in v1.62.711

func (client *Client) QueryMessageWithChan(request *QueryMessageRequest) (<-chan *QueryMessageResponse, <-chan error)

QueryMessageWithChan invokes the alikafka.QueryMessage API asynchronously

func (*Client) ReleaseInstance ¶

func (client *Client) ReleaseInstance(request *ReleaseInstanceRequest) (response *ReleaseInstanceResponse, err error)

ReleaseInstance invokes the alikafka.ReleaseInstance API synchronously

func (*Client) ReleaseInstanceWithCallback ¶

func (client *Client) ReleaseInstanceWithCallback(request *ReleaseInstanceRequest, callback func(response *ReleaseInstanceResponse, err error)) <-chan int

ReleaseInstanceWithCallback invokes the alikafka.ReleaseInstance API asynchronously

func (*Client) ReleaseInstanceWithChan ¶

func (client *Client) ReleaseInstanceWithChan(request *ReleaseInstanceRequest) (<-chan *ReleaseInstanceResponse, <-chan error)

ReleaseInstanceWithChan invokes the alikafka.ReleaseInstance API asynchronously

func (*Client) ReopenInstance ¶ added in v1.62.711

func (client *Client) ReopenInstance(request *ReopenInstanceRequest) (response *ReopenInstanceResponse, err error)

ReopenInstance invokes the alikafka.ReopenInstance API synchronously

func (*Client) ReopenInstanceWithCallback ¶ added in v1.62.711

func (client *Client) ReopenInstanceWithCallback(request *ReopenInstanceRequest, callback func(response *ReopenInstanceResponse, err error)) <-chan int

ReopenInstanceWithCallback invokes the alikafka.ReopenInstance API asynchronously

func (*Client) ReopenInstanceWithChan ¶ added in v1.62.711

func (client *Client) ReopenInstanceWithChan(request *ReopenInstanceRequest) (<-chan *ReopenInstanceResponse, <-chan error)

ReopenInstanceWithChan invokes the alikafka.ReopenInstance API asynchronously

func (*Client) StartInstance ¶

func (client *Client) StartInstance(request *StartInstanceRequest) (response *StartInstanceResponse, err error)

StartInstance invokes the alikafka.StartInstance API synchronously

func (*Client) StartInstanceWithCallback ¶

func (client *Client) StartInstanceWithCallback(request *StartInstanceRequest, callback func(response *StartInstanceResponse, err error)) <-chan int

StartInstanceWithCallback invokes the alikafka.StartInstance API asynchronously

func (*Client) StartInstanceWithChan ¶

func (client *Client) StartInstanceWithChan(request *StartInstanceRequest) (<-chan *StartInstanceResponse, <-chan error)

StartInstanceWithChan invokes the alikafka.StartInstance API asynchronously

func (*Client) StopInstance ¶ added in v1.62.711

func (client *Client) StopInstance(request *StopInstanceRequest) (response *StopInstanceResponse, err error)

StopInstance invokes the alikafka.StopInstance API synchronously

func (*Client) StopInstanceWithCallback ¶ added in v1.62.711

func (client *Client) StopInstanceWithCallback(request *StopInstanceRequest, callback func(response *StopInstanceResponse, err error)) <-chan int

StopInstanceWithCallback invokes the alikafka.StopInstance API asynchronously

func (*Client) StopInstanceWithChan ¶ added in v1.62.711

func (client *Client) StopInstanceWithChan(request *StopInstanceRequest) (<-chan *StopInstanceResponse, <-chan error)

StopInstanceWithChan invokes the alikafka.StopInstance API asynchronously

func (*Client) TagResources ¶

func (client *Client) TagResources(request *TagResourcesRequest) (response *TagResourcesResponse, err error)

TagResources invokes the alikafka.TagResources API synchronously

func (*Client) TagResourcesWithCallback ¶

func (client *Client) TagResourcesWithCallback(request *TagResourcesRequest, callback func(response *TagResourcesResponse, err error)) <-chan int

TagResourcesWithCallback invokes the alikafka.TagResources API asynchronously

func (*Client) TagResourcesWithChan ¶

func (client *Client) TagResourcesWithChan(request *TagResourcesRequest) (<-chan *TagResourcesResponse, <-chan error)

TagResourcesWithChan invokes the alikafka.TagResources API asynchronously

func (*Client) UntagResources ¶

func (client *Client) UntagResources(request *UntagResourcesRequest) (response *UntagResourcesResponse, err error)

UntagResources invokes the alikafka.UntagResources API synchronously

func (*Client) UntagResourcesWithCallback ¶

func (client *Client) UntagResourcesWithCallback(request *UntagResourcesRequest, callback func(response *UntagResourcesResponse, err error)) <-chan int

UntagResourcesWithCallback invokes the alikafka.UntagResources API asynchronously

func (*Client) UntagResourcesWithChan ¶

func (client *Client) UntagResourcesWithChan(request *UntagResourcesRequest) (<-chan *UntagResourcesResponse, <-chan error)

UntagResourcesWithChan invokes the alikafka.UntagResources API asynchronously

func (*Client) UpdateAllowedIp ¶ added in v1.61.349

func (client *Client) UpdateAllowedIp(request *UpdateAllowedIpRequest) (response *UpdateAllowedIpResponse, err error)

UpdateAllowedIp invokes the alikafka.UpdateAllowedIp API synchronously

func (*Client) UpdateAllowedIpWithCallback ¶ added in v1.61.349

func (client *Client) UpdateAllowedIpWithCallback(request *UpdateAllowedIpRequest, callback func(response *UpdateAllowedIpResponse, err error)) <-chan int

UpdateAllowedIpWithCallback invokes the alikafka.UpdateAllowedIp API asynchronously

func (*Client) UpdateAllowedIpWithChan ¶ added in v1.61.349

func (client *Client) UpdateAllowedIpWithChan(request *UpdateAllowedIpRequest) (<-chan *UpdateAllowedIpResponse, <-chan error)

UpdateAllowedIpWithChan invokes the alikafka.UpdateAllowedIp API asynchronously

func (*Client) UpdateConsumerOffset ¶ added in v1.62.293

func (client *Client) UpdateConsumerOffset(request *UpdateConsumerOffsetRequest) (response *UpdateConsumerOffsetResponse, err error)

UpdateConsumerOffset invokes the alikafka.UpdateConsumerOffset API synchronously

func (*Client) UpdateConsumerOffsetWithCallback ¶ added in v1.62.293

func (client *Client) UpdateConsumerOffsetWithCallback(request *UpdateConsumerOffsetRequest, callback func(response *UpdateConsumerOffsetResponse, err error)) <-chan int

UpdateConsumerOffsetWithCallback invokes the alikafka.UpdateConsumerOffset API asynchronously

func (*Client) UpdateConsumerOffsetWithChan ¶ added in v1.62.293

func (client *Client) UpdateConsumerOffsetWithChan(request *UpdateConsumerOffsetRequest) (<-chan *UpdateConsumerOffsetResponse, <-chan error)

UpdateConsumerOffsetWithChan invokes the alikafka.UpdateConsumerOffset API asynchronously

func (*Client) UpdateInstanceConfig ¶ added in v1.61.815

func (client *Client) UpdateInstanceConfig(request *UpdateInstanceConfigRequest) (response *UpdateInstanceConfigResponse, err error)

UpdateInstanceConfig invokes the alikafka.UpdateInstanceConfig API synchronously

func (*Client) UpdateInstanceConfigWithCallback ¶ added in v1.61.815

func (client *Client) UpdateInstanceConfigWithCallback(request *UpdateInstanceConfigRequest, callback func(response *UpdateInstanceConfigResponse, err error)) <-chan int

UpdateInstanceConfigWithCallback invokes the alikafka.UpdateInstanceConfig API asynchronously

func (*Client) UpdateInstanceConfigWithChan ¶ added in v1.61.815

func (client *Client) UpdateInstanceConfigWithChan(request *UpdateInstanceConfigRequest) (<-chan *UpdateInstanceConfigResponse, <-chan error)

UpdateInstanceConfigWithChan invokes the alikafka.UpdateInstanceConfig API asynchronously

func (*Client) UpdateTopicConfig ¶ added in v1.62.711

func (client *Client) UpdateTopicConfig(request *UpdateTopicConfigRequest) (response *UpdateTopicConfigResponse, err error)

UpdateTopicConfig invokes the alikafka.UpdateTopicConfig API synchronously

func (*Client) UpdateTopicConfigWithCallback ¶ added in v1.62.711

func (client *Client) UpdateTopicConfigWithCallback(request *UpdateTopicConfigRequest, callback func(response *UpdateTopicConfigResponse, err error)) <-chan int

UpdateTopicConfigWithCallback invokes the alikafka.UpdateTopicConfig API asynchronously

func (*Client) UpdateTopicConfigWithChan ¶ added in v1.62.711

func (client *Client) UpdateTopicConfigWithChan(request *UpdateTopicConfigRequest) (<-chan *UpdateTopicConfigResponse, <-chan error)

UpdateTopicConfigWithChan invokes the alikafka.UpdateTopicConfig API asynchronously

func (*Client) UpgradeInstanceVersion ¶ added in v1.61.815

func (client *Client) UpgradeInstanceVersion(request *UpgradeInstanceVersionRequest) (response *UpgradeInstanceVersionResponse, err error)

UpgradeInstanceVersion invokes the alikafka.UpgradeInstanceVersion API synchronously

func (*Client) UpgradeInstanceVersionWithCallback ¶ added in v1.61.815

func (client *Client) UpgradeInstanceVersionWithCallback(request *UpgradeInstanceVersionRequest, callback func(response *UpgradeInstanceVersionResponse, err error)) <-chan int

UpgradeInstanceVersionWithCallback invokes the alikafka.UpgradeInstanceVersion API asynchronously

func (*Client) UpgradeInstanceVersionWithChan ¶ added in v1.61.815

func (client *Client) UpgradeInstanceVersionWithChan(request *UpgradeInstanceVersionRequest) (<-chan *UpgradeInstanceVersionResponse, <-chan error)

UpgradeInstanceVersionWithChan invokes the alikafka.UpgradeInstanceVersion API asynchronously

func (*Client) UpgradePostPayOrder ¶

func (client *Client) UpgradePostPayOrder(request *UpgradePostPayOrderRequest) (response *UpgradePostPayOrderResponse, err error)

UpgradePostPayOrder invokes the alikafka.UpgradePostPayOrder API synchronously

func (*Client) UpgradePostPayOrderWithCallback ¶

func (client *Client) UpgradePostPayOrderWithCallback(request *UpgradePostPayOrderRequest, callback func(response *UpgradePostPayOrderResponse, err error)) <-chan int

UpgradePostPayOrderWithCallback invokes the alikafka.UpgradePostPayOrder API asynchronously

func (*Client) UpgradePostPayOrderWithChan ¶

func (client *Client) UpgradePostPayOrderWithChan(request *UpgradePostPayOrderRequest) (<-chan *UpgradePostPayOrderResponse, <-chan error)

UpgradePostPayOrderWithChan invokes the alikafka.UpgradePostPayOrder API asynchronously

func (*Client) UpgradePrePayOrder ¶ added in v1.60.294

func (client *Client) UpgradePrePayOrder(request *UpgradePrePayOrderRequest) (response *UpgradePrePayOrderResponse, err error)

UpgradePrePayOrder invokes the alikafka.UpgradePrePayOrder API synchronously

func (*Client) UpgradePrePayOrderWithCallback ¶ added in v1.60.294

func (client *Client) UpgradePrePayOrderWithCallback(request *UpgradePrePayOrderRequest, callback func(response *UpgradePrePayOrderResponse, err error)) <-chan int

UpgradePrePayOrderWithCallback invokes the alikafka.UpgradePrePayOrder API asynchronously

func (*Client) UpgradePrePayOrderWithChan ¶ added in v1.60.294

func (client *Client) UpgradePrePayOrderWithChan(request *UpgradePrePayOrderRequest) (<-chan *UpgradePrePayOrderResponse, <-chan error)

UpgradePrePayOrderWithChan invokes the alikafka.UpgradePrePayOrder API asynchronously

type ConfluentConfig ¶ added in v1.62.711

type ConfluentConfig struct {
	KafkaCU               int `json:"KafkaCU" xml:"KafkaCU"`
	KafkaStorage          int `json:"KafkaStorage" xml:"KafkaStorage"`
	KafkaReplica          int `json:"KafkaReplica" xml:"KafkaReplica"`
	ZooKeeperCU           int `json:"ZooKeeperCU" xml:"ZooKeeperCU"`
	ZooKeeperStorage      int `json:"ZooKeeperStorage" xml:"ZooKeeperStorage"`
	ZooKeeperReplica      int `json:"ZooKeeperReplica" xml:"ZooKeeperReplica"`
	ControlCenterCU       int `json:"ControlCenterCU" xml:"ControlCenterCU"`
	ControlCenterStorage  int `json:"ControlCenterStorage" xml:"ControlCenterStorage"`
	ControlCenterReplica  int `json:"ControlCenterReplica" xml:"ControlCenterReplica"`
	SchemaRegistryCU      int `json:"SchemaRegistryCU" xml:"SchemaRegistryCU"`
	SchemaRegistryReplica int `json:"SchemaRegistryReplica" xml:"SchemaRegistryReplica"`
	ConnectCU             int `json:"ConnectCU" xml:"ConnectCU"`
	ConnectReplica        int `json:"ConnectReplica" xml:"ConnectReplica"`
	KsqlCU                int `json:"KsqlCU" xml:"KsqlCU"`
	KsqlStorage           int `json:"KsqlStorage" xml:"KsqlStorage"`
	KsqlReplica           int `json:"KsqlReplica" xml:"KsqlReplica"`
	KafkaRestProxyCU      int `json:"KafkaRestProxyCU" xml:"KafkaRestProxyCU"`
	KafkaRestProxyReplica int `json:"KafkaRestProxyReplica" xml:"KafkaRestProxyReplica"`
}

ConfluentConfig is a nested struct in alikafka response

type ConsumerGroups ¶ added in v1.62.711

type ConsumerGroups struct {
	ConsumerGroups []string `json:"ConsumerGroups" xml:"ConsumerGroups"`
}

ConsumerGroups is a nested struct in alikafka response

type ConsumerList ¶

type ConsumerList struct {
	ConsumerVO []ConsumerVO `json:"ConsumerVO" xml:"ConsumerVO"`
}

ConsumerList is a nested struct in alikafka response

type ConsumerProgress ¶

type ConsumerProgress struct {
	LastTimestamp     int64                          `json:"LastTimestamp" xml:"LastTimestamp"`
	TotalDiff         int64                          `json:"TotalDiff" xml:"TotalDiff"`
	TopicList         TopicListInGetConsumerProgress `json:"TopicList" xml:"TopicList"`
	RebalanceInfoList RebalanceInfoList              `json:"RebalanceInfoList" xml:"RebalanceInfoList"`
}

ConsumerProgress is a nested struct in alikafka response

type ConsumerVO ¶

type ConsumerVO struct {
	ConsumerId                string                `json:"ConsumerId" xml:"ConsumerId"`
	InstanceId                string                `json:"InstanceId" xml:"InstanceId"`
	Remark                    string                `json:"Remark" xml:"Remark"`
	RegionId                  string                `json:"RegionId" xml:"RegionId"`
	AutomaticallyCreatedGroup bool                  `json:"AutomaticallyCreatedGroup" xml:"AutomaticallyCreatedGroup"`
	Tags                      TagsInGetConsumerList `json:"Tags" xml:"Tags"`
}

ConsumerVO is a nested struct in alikafka response

type ConvertPostPayOrderRequest ¶

type ConvertPostPayOrderRequest struct {
	*requests.RpcRequest
	Duration   requests.Integer `position:"Query" name:"Duration"`
	InstanceId string           `position:"Query" name:"InstanceId"`
}

ConvertPostPayOrderRequest is the request struct for api ConvertPostPayOrder

func CreateConvertPostPayOrderRequest ¶

func CreateConvertPostPayOrderRequest() (request *ConvertPostPayOrderRequest)

CreateConvertPostPayOrderRequest creates a request to invoke ConvertPostPayOrder API

type ConvertPostPayOrderResponse ¶

type ConvertPostPayOrderResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	OrderId   string `json:"OrderId" xml:"OrderId"`
}

ConvertPostPayOrderResponse is the response struct for api ConvertPostPayOrder

func CreateConvertPostPayOrderResponse ¶

func CreateConvertPostPayOrderResponse() (response *ConvertPostPayOrderResponse)

CreateConvertPostPayOrderResponse creates a response to parse from ConvertPostPayOrder response

type CreateAclRequest ¶ added in v1.60.294

type CreateAclRequest struct {
	*requests.RpcRequest
	AclResourcePatternType string `position:"Query" name:"AclResourcePatternType"`
	AclResourceType        string `position:"Query" name:"AclResourceType"`
	AclOperationTypes      string `position:"Query" name:"AclOperationTypes"`
	AclOperationType       string `position:"Query" name:"AclOperationType"`
	AclResourceName        string `position:"Query" name:"AclResourceName"`
	InstanceId             string `position:"Query" name:"InstanceId"`
	Host                   string `position:"Query" name:"Host"`
	AclPermissionType      string `position:"Query" name:"AclPermissionType"`
	Username               string `position:"Query" name:"Username"`
}

CreateAclRequest is the request struct for api CreateAcl

func CreateCreateAclRequest ¶ added in v1.60.294

func CreateCreateAclRequest() (request *CreateAclRequest)

CreateCreateAclRequest creates a request to invoke CreateAcl API

type CreateAclResponse ¶ added in v1.60.294

type CreateAclResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

CreateAclResponse is the response struct for api CreateAcl

func CreateCreateAclResponse ¶ added in v1.60.294

func CreateCreateAclResponse() (response *CreateAclResponse)

CreateCreateAclResponse creates a response to parse from CreateAcl response

type CreateConsumerGroupRequest ¶

type CreateConsumerGroupRequest struct {
	*requests.RpcRequest
	ConsumerId string                    `position:"Query" name:"ConsumerId"`
	Remark     string                    `position:"Query" name:"Remark"`
	InstanceId string                    `position:"Query" name:"InstanceId"`
	Tag        *[]CreateConsumerGroupTag `position:"Query" name:"Tag"  type:"Repeated"`
}

CreateConsumerGroupRequest is the request struct for api CreateConsumerGroup

func CreateCreateConsumerGroupRequest ¶

func CreateCreateConsumerGroupRequest() (request *CreateConsumerGroupRequest)

CreateCreateConsumerGroupRequest creates a request to invoke CreateConsumerGroup API

type CreateConsumerGroupResponse ¶

type CreateConsumerGroupResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

CreateConsumerGroupResponse is the response struct for api CreateConsumerGroup

func CreateCreateConsumerGroupResponse ¶

func CreateCreateConsumerGroupResponse() (response *CreateConsumerGroupResponse)

CreateCreateConsumerGroupResponse creates a response to parse from CreateConsumerGroup response

type CreateConsumerGroupTag ¶ added in v1.62.80

type CreateConsumerGroupTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

CreateConsumerGroupTag is a repeated param struct in CreateConsumerGroupRequest

type CreatePostPayOrderRequest ¶

type CreatePostPayOrderRequest struct {
	*requests.RpcRequest
	IoMax           requests.Integer         `position:"Query" name:"IoMax"`
	EipMax          requests.Integer         `position:"Query" name:"EipMax"`
	SpecType        string                   `position:"Query" name:"SpecType"`
	ResourceGroupId string                   `position:"Query" name:"ResourceGroupId"`
	Tag             *[]CreatePostPayOrderTag `position:"Query" name:"Tag"  type:"Repeated"`
	PartitionNum    requests.Integer         `position:"Query" name:"PartitionNum"`
	PaidType        requests.Integer         `position:"Query" name:"PaidType"`
	DiskSize        requests.Integer         `position:"Query" name:"DiskSize"`
	IoMaxSpec       string                   `position:"Query" name:"IoMaxSpec"`
	DiskType        string                   `position:"Query" name:"DiskType"`
	TopicQuota      requests.Integer         `position:"Query" name:"TopicQuota"`
	DeployType      requests.Integer         `position:"Query" name:"DeployType"`
}

CreatePostPayOrderRequest is the request struct for api CreatePostPayOrder

func CreateCreatePostPayOrderRequest ¶

func CreateCreatePostPayOrderRequest() (request *CreatePostPayOrderRequest)

CreateCreatePostPayOrderRequest creates a request to invoke CreatePostPayOrder API

type CreatePostPayOrderResponse ¶

type CreatePostPayOrderResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	OrderId   string `json:"OrderId" xml:"OrderId"`
}

CreatePostPayOrderResponse is the response struct for api CreatePostPayOrder

func CreateCreatePostPayOrderResponse ¶

func CreateCreatePostPayOrderResponse() (response *CreatePostPayOrderResponse)

CreateCreatePostPayOrderResponse creates a response to parse from CreatePostPayOrder response

type CreatePostPayOrderTag ¶ added in v1.62.80

type CreatePostPayOrderTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

CreatePostPayOrderTag is a repeated param struct in CreatePostPayOrderRequest

type CreatePrePayOrderConfluentConfig ¶ added in v1.62.711

type CreatePrePayOrderConfluentConfig struct {
	KsqlStorage           string `name:"KsqlStorage"`
	ControlCenterStorage  string `name:"ControlCenterStorage"`
	KafkaRestProxyReplica string `name:"KafkaRestProxyReplica"`
	ZooKeeperReplica      string `name:"ZooKeeperReplica"`
	ConnectCU             string `name:"ConnectCU"`
	KafkaReplica          string `name:"KafkaReplica"`
	SchemaRegistryReplica string `name:"SchemaRegistryReplica"`
	KafkaCU               string `name:"KafkaCU"`
	ConnectReplica        string `name:"ConnectReplica"`
	ControlCenterCU       string `name:"ControlCenterCU"`
	KsqlReplica           string `name:"KsqlReplica"`
	ControlCenterReplica  string `name:"ControlCenterReplica"`
	KafkaStorage          string `name:"KafkaStorage"`
	ZooKeeperStorage      string `name:"ZooKeeperStorage"`
	KsqlCU                string `name:"KsqlCU"`
	SchemaRegistryCU      string `name:"SchemaRegistryCU"`
	ZooKeeperCU           string `name:"ZooKeeperCU"`
	KafkaRestProxyCU      string `name:"KafkaRestProxyCU"`
}

CreatePrePayOrderConfluentConfig is a repeated param struct in CreatePrePayOrderRequest

type CreatePrePayOrderRequest ¶ added in v1.60.294

type CreatePrePayOrderRequest struct {
	*requests.RpcRequest
	IoMax           requests.Integer                 `position:"Query" name:"IoMax"`
	EipMax          requests.Integer                 `position:"Query" name:"EipMax"`
	Duration        requests.Integer                 `position:"Query" name:"Duration"`
	SpecType        string                           `position:"Query" name:"SpecType"`
	ResourceGroupId string                           `position:"Query" name:"ResourceGroupId"`
	ConfluentConfig CreatePrePayOrderConfluentConfig `position:"Query" name:"ConfluentConfig"  type:"Struct"`
	Tag             *[]CreatePrePayOrderTag          `position:"Query" name:"Tag"  type:"Repeated"`
	PartitionNum    requests.Integer                 `position:"Query" name:"PartitionNum"`
	PaidType        requests.Integer                 `position:"Query" name:"PaidType"`
	DiskSize        requests.Integer                 `position:"Query" name:"DiskSize"`
	IoMaxSpec       string                           `position:"Query" name:"IoMaxSpec"`
	DiskType        string                           `position:"Query" name:"DiskType"`
	TopicQuota      requests.Integer                 `position:"Query" name:"TopicQuota"`
	DeployType      requests.Integer                 `position:"Query" name:"DeployType"`
}

CreatePrePayOrderRequest is the request struct for api CreatePrePayOrder

func CreateCreatePrePayOrderRequest ¶ added in v1.60.294

func CreateCreatePrePayOrderRequest() (request *CreatePrePayOrderRequest)

CreateCreatePrePayOrderRequest creates a request to invoke CreatePrePayOrder API

type CreatePrePayOrderResponse ¶ added in v1.60.294

type CreatePrePayOrderResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	OrderId   string `json:"OrderId" xml:"OrderId"`
}

CreatePrePayOrderResponse is the response struct for api CreatePrePayOrder

func CreateCreatePrePayOrderResponse ¶ added in v1.60.294

func CreateCreatePrePayOrderResponse() (response *CreatePrePayOrderResponse)

CreateCreatePrePayOrderResponse creates a response to parse from CreatePrePayOrder response

type CreatePrePayOrderTag ¶ added in v1.62.80

type CreatePrePayOrderTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

CreatePrePayOrderTag is a repeated param struct in CreatePrePayOrderRequest

type CreateSaslUserRequest ¶ added in v1.60.294

type CreateSaslUserRequest struct {
	*requests.RpcRequest
	Type       string `position:"Query" name:"Type"`
	Password   string `position:"Query" name:"Password"`
	InstanceId string `position:"Query" name:"InstanceId"`
	Mechanism  string `position:"Query" name:"Mechanism"`
	Username   string `position:"Query" name:"Username"`
}

CreateSaslUserRequest is the request struct for api CreateSaslUser

func CreateCreateSaslUserRequest ¶ added in v1.60.294

func CreateCreateSaslUserRequest() (request *CreateSaslUserRequest)

CreateCreateSaslUserRequest creates a request to invoke CreateSaslUser API

type CreateSaslUserResponse ¶ added in v1.60.294

type CreateSaslUserResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

CreateSaslUserResponse is the response struct for api CreateSaslUser

func CreateCreateSaslUserResponse ¶ added in v1.60.294

func CreateCreateSaslUserResponse() (response *CreateSaslUserResponse)

CreateCreateSaslUserResponse creates a response to parse from CreateSaslUser response

type CreateTopicRequest ¶

type CreateTopicRequest struct {
	*requests.RpcRequest
	Remark            string            `position:"Query" name:"Remark"`
	ReplicationFactor requests.Integer  `position:"Query" name:"ReplicationFactor"`
	MinInsyncReplicas requests.Integer  `position:"Query" name:"MinInsyncReplicas"`
	InstanceId        string            `position:"Query" name:"InstanceId"`
	Topic             string            `position:"Query" name:"Topic"`
	CompactTopic      requests.Boolean  `position:"Query" name:"CompactTopic"`
	Tag               *[]CreateTopicTag `position:"Query" name:"Tag"  type:"Repeated"`
	PartitionNum      string            `position:"Query" name:"PartitionNum"`
	Config            string            `position:"Query" name:"Config"`
	LocalTopic        requests.Boolean  `position:"Query" name:"LocalTopic"`
}

CreateTopicRequest is the request struct for api CreateTopic

func CreateCreateTopicRequest ¶

func CreateCreateTopicRequest() (request *CreateTopicRequest)

CreateCreateTopicRequest creates a request to invoke CreateTopic API

type CreateTopicResponse ¶

type CreateTopicResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

CreateTopicResponse is the response struct for api CreateTopic

func CreateCreateTopicResponse ¶

func CreateCreateTopicResponse() (response *CreateTopicResponse)

CreateCreateTopicResponse creates a response to parse from CreateTopic response

type CreateTopicTag ¶ added in v1.62.80

type CreateTopicTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

CreateTopicTag is a repeated param struct in CreateTopicRequest

type DeleteAclRequest ¶ added in v1.60.294

type DeleteAclRequest struct {
	*requests.RpcRequest
	AclResourcePatternType string `position:"Query" name:"AclResourcePatternType"`
	AclResourceType        string `position:"Query" name:"AclResourceType"`
	AclOperationTypes      string `position:"Query" name:"AclOperationTypes"`
	AclOperationType       string `position:"Query" name:"AclOperationType"`
	AclResourceName        string `position:"Query" name:"AclResourceName"`
	InstanceId             string `position:"Query" name:"InstanceId"`
	Host                   string `position:"Query" name:"Host"`
	AclPermissionType      string `position:"Query" name:"AclPermissionType"`
	Username               string `position:"Query" name:"Username"`
}

DeleteAclRequest is the request struct for api DeleteAcl

func CreateDeleteAclRequest ¶ added in v1.60.294

func CreateDeleteAclRequest() (request *DeleteAclRequest)

CreateDeleteAclRequest creates a request to invoke DeleteAcl API

type DeleteAclResponse ¶ added in v1.60.294

type DeleteAclResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DeleteAclResponse is the response struct for api DeleteAcl

func CreateDeleteAclResponse ¶ added in v1.60.294

func CreateDeleteAclResponse() (response *DeleteAclResponse)

CreateDeleteAclResponse creates a response to parse from DeleteAcl response

type DeleteConsumerGroupRequest ¶

type DeleteConsumerGroupRequest struct {
	*requests.RpcRequest
	ConsumerId string `position:"Query" name:"ConsumerId"`
	InstanceId string `position:"Query" name:"InstanceId"`
}

DeleteConsumerGroupRequest is the request struct for api DeleteConsumerGroup

func CreateDeleteConsumerGroupRequest ¶

func CreateDeleteConsumerGroupRequest() (request *DeleteConsumerGroupRequest)

CreateDeleteConsumerGroupRequest creates a request to invoke DeleteConsumerGroup API

type DeleteConsumerGroupResponse ¶

type DeleteConsumerGroupResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DeleteConsumerGroupResponse is the response struct for api DeleteConsumerGroup

func CreateDeleteConsumerGroupResponse ¶

func CreateDeleteConsumerGroupResponse() (response *DeleteConsumerGroupResponse)

CreateDeleteConsumerGroupResponse creates a response to parse from DeleteConsumerGroup response

type DeleteInstanceRequest ¶ added in v1.60.294

type DeleteInstanceRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
}

DeleteInstanceRequest is the request struct for api DeleteInstance

func CreateDeleteInstanceRequest ¶ added in v1.60.294

func CreateDeleteInstanceRequest() (request *DeleteInstanceRequest)

CreateDeleteInstanceRequest creates a request to invoke DeleteInstance API

type DeleteInstanceResponse ¶ added in v1.60.294

type DeleteInstanceResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DeleteInstanceResponse is the response struct for api DeleteInstance

func CreateDeleteInstanceResponse ¶ added in v1.60.294

func CreateDeleteInstanceResponse() (response *DeleteInstanceResponse)

CreateDeleteInstanceResponse creates a response to parse from DeleteInstance response

type DeleteSaslUserRequest ¶ added in v1.60.294

type DeleteSaslUserRequest struct {
	*requests.RpcRequest
	Type       string `position:"Query" name:"Type"`
	InstanceId string `position:"Query" name:"InstanceId"`
	Mechanism  string `position:"Query" name:"Mechanism"`
	Username   string `position:"Query" name:"Username"`
}

DeleteSaslUserRequest is the request struct for api DeleteSaslUser

func CreateDeleteSaslUserRequest ¶ added in v1.60.294

func CreateDeleteSaslUserRequest() (request *DeleteSaslUserRequest)

CreateDeleteSaslUserRequest creates a request to invoke DeleteSaslUser API

type DeleteSaslUserResponse ¶ added in v1.60.294

type DeleteSaslUserResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DeleteSaslUserResponse is the response struct for api DeleteSaslUser

func CreateDeleteSaslUserResponse ¶ added in v1.60.294

func CreateDeleteSaslUserResponse() (response *DeleteSaslUserResponse)

CreateDeleteSaslUserResponse creates a response to parse from DeleteSaslUser response

type DeleteTopicRequest ¶

type DeleteTopicRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
	Topic      string `position:"Query" name:"Topic"`
}

DeleteTopicRequest is the request struct for api DeleteTopic

func CreateDeleteTopicRequest ¶

func CreateDeleteTopicRequest() (request *DeleteTopicRequest)

CreateDeleteTopicRequest creates a request to invoke DeleteTopic API

type DeleteTopicResponse ¶

type DeleteTopicResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DeleteTopicResponse is the response struct for api DeleteTopic

func CreateDeleteTopicResponse ¶

func CreateDeleteTopicResponse() (response *DeleteTopicResponse)

CreateDeleteTopicResponse creates a response to parse from DeleteTopic response

type DescribeAclsRequest ¶ added in v1.60.294

type DescribeAclsRequest struct {
	*requests.RpcRequest
	AclResourcePatternType string `position:"Query" name:"AclResourcePatternType"`
	AclResourceType        string `position:"Query" name:"AclResourceType"`
	AclOperationType       string `position:"Query" name:"AclOperationType"`
	AclResourceName        string `position:"Query" name:"AclResourceName"`
	InstanceId             string `position:"Query" name:"InstanceId"`
	Host                   string `position:"Query" name:"Host"`
	AclPermissionType      string `position:"Query" name:"AclPermissionType"`
	Username               string `position:"Query" name:"Username"`
}

DescribeAclsRequest is the request struct for api DescribeAcls

func CreateDescribeAclsRequest ¶ added in v1.60.294

func CreateDescribeAclsRequest() (request *DescribeAclsRequest)

CreateDescribeAclsRequest creates a request to invoke DescribeAcls API

type DescribeAclsResponse ¶ added in v1.60.294

type DescribeAclsResponse struct {
	*responses.BaseResponse
	Code         int          `json:"Code" xml:"Code"`
	Message      string       `json:"Message" xml:"Message"`
	RequestId    string       `json:"RequestId" xml:"RequestId"`
	Success      bool         `json:"Success" xml:"Success"`
	KafkaAclList KafkaAclList `json:"KafkaAclList" xml:"KafkaAclList"`
}

DescribeAclsResponse is the response struct for api DescribeAcls

func CreateDescribeAclsResponse ¶ added in v1.60.294

func CreateDescribeAclsResponse() (response *DescribeAclsResponse)

CreateDescribeAclsResponse creates a response to parse from DescribeAcls response

type DescribeSaslUsersRequest ¶ added in v1.60.294

type DescribeSaslUsersRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
}

DescribeSaslUsersRequest is the request struct for api DescribeSaslUsers

func CreateDescribeSaslUsersRequest ¶ added in v1.60.294

func CreateDescribeSaslUsersRequest() (request *DescribeSaslUsersRequest)

CreateDescribeSaslUsersRequest creates a request to invoke DescribeSaslUsers API

type DescribeSaslUsersResponse ¶ added in v1.60.294

type DescribeSaslUsersResponse struct {
	*responses.BaseResponse
	Code         int          `json:"Code" xml:"Code"`
	Message      string       `json:"Message" xml:"Message"`
	RequestId    string       `json:"RequestId" xml:"RequestId"`
	Success      bool         `json:"Success" xml:"Success"`
	SaslUserList SaslUserList `json:"SaslUserList" xml:"SaslUserList"`
}

DescribeSaslUsersResponse is the response struct for api DescribeSaslUsers

func CreateDescribeSaslUsersResponse ¶ added in v1.60.294

func CreateDescribeSaslUsersResponse() (response *DescribeSaslUsersResponse)

CreateDescribeSaslUsersResponse creates a response to parse from DescribeSaslUsers response

type EnableAutoGroupCreationRequest ¶ added in v1.62.711

type EnableAutoGroupCreationRequest struct {
	*requests.RpcRequest
	InstanceId string           `position:"Query" name:"InstanceId"`
	Enable     requests.Boolean `position:"Query" name:"Enable"`
}

EnableAutoGroupCreationRequest is the request struct for api EnableAutoGroupCreation

func CreateEnableAutoGroupCreationRequest ¶ added in v1.62.711

func CreateEnableAutoGroupCreationRequest() (request *EnableAutoGroupCreationRequest)

CreateEnableAutoGroupCreationRequest creates a request to invoke EnableAutoGroupCreation API

type EnableAutoGroupCreationResponse ¶ added in v1.62.711

type EnableAutoGroupCreationResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

EnableAutoGroupCreationResponse is the response struct for api EnableAutoGroupCreation

func CreateEnableAutoGroupCreationResponse ¶ added in v1.62.711

func CreateEnableAutoGroupCreationResponse() (response *EnableAutoGroupCreationResponse)

CreateEnableAutoGroupCreationResponse creates a response to parse from EnableAutoGroupCreation response

type EnableAutoTopicCreationRequest ¶ added in v1.62.711

type EnableAutoTopicCreationRequest struct {
	*requests.RpcRequest
	InstanceId   string           `position:"Query" name:"InstanceId"`
	Operate      string           `position:"Query" name:"Operate"`
	PartitionNum requests.Integer `position:"Query" name:"PartitionNum"`
}

EnableAutoTopicCreationRequest is the request struct for api EnableAutoTopicCreation

func CreateEnableAutoTopicCreationRequest ¶ added in v1.62.711

func CreateEnableAutoTopicCreationRequest() (request *EnableAutoTopicCreationRequest)

CreateEnableAutoTopicCreationRequest creates a request to invoke EnableAutoTopicCreation API

type EnableAutoTopicCreationResponse ¶ added in v1.62.711

type EnableAutoTopicCreationResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

EnableAutoTopicCreationResponse is the response struct for api EnableAutoTopicCreation

func CreateEnableAutoTopicCreationResponse ¶ added in v1.62.711

func CreateEnableAutoTopicCreationResponse() (response *EnableAutoTopicCreationResponse)

CreateEnableAutoTopicCreationResponse creates a response to parse from EnableAutoTopicCreation response

type GetAllInstanceIdListRequest ¶ added in v1.61.1694

type GetAllInstanceIdListRequest struct {
	*requests.RpcRequest
}

GetAllInstanceIdListRequest is the request struct for api GetAllInstanceIdList

func CreateGetAllInstanceIdListRequest ¶ added in v1.61.1694

func CreateGetAllInstanceIdListRequest() (request *GetAllInstanceIdListRequest)

CreateGetAllInstanceIdListRequest creates a request to invoke GetAllInstanceIdList API

type GetAllInstanceIdListResponse ¶ added in v1.61.1694

type GetAllInstanceIdListResponse struct {
	*responses.BaseResponse
	Code        int                    `json:"Code" xml:"Code"`
	Message     string                 `json:"Message" xml:"Message"`
	InstanceIds map[string]interface{} `json:"InstanceIds" xml:"InstanceIds"`
	RequestId   string                 `json:"RequestId" xml:"RequestId"`
	Success     bool                   `json:"Success" xml:"Success"`
}

GetAllInstanceIdListResponse is the response struct for api GetAllInstanceIdList

func CreateGetAllInstanceIdListResponse ¶ added in v1.61.1694

func CreateGetAllInstanceIdListResponse() (response *GetAllInstanceIdListResponse)

CreateGetAllInstanceIdListResponse creates a response to parse from GetAllInstanceIdList response

type GetAllowedIpListRequest ¶ added in v1.61.349

type GetAllowedIpListRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
}

GetAllowedIpListRequest is the request struct for api GetAllowedIpList

func CreateGetAllowedIpListRequest ¶ added in v1.61.349

func CreateGetAllowedIpListRequest() (request *GetAllowedIpListRequest)

CreateGetAllowedIpListRequest creates a request to invoke GetAllowedIpList API

type GetAllowedIpListResponse ¶ added in v1.61.349

type GetAllowedIpListResponse struct {
	*responses.BaseResponse
	Code        int         `json:"Code" xml:"Code"`
	Message     string      `json:"Message" xml:"Message"`
	RequestId   string      `json:"RequestId" xml:"RequestId"`
	Success     bool        `json:"Success" xml:"Success"`
	AllowedList AllowedList `json:"AllowedList" xml:"AllowedList"`
}

GetAllowedIpListResponse is the response struct for api GetAllowedIpList

func CreateGetAllowedIpListResponse ¶ added in v1.61.349

func CreateGetAllowedIpListResponse() (response *GetAllowedIpListResponse)

CreateGetAllowedIpListResponse creates a response to parse from GetAllowedIpList response

type GetConsumerListRequest ¶

type GetConsumerListRequest struct {
	*requests.RpcRequest
	ConsumerId  string           `position:"Query" name:"ConsumerId"`
	CurrentPage requests.Integer `position:"Query" name:"CurrentPage"`
	InstanceId  string           `position:"Query" name:"InstanceId"`
	PageSize    requests.Integer `position:"Query" name:"PageSize"`
}

GetConsumerListRequest is the request struct for api GetConsumerList

func CreateGetConsumerListRequest ¶

func CreateGetConsumerListRequest() (request *GetConsumerListRequest)

CreateGetConsumerListRequest creates a request to invoke GetConsumerList API

type GetConsumerListResponse ¶

type GetConsumerListResponse struct {
	*responses.BaseResponse
	Code         int          `json:"Code" xml:"Code"`
	Message      string       `json:"Message" xml:"Message"`
	RequestId    string       `json:"RequestId" xml:"RequestId"`
	Success      bool         `json:"Success" xml:"Success"`
	Total        int64        `json:"Total" xml:"Total"`
	PageSize     int          `json:"PageSize" xml:"PageSize"`
	CurrentPage  int          `json:"CurrentPage" xml:"CurrentPage"`
	ConsumerList ConsumerList `json:"ConsumerList" xml:"ConsumerList"`
}

GetConsumerListResponse is the response struct for api GetConsumerList

func CreateGetConsumerListResponse ¶

func CreateGetConsumerListResponse() (response *GetConsumerListResponse)

CreateGetConsumerListResponse creates a response to parse from GetConsumerList response

type GetConsumerProgressRequest ¶

type GetConsumerProgressRequest struct {
	*requests.RpcRequest
	ConsumerId string `position:"Query" name:"ConsumerId"`
	InstanceId string `position:"Query" name:"InstanceId"`
}

GetConsumerProgressRequest is the request struct for api GetConsumerProgress

func CreateGetConsumerProgressRequest ¶

func CreateGetConsumerProgressRequest() (request *GetConsumerProgressRequest)

CreateGetConsumerProgressRequest creates a request to invoke GetConsumerProgress API

type GetConsumerProgressResponse ¶

type GetConsumerProgressResponse struct {
	*responses.BaseResponse
	Code             int              `json:"Code" xml:"Code"`
	Message          string           `json:"Message" xml:"Message"`
	RequestId        string           `json:"RequestId" xml:"RequestId"`
	Success          bool             `json:"Success" xml:"Success"`
	ConsumerProgress ConsumerProgress `json:"ConsumerProgress" xml:"ConsumerProgress"`
}

GetConsumerProgressResponse is the response struct for api GetConsumerProgress

func CreateGetConsumerProgressResponse ¶

func CreateGetConsumerProgressResponse() (response *GetConsumerProgressResponse)

CreateGetConsumerProgressResponse creates a response to parse from GetConsumerProgress response

type GetInstanceListRequest ¶

type GetInstanceListRequest struct {
	*requests.RpcRequest
	OrderId         string                `position:"Query" name:"OrderId"`
	ResourceGroupId string                `position:"Query" name:"ResourceGroupId"`
	InstanceId      *[]string             `position:"Query" name:"InstanceId"  type:"Repeated"`
	Tag             *[]GetInstanceListTag `position:"Query" name:"Tag"  type:"Repeated"`
}

GetInstanceListRequest is the request struct for api GetInstanceList

func CreateGetInstanceListRequest ¶

func CreateGetInstanceListRequest() (request *GetInstanceListRequest)

CreateGetInstanceListRequest creates a request to invoke GetInstanceList API

type GetInstanceListResponse ¶

type GetInstanceListResponse struct {
	*responses.BaseResponse
	Code         int          `json:"Code" xml:"Code"`
	Message      string       `json:"Message" xml:"Message"`
	RequestId    string       `json:"RequestId" xml:"RequestId"`
	Success      bool         `json:"Success" xml:"Success"`
	InstanceList InstanceList `json:"InstanceList" xml:"InstanceList"`
}

GetInstanceListResponse is the response struct for api GetInstanceList

func CreateGetInstanceListResponse ¶

func CreateGetInstanceListResponse() (response *GetInstanceListResponse)

CreateGetInstanceListResponse creates a response to parse from GetInstanceList response

type GetInstanceListTag ¶ added in v1.60.334

type GetInstanceListTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

GetInstanceListTag is a repeated param struct in GetInstanceListRequest

type GetQuotaTipRequest ¶ added in v1.62.80

type GetQuotaTipRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
}

GetQuotaTipRequest is the request struct for api GetQuotaTip

func CreateGetQuotaTipRequest ¶ added in v1.62.80

func CreateGetQuotaTipRequest() (request *GetQuotaTipRequest)

CreateGetQuotaTipRequest creates a request to invoke GetQuotaTip API

type GetQuotaTipResponse ¶ added in v1.62.80

type GetQuotaTipResponse struct {
	*responses.BaseResponse
	Code      int       `json:"Code" xml:"Code"`
	Message   string    `json:"Message" xml:"Message"`
	RequestId string    `json:"RequestId" xml:"RequestId"`
	Success   bool      `json:"Success" xml:"Success"`
	QuotaData QuotaData `json:"QuotaData" xml:"QuotaData"`
}

GetQuotaTipResponse is the response struct for api GetQuotaTip

func CreateGetQuotaTipResponse ¶ added in v1.62.80

func CreateGetQuotaTipResponse() (response *GetQuotaTipResponse)

CreateGetQuotaTipResponse creates a response to parse from GetQuotaTip response

type GetTopicListRequest ¶

type GetTopicListRequest struct {
	*requests.RpcRequest
	CurrentPage string `position:"Query" name:"CurrentPage"`
	InstanceId  string `position:"Query" name:"InstanceId"`
	PageSize    string `position:"Query" name:"PageSize"`
	Topic       string `position:"Query" name:"Topic"`
}

GetTopicListRequest is the request struct for api GetTopicList

func CreateGetTopicListRequest ¶

func CreateGetTopicListRequest() (request *GetTopicListRequest)

CreateGetTopicListRequest creates a request to invoke GetTopicList API

type GetTopicListResponse ¶

type GetTopicListResponse struct {
	*responses.BaseResponse
	CurrentPage int                     `json:"CurrentPage" xml:"CurrentPage"`
	RequestId   string                  `json:"RequestId" xml:"RequestId"`
	Success     bool                    `json:"Success" xml:"Success"`
	Code        int                     `json:"Code" xml:"Code"`
	Message     string                  `json:"Message" xml:"Message"`
	PageSize    int                     `json:"PageSize" xml:"PageSize"`
	Total       int                     `json:"Total" xml:"Total"`
	TopicList   TopicListInGetTopicList `json:"TopicList" xml:"TopicList"`
}

GetTopicListResponse is the response struct for api GetTopicList

func CreateGetTopicListResponse ¶

func CreateGetTopicListResponse() (response *GetTopicListResponse)

CreateGetTopicListResponse creates a response to parse from GetTopicList response

type GetTopicStatusRequest ¶

type GetTopicStatusRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
	Topic      string `position:"Query" name:"Topic"`
}

GetTopicStatusRequest is the request struct for api GetTopicStatus

func CreateGetTopicStatusRequest ¶

func CreateGetTopicStatusRequest() (request *GetTopicStatusRequest)

CreateGetTopicStatusRequest creates a request to invoke GetTopicStatus API

type GetTopicStatusResponse ¶

type GetTopicStatusResponse struct {
	*responses.BaseResponse
	Code        int         `json:"Code" xml:"Code"`
	Message     string      `json:"Message" xml:"Message"`
	RequestId   string      `json:"RequestId" xml:"RequestId"`
	Success     bool        `json:"Success" xml:"Success"`
	TopicStatus TopicStatus `json:"TopicStatus" xml:"TopicStatus"`
}

GetTopicStatusResponse is the response struct for api GetTopicStatus

func CreateGetTopicStatusResponse ¶

func CreateGetTopicStatusResponse() (response *GetTopicStatusResponse)

CreateGetTopicStatusResponse creates a response to parse from GetTopicStatus response

type GetTopicSubscribeStatusRequest ¶ added in v1.62.711

type GetTopicSubscribeStatusRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
	Topic      string `position:"Query" name:"Topic"`
}

GetTopicSubscribeStatusRequest is the request struct for api GetTopicSubscribeStatus

func CreateGetTopicSubscribeStatusRequest ¶ added in v1.62.711

func CreateGetTopicSubscribeStatusRequest() (request *GetTopicSubscribeStatusRequest)

CreateGetTopicSubscribeStatusRequest creates a request to invoke GetTopicSubscribeStatus API

type GetTopicSubscribeStatusResponse ¶ added in v1.62.711

type GetTopicSubscribeStatusResponse struct {
	*responses.BaseResponse
	RequestId            string               `json:"RequestId" xml:"RequestId"`
	Code                 int                  `json:"Code" xml:"Code"`
	Success              bool                 `json:"Success" xml:"Success"`
	Message              string               `json:"Message" xml:"Message"`
	TopicSubscribeStatus TopicSubscribeStatus `json:"TopicSubscribeStatus" xml:"TopicSubscribeStatus"`
}

GetTopicSubscribeStatusResponse is the response struct for api GetTopicSubscribeStatus

func CreateGetTopicSubscribeStatusResponse ¶ added in v1.62.711

func CreateGetTopicSubscribeStatusResponse() (response *GetTopicSubscribeStatusResponse)

CreateGetTopicSubscribeStatusResponse creates a response to parse from GetTopicSubscribeStatus response

type IPListVO ¶ added in v1.61.349

type IPListVO struct {
	AllowedIpGroup map[string]interface{} `json:"AllowedIpGroup" xml:"AllowedIpGroup"`
	PortRange      string                 `json:"PortRange" xml:"PortRange"`
	AllowedIpList  []string               `json:"AllowedIpList" xml:"AllowedIpList"`
}

IPListVO is a nested struct in alikafka response

type InstanceList ¶

type InstanceList struct {
	InstanceVO []InstanceVO `json:"InstanceVO" xml:"InstanceVO"`
}

InstanceList is a nested struct in alikafka response

type InstanceVO ¶

type InstanceVO struct {
	VpcId                     string                   `json:"VpcId" xml:"VpcId"`
	SpecType                  string                   `json:"SpecType" xml:"SpecType"`
	DeployType                int                      `json:"DeployType" xml:"DeployType"`
	CreateTime                int64                    `json:"CreateTime" xml:"CreateTime"`
	DiskSize                  int                      `json:"DiskSize" xml:"DiskSize"`
	DiskType                  int                      `json:"DiskType" xml:"DiskType"`
	SecurityGroup             string                   `json:"SecurityGroup" xml:"SecurityGroup"`
	SslEndPoint               string                   `json:"SslEndPoint" xml:"SslEndPoint"`
	InstanceId                string                   `json:"InstanceId" xml:"InstanceId"`
	AllConfig                 string                   `json:"AllConfig" xml:"AllConfig"`
	ServiceStatus             int                      `json:"ServiceStatus" xml:"ServiceStatus"`
	EipMax                    int                      `json:"EipMax" xml:"EipMax"`
	RegionId                  string                   `json:"RegionId" xml:"RegionId"`
	MsgRetain                 int                      `json:"MsgRetain" xml:"MsgRetain"`
	VSwitchId                 string                   `json:"VSwitchId" xml:"VSwitchId"`
	ExpiredTime               int64                    `json:"ExpiredTime" xml:"ExpiredTime"`
	TopicNumLimit             int                      `json:"TopicNumLimit" xml:"TopicNumLimit"`
	ZoneId                    string                   `json:"ZoneId" xml:"ZoneId"`
	IoMax                     int                      `json:"IoMax" xml:"IoMax"`
	PaidType                  int                      `json:"PaidType" xml:"PaidType"`
	Name                      string                   `json:"Name" xml:"Name"`
	EndPoint                  string                   `json:"EndPoint" xml:"EndPoint"`
	DomainEndpoint            string                   `json:"DomainEndpoint" xml:"DomainEndpoint"`
	SslDomainEndpoint         string                   `json:"SslDomainEndpoint" xml:"SslDomainEndpoint"`
	SaslDomainEndpoint        string                   `json:"SaslDomainEndpoint" xml:"SaslDomainEndpoint"`
	ResourceGroupId           string                   `json:"ResourceGroupId" xml:"ResourceGroupId"`
	UsedTopicCount            int                      `json:"UsedTopicCount" xml:"UsedTopicCount"`
	UsedGroupCount            int                      `json:"UsedGroupCount" xml:"UsedGroupCount"`
	UsedPartitionCount        int                      `json:"UsedPartitionCount" xml:"UsedPartitionCount"`
	KmsKeyId                  string                   `json:"KmsKeyId" xml:"KmsKeyId"`
	StandardZoneId            string                   `json:"StandardZoneId" xml:"StandardZoneId"`
	IoMaxSpec                 string                   `json:"IoMaxSpec" xml:"IoMaxSpec"`
	ReservedPublishCapacity   int                      `json:"ReservedPublishCapacity" xml:"ReservedPublishCapacity"`
	ReservedSubscribeCapacity int                      `json:"ReservedSubscribeCapacity" xml:"ReservedSubscribeCapacity"`
	ViewInstanceStatusCode    int                      `json:"ViewInstanceStatusCode" xml:"ViewInstanceStatusCode"`
	UpgradeServiceDetailInfo  UpgradeServiceDetailInfo `json:"UpgradeServiceDetailInfo" xml:"UpgradeServiceDetailInfo"`
	ConfluentConfig           ConfluentConfig          `json:"ConfluentConfig" xml:"ConfluentConfig"`
	Tags                      TagsInGetInstanceList    `json:"Tags" xml:"Tags"`
}

InstanceVO is a nested struct in alikafka response

type InternetList ¶ added in v1.61.349

type InternetList struct {
	IPListVO []IPListVO `json:"IPListVO" xml:"IPListVO"`
}

InternetList is a nested struct in alikafka response

type KafkaAclList ¶ added in v1.60.294

type KafkaAclList struct {
	KafkaAclVO []KafkaAclVO `json:"KafkaAclVO" xml:"KafkaAclVO"`
}

KafkaAclList is a nested struct in alikafka response

type KafkaAclVO ¶ added in v1.60.294

type KafkaAclVO struct {
	AclResourceType        string `json:"AclResourceType" xml:"AclResourceType"`
	Host                   string `json:"Host" xml:"Host"`
	AclOperationType       string `json:"AclOperationType" xml:"AclOperationType"`
	AclResourceName        string `json:"AclResourceName" xml:"AclResourceName"`
	AclResourcePatternType string `json:"AclResourcePatternType" xml:"AclResourcePatternType"`
	Username               string `json:"Username" xml:"Username"`
	AclPermissionType      string `json:"AclPermissionType" xml:"AclPermissionType"`
}

KafkaAclVO is a nested struct in alikafka response

type ListTagResourcesRequest ¶

type ListTagResourcesRequest struct {
	*requests.RpcRequest
	ResourceId   *[]string              `position:"Query" name:"ResourceId"  type:"Repeated"`
	ResourceType string                 `position:"Query" name:"ResourceType"`
	NextToken    string                 `position:"Query" name:"NextToken"`
	Tag          *[]ListTagResourcesTag `position:"Query" name:"Tag"  type:"Repeated"`
}

ListTagResourcesRequest is the request struct for api ListTagResources

func CreateListTagResourcesRequest ¶

func CreateListTagResourcesRequest() (request *ListTagResourcesRequest)

CreateListTagResourcesRequest creates a request to invoke ListTagResources API

type ListTagResourcesResponse ¶

type ListTagResourcesResponse struct {
	*responses.BaseResponse
	NextToken    string       `json:"NextToken" xml:"NextToken"`
	RequestId    string       `json:"RequestId" xml:"RequestId"`
	TagResources TagResources `json:"TagResources" xml:"TagResources"`
}

ListTagResourcesResponse is the response struct for api ListTagResources

func CreateListTagResourcesResponse ¶

func CreateListTagResourcesResponse() (response *ListTagResourcesResponse)

CreateListTagResourcesResponse creates a response to parse from ListTagResources response

type ListTagResourcesTag ¶

type ListTagResourcesTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

ListTagResourcesTag is a repeated param struct in ListTagResourcesRequest

type MessageList ¶ added in v1.62.711

type MessageList struct {
	MessageVO []MessageVO `json:"MessageVO" xml:"MessageVO"`
}

MessageList is a nested struct in alikafka response

type MessageVO ¶ added in v1.62.711

type MessageVO struct {
	Topic               string `json:"Topic" xml:"Topic"`
	Partition           int64  `json:"Partition" xml:"Partition"`
	Offset              int64  `json:"Offset" xml:"Offset"`
	Timestamp           int64  `json:"Timestamp" xml:"Timestamp"`
	TimestampType       string `json:"TimestampType" xml:"TimestampType"`
	Checksum            int64  `json:"Checksum" xml:"Checksum"`
	SerializedKeySize   int    `json:"SerializedKeySize" xml:"SerializedKeySize"`
	SerializedValueSize int    `json:"SerializedValueSize" xml:"SerializedValueSize"`
	Key                 string `json:"Key" xml:"Key"`
	Value               string `json:"Value" xml:"Value"`
	KeyTruncated        bool   `json:"KeyTruncated" xml:"KeyTruncated"`
	ValueTruncated      bool   `json:"ValueTruncated" xml:"ValueTruncated"`
	TruncatedKeySize    int    `json:"TruncatedKeySize" xml:"TruncatedKeySize"`
	TruncatedValueSize  int    `json:"TruncatedValueSize" xml:"TruncatedValueSize"`
}

MessageVO is a nested struct in alikafka response

type ModifyInstanceNameRequest ¶

type ModifyInstanceNameRequest struct {
	*requests.RpcRequest
	InstanceId   string `position:"Query" name:"InstanceId"`
	InstanceName string `position:"Query" name:"InstanceName"`
}

ModifyInstanceNameRequest is the request struct for api ModifyInstanceName

func CreateModifyInstanceNameRequest ¶

func CreateModifyInstanceNameRequest() (request *ModifyInstanceNameRequest)

CreateModifyInstanceNameRequest creates a request to invoke ModifyInstanceName API

type ModifyInstanceNameResponse ¶

type ModifyInstanceNameResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

ModifyInstanceNameResponse is the response struct for api ModifyInstanceName

func CreateModifyInstanceNameResponse ¶

func CreateModifyInstanceNameResponse() (response *ModifyInstanceNameResponse)

CreateModifyInstanceNameResponse creates a response to parse from ModifyInstanceName response

type ModifyPartitionNumRequest ¶ added in v1.60.334

type ModifyPartitionNumRequest struct {
	*requests.RpcRequest
	AddPartitionNum requests.Integer `position:"Query" name:"AddPartitionNum"`
	InstanceId      string           `position:"Query" name:"InstanceId"`
	Topic           string           `position:"Query" name:"Topic"`
}

ModifyPartitionNumRequest is the request struct for api ModifyPartitionNum

func CreateModifyPartitionNumRequest ¶ added in v1.60.334

func CreateModifyPartitionNumRequest() (request *ModifyPartitionNumRequest)

CreateModifyPartitionNumRequest creates a request to invoke ModifyPartitionNum API

type ModifyPartitionNumResponse ¶ added in v1.60.334

type ModifyPartitionNumResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

ModifyPartitionNumResponse is the response struct for api ModifyPartitionNum

func CreateModifyPartitionNumResponse ¶ added in v1.60.334

func CreateModifyPartitionNumResponse() (response *ModifyPartitionNumResponse)

CreateModifyPartitionNumResponse creates a response to parse from ModifyPartitionNum response

type ModifyTopicRemarkRequest ¶ added in v1.60.334

type ModifyTopicRemarkRequest struct {
	*requests.RpcRequest
	Remark     string `position:"Query" name:"Remark"`
	InstanceId string `position:"Query" name:"InstanceId"`
	Topic      string `position:"Query" name:"Topic"`
}

ModifyTopicRemarkRequest is the request struct for api ModifyTopicRemark

func CreateModifyTopicRemarkRequest ¶ added in v1.60.334

func CreateModifyTopicRemarkRequest() (request *ModifyTopicRemarkRequest)

CreateModifyTopicRemarkRequest creates a request to invoke ModifyTopicRemark API

type ModifyTopicRemarkResponse ¶ added in v1.60.334

type ModifyTopicRemarkResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

ModifyTopicRemarkResponse is the response struct for api ModifyTopicRemark

func CreateModifyTopicRemarkResponse ¶ added in v1.60.334

func CreateModifyTopicRemarkResponse() (response *ModifyTopicRemarkResponse)

CreateModifyTopicRemarkResponse creates a response to parse from ModifyTopicRemark response

type OffsetList ¶

type OffsetList struct {
	OffsetListItem []OffsetListItem `json:"OffsetList" xml:"OffsetList"`
}

OffsetList is a nested struct in alikafka response

type OffsetListItem ¶

type OffsetListItem struct {
	Partition      int   `json:"Partition" xml:"Partition"`
	BrokerOffset   int64 `json:"BrokerOffset" xml:"BrokerOffset"`
	ConsumerOffset int64 `json:"ConsumerOffset" xml:"ConsumerOffset"`
	LastTimestamp  int64 `json:"LastTimestamp" xml:"LastTimestamp"`
}

OffsetListItem is a nested struct in alikafka response

type OffsetTable ¶

type OffsetTable struct {
	OffsetTableItem []OffsetTableItem `json:"OffsetTable" xml:"OffsetTable"`
}

OffsetTable is a nested struct in alikafka response

type OffsetTableItem ¶

type OffsetTableItem struct {
	Partition           int    `json:"Partition" xml:"Partition"`
	MinOffset           int64  `json:"MinOffset" xml:"MinOffset"`
	LastUpdateTimestamp int64  `json:"LastUpdateTimestamp" xml:"LastUpdateTimestamp"`
	MaxOffset           int64  `json:"MaxOffset" xml:"MaxOffset"`
	Topic               string `json:"Topic" xml:"Topic"`
}

OffsetTableItem is a nested struct in alikafka response

type QueryMessageRequest ¶ added in v1.62.711

type QueryMessageRequest struct {
	*requests.RpcRequest
	Offset     string           `position:"Query" name:"Offset"`
	BeginTime  requests.Integer `position:"Query" name:"BeginTime"`
	InstanceId string           `position:"Query" name:"InstanceId"`
	Partition  string           `position:"Query" name:"Partition"`
	Topic      string           `position:"Query" name:"Topic"`
	QueryType  string           `position:"Query" name:"QueryType"`
}

QueryMessageRequest is the request struct for api QueryMessage

func CreateQueryMessageRequest ¶ added in v1.62.711

func CreateQueryMessageRequest() (request *QueryMessageRequest)

CreateQueryMessageRequest creates a request to invoke QueryMessage API

type QueryMessageResponse ¶ added in v1.62.711

type QueryMessageResponse struct {
	*responses.BaseResponse
	Code        int         `json:"Code" xml:"Code"`
	Message     string      `json:"Message" xml:"Message"`
	RequestId   string      `json:"RequestId" xml:"RequestId"`
	Success     bool        `json:"Success" xml:"Success"`
	MessageList []MessageVO `json:"MessageList" xml:"MessageList"`
}

QueryMessageResponse is the response struct for api QueryMessage

func CreateQueryMessageResponse ¶ added in v1.62.711

func CreateQueryMessageResponse() (response *QueryMessageResponse)

CreateQueryMessageResponse creates a response to parse from QueryMessage response

type QuotaData ¶ added in v1.62.80

type QuotaData struct {
	TopicNumOfBuy     int `json:"TopicNumOfBuy" xml:"TopicNumOfBuy"`
	TopicQuota        int `json:"TopicQuota" xml:"TopicQuota"`
	TopicLeft         int `json:"TopicLeft" xml:"TopicLeft"`
	TopicUsed         int `json:"TopicUsed" xml:"TopicUsed"`
	PartitionNumOfBuy int `json:"PartitionNumOfBuy" xml:"PartitionNumOfBuy"`
	PartitionQuata    int `json:"PartitionQuata" xml:"PartitionQuata"`
	PartitionLeft     int `json:"PartitionLeft" xml:"PartitionLeft"`
	PartitionUsed     int `json:"PartitionUsed" xml:"PartitionUsed"`
	GroupLeft         int `json:"GroupLeft" xml:"GroupLeft"`
	GroupUsed         int `json:"GroupUsed" xml:"GroupUsed"`
	IsPartitionBuy    int `json:"IsPartitionBuy" xml:"IsPartitionBuy"`
	PartitionQuota    int `json:"PartitionQuota" xml:"PartitionQuota"`
}

QuotaData is a nested struct in alikafka response

type RebalanceInfoList ¶ added in v1.62.711

type RebalanceInfoList struct {
	RebalanceInfoListItem []RebalanceInfoListItem `json:"RebalanceInfoList" xml:"RebalanceInfoList"`
}

RebalanceInfoList is a nested struct in alikafka response

type RebalanceInfoListItem ¶ added in v1.62.711

type RebalanceInfoListItem struct {
	Generation             int64  `json:"Generation" xml:"Generation"`
	LastRebalanceTimestamp int64  `json:"LastRebalanceTimestamp" xml:"LastRebalanceTimestamp"`
	Reason                 string `json:"Reason" xml:"Reason"`
	GroupId                string `json:"GroupId" xml:"GroupId"`
	RebalanceTimeConsuming int64  `json:"RebalanceTimeConsuming" xml:"RebalanceTimeConsuming"`
	RebalanceSuccess       bool   `json:"RebalanceSuccess" xml:"RebalanceSuccess"`
}

RebalanceInfoListItem is a nested struct in alikafka response

type ReleaseInstanceRequest ¶

type ReleaseInstanceRequest struct {
	*requests.RpcRequest
	ForceDeleteInstance requests.Boolean `position:"Query" name:"ForceDeleteInstance"`
	InstanceId          string           `position:"Query" name:"InstanceId"`
	ReleaseIgnoreTime   requests.Boolean `position:"Query" name:"ReleaseIgnoreTime"`
}

ReleaseInstanceRequest is the request struct for api ReleaseInstance

func CreateReleaseInstanceRequest ¶

func CreateReleaseInstanceRequest() (request *ReleaseInstanceRequest)

CreateReleaseInstanceRequest creates a request to invoke ReleaseInstance API

type ReleaseInstanceResponse ¶

type ReleaseInstanceResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

ReleaseInstanceResponse is the response struct for api ReleaseInstance

func CreateReleaseInstanceResponse ¶

func CreateReleaseInstanceResponse() (response *ReleaseInstanceResponse)

CreateReleaseInstanceResponse creates a response to parse from ReleaseInstance response

type ReopenInstanceRequest ¶ added in v1.62.711

type ReopenInstanceRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
}

ReopenInstanceRequest is the request struct for api ReopenInstance

func CreateReopenInstanceRequest ¶ added in v1.62.711

func CreateReopenInstanceRequest() (request *ReopenInstanceRequest)

CreateReopenInstanceRequest creates a request to invoke ReopenInstance API

type ReopenInstanceResponse ¶ added in v1.62.711

type ReopenInstanceResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Success   bool   `json:"Success" xml:"Success"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Message   string `json:"Message" xml:"Message"`
}

ReopenInstanceResponse is the response struct for api ReopenInstance

func CreateReopenInstanceResponse ¶ added in v1.62.711

func CreateReopenInstanceResponse() (response *ReopenInstanceResponse)

CreateReopenInstanceResponse creates a response to parse from ReopenInstance response

type SaslUserList ¶ added in v1.60.294

type SaslUserList struct {
	SaslUserVO []SaslUserVO `json:"SaslUserVO" xml:"SaslUserVO"`
}

SaslUserList is a nested struct in alikafka response

type SaslUserVO ¶ added in v1.60.294

type SaslUserVO struct {
	Type      string `json:"Type" xml:"Type"`
	Password  string `json:"Password" xml:"Password"`
	Username  string `json:"Username" xml:"Username"`
	Mechanism string `json:"Mechanism" xml:"Mechanism"`
}

SaslUserVO is a nested struct in alikafka response

type StartInstanceRequest ¶

type StartInstanceRequest struct {
	*requests.RpcRequest
	VSwitchIds           *[]string        `position:"Query" name:"VSwitchIds"  type:"Repeated"`
	SelectedZones        string           `position:"Query" name:"SelectedZones"`
	IsEipInner           requests.Boolean `position:"Query" name:"IsEipInner"`
	SecurityGroup        string           `position:"Query" name:"SecurityGroup"`
	DeployModule         string           `position:"Query" name:"DeployModule"`
	IsSetUserAndPassword requests.Boolean `position:"Query" name:"IsSetUserAndPassword"`
	Password             string           `position:"Query" name:"Password"`
	Notifier             string           `position:"Query" name:"Notifier"`
	IsForceSelectedZones requests.Boolean `position:"Query" name:"IsForceSelectedZones"`
	VSwitchId            string           `position:"Query" name:"VSwitchId"`
	UserPhoneNum         string           `position:"Query" name:"UserPhoneNum"`
	InstanceId           string           `position:"Query" name:"InstanceId"`
	VpcId                string           `position:"Query" name:"VpcId"`
	CrossZone            requests.Boolean `position:"Query" name:"CrossZone"`
	Name                 string           `position:"Query" name:"Name"`
	ServiceVersion       string           `position:"Query" name:"ServiceVersion"`
	ZoneId               string           `position:"Query" name:"ZoneId"`
	KMSKeyId             string           `position:"Query" name:"KMSKeyId"`
	Config               string           `position:"Query" name:"Config"`
	Username             string           `position:"Query" name:"Username"`
}

StartInstanceRequest is the request struct for api StartInstance

func CreateStartInstanceRequest ¶

func CreateStartInstanceRequest() (request *StartInstanceRequest)

CreateStartInstanceRequest creates a request to invoke StartInstance API

type StartInstanceResponse ¶

type StartInstanceResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

StartInstanceResponse is the response struct for api StartInstance

func CreateStartInstanceResponse ¶

func CreateStartInstanceResponse() (response *StartInstanceResponse)

CreateStartInstanceResponse creates a response to parse from StartInstance response

type StopInstanceRequest ¶ added in v1.62.711

type StopInstanceRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
}

StopInstanceRequest is the request struct for api StopInstance

func CreateStopInstanceRequest ¶ added in v1.62.711

func CreateStopInstanceRequest() (request *StopInstanceRequest)

CreateStopInstanceRequest creates a request to invoke StopInstance API

type StopInstanceResponse ¶ added in v1.62.711

type StopInstanceResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

StopInstanceResponse is the response struct for api StopInstance

func CreateStopInstanceResponse ¶ added in v1.62.711

func CreateStopInstanceResponse() (response *StopInstanceResponse)

CreateStopInstanceResponse creates a response to parse from StopInstance response

type TagResource ¶

type TagResource struct {
	TagValue     string `json:"TagValue" xml:"TagValue"`
	ResourceType string `json:"ResourceType" xml:"ResourceType"`
	ResourceId   string `json:"ResourceId" xml:"ResourceId"`
	TagKey       string `json:"TagKey" xml:"TagKey"`
}

TagResource is a nested struct in alikafka response

type TagResources ¶

type TagResources struct {
	TagResource []TagResource `json:"TagResource" xml:"TagResource"`
}

TagResources is a nested struct in alikafka response

type TagResourcesRequest ¶

type TagResourcesRequest struct {
	*requests.RpcRequest
	ResourceId   *[]string          `position:"Query" name:"ResourceId"  type:"Repeated"`
	ResourceType string             `position:"Query" name:"ResourceType"`
	InstanceId   string             `position:"Query" name:"InstanceId"`
	Tag          *[]TagResourcesTag `position:"Query" name:"Tag"  type:"Repeated"`
}

TagResourcesRequest is the request struct for api TagResources

func CreateTagResourcesRequest ¶

func CreateTagResourcesRequest() (request *TagResourcesRequest)

CreateTagResourcesRequest creates a request to invoke TagResources API

type TagResourcesResponse ¶

type TagResourcesResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
}

TagResourcesResponse is the response struct for api TagResources

func CreateTagResourcesResponse ¶

func CreateTagResourcesResponse() (response *TagResourcesResponse)

CreateTagResourcesResponse creates a response to parse from TagResources response

type TagResourcesTag ¶

type TagResourcesTag struct {
	Value string `name:"Value"`
	Key   string `name:"Key"`
}

TagResourcesTag is a repeated param struct in TagResourcesRequest

type TagVO ¶

type TagVO struct {
	Key   string `json:"Key" xml:"Key"`
	Value string `json:"Value" xml:"Value"`
}

TagVO is a nested struct in alikafka response

type TagsInGetConsumerList ¶

type TagsInGetConsumerList struct {
	TagVO []TagVO `json:"TagVO" xml:"TagVO"`
}

TagsInGetConsumerList is a nested struct in alikafka response

type TagsInGetInstanceList ¶

type TagsInGetInstanceList struct {
	TagVO []TagVO `json:"TagVO" xml:"TagVO"`
}

TagsInGetInstanceList is a nested struct in alikafka response

type TagsInGetTopicList ¶

type TagsInGetTopicList struct {
	TagVO []TagVO `json:"TagVO" xml:"TagVO"`
}

TagsInGetTopicList is a nested struct in alikafka response

type TopicListInGetConsumerProgress ¶

type TopicListInGetConsumerProgress struct {
	TopicListItem []TopicListItem `json:"TopicList" xml:"TopicList"`
}

TopicListInGetConsumerProgress is a nested struct in alikafka response

type TopicListInGetTopicList ¶

type TopicListInGetTopicList struct {
	TopicVO []TopicVO `json:"TopicVO" xml:"TopicVO"`
}

TopicListInGetTopicList is a nested struct in alikafka response

type TopicListItem ¶

type TopicListItem struct {
	TotalDiff     int64      `json:"TotalDiff" xml:"TotalDiff"`
	LastTimestamp int64      `json:"LastTimestamp" xml:"LastTimestamp"`
	Topic         string     `json:"Topic" xml:"Topic"`
	OffsetList    OffsetList `json:"OffsetList" xml:"OffsetList"`
}

TopicListItem is a nested struct in alikafka response

type TopicStatus ¶

type TopicStatus struct {
	TotalCount    int64       `json:"TotalCount" xml:"TotalCount"`
	LastTimeStamp int64       `json:"LastTimeStamp" xml:"LastTimeStamp"`
	OffsetTable   OffsetTable `json:"OffsetTable" xml:"OffsetTable"`
}

TopicStatus is a nested struct in alikafka response

type TopicSubscribeStatus ¶ added in v1.62.711

type TopicSubscribeStatus struct {
	Topic          string   `json:"Topic" xml:"Topic"`
	ConsumerGroups []string `json:"ConsumerGroups" xml:"ConsumerGroups"`
}

TopicSubscribeStatus is a nested struct in alikafka response

type TopicVO ¶

type TopicVO struct {
	Status       int                `json:"Status" xml:"Status"`
	PartitionNum int                `json:"PartitionNum" xml:"PartitionNum"`
	Remark       string             `json:"Remark" xml:"Remark"`
	CreateTime   int64              `json:"CreateTime" xml:"CreateTime"`
	Topic        string             `json:"Topic" xml:"Topic"`
	StatusName   string             `json:"StatusName" xml:"StatusName"`
	CompactTopic bool               `json:"CompactTopic" xml:"CompactTopic"`
	InstanceId   string             `json:"InstanceId" xml:"InstanceId"`
	LocalTopic   bool               `json:"LocalTopic" xml:"LocalTopic"`
	RegionId     string             `json:"RegionId" xml:"RegionId"`
	AutoCreate   bool               `json:"AutoCreate" xml:"AutoCreate"`
	Tags         TagsInGetTopicList `json:"Tags" xml:"Tags"`
}

TopicVO is a nested struct in alikafka response

type UntagResourcesRequest ¶

type UntagResourcesRequest struct {
	*requests.RpcRequest
	All          requests.Boolean `position:"Query" name:"All"`
	ResourceId   *[]string        `position:"Query" name:"ResourceId"  type:"Repeated"`
	ResourceType string           `position:"Query" name:"ResourceType"`
	TagKey       *[]string        `position:"Query" name:"TagKey"  type:"Repeated"`
}

UntagResourcesRequest is the request struct for api UntagResources

func CreateUntagResourcesRequest ¶

func CreateUntagResourcesRequest() (request *UntagResourcesRequest)

CreateUntagResourcesRequest creates a request to invoke UntagResources API

type UntagResourcesResponse ¶

type UntagResourcesResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
}

UntagResourcesResponse is the response struct for api UntagResources

func CreateUntagResourcesResponse ¶

func CreateUntagResourcesResponse() (response *UntagResourcesResponse)

CreateUntagResourcesResponse creates a response to parse from UntagResources response

type UpdateAllowedIpRequest ¶ added in v1.61.349

type UpdateAllowedIpRequest struct {
	*requests.RpcRequest
	PortRange       string `position:"Query" name:"PortRange"`
	AllowedListIp   string `position:"Query" name:"AllowedListIp"`
	UpdateType      string `position:"Query" name:"UpdateType"`
	AllowedListType string `position:"Query" name:"AllowedListType"`
	Description     string `position:"Query" name:"Description"`
	InstanceId      string `position:"Query" name:"InstanceId"`
}

UpdateAllowedIpRequest is the request struct for api UpdateAllowedIp

func CreateUpdateAllowedIpRequest ¶ added in v1.61.349

func CreateUpdateAllowedIpRequest() (request *UpdateAllowedIpRequest)

CreateUpdateAllowedIpRequest creates a request to invoke UpdateAllowedIp API

type UpdateAllowedIpResponse ¶ added in v1.61.349

type UpdateAllowedIpResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

UpdateAllowedIpResponse is the response struct for api UpdateAllowedIp

func CreateUpdateAllowedIpResponse ¶ added in v1.61.349

func CreateUpdateAllowedIpResponse() (response *UpdateAllowedIpResponse)

CreateUpdateAllowedIpResponse creates a response to parse from UpdateAllowedIp response

type UpdateConsumerOffsetOffsets ¶ added in v1.62.293

type UpdateConsumerOffsetOffsets struct {
	Partition string `name:"Partition"`
	Offset    string `name:"Offset"`
}

UpdateConsumerOffsetOffsets is a repeated param struct in UpdateConsumerOffsetRequest

type UpdateConsumerOffsetRequest ¶ added in v1.62.293

type UpdateConsumerOffsetRequest struct {
	*requests.RpcRequest
	ConsumerId string                         `position:"Query" name:"ConsumerId"`
	ResetType  string                         `position:"Query" name:"ResetType"`
	InstanceId string                         `position:"Query" name:"InstanceId"`
	Offsets    *[]UpdateConsumerOffsetOffsets `position:"Query" name:"Offsets"  type:"Json"`
	Topic      string                         `position:"Query" name:"Topic"`
	Time       string                         `position:"Query" name:"Time"`
}

UpdateConsumerOffsetRequest is the request struct for api UpdateConsumerOffset

func CreateUpdateConsumerOffsetRequest ¶ added in v1.62.293

func CreateUpdateConsumerOffsetRequest() (request *UpdateConsumerOffsetRequest)

CreateUpdateConsumerOffsetRequest creates a request to invoke UpdateConsumerOffset API

type UpdateConsumerOffsetResponse ¶ added in v1.62.293

type UpdateConsumerOffsetResponse struct {
	*responses.BaseResponse
	Success   bool   `json:"Success" xml:"Success"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
}

UpdateConsumerOffsetResponse is the response struct for api UpdateConsumerOffset

func CreateUpdateConsumerOffsetResponse ¶ added in v1.62.293

func CreateUpdateConsumerOffsetResponse() (response *UpdateConsumerOffsetResponse)

CreateUpdateConsumerOffsetResponse creates a response to parse from UpdateConsumerOffset response

type UpdateInstanceConfigRequest ¶ added in v1.61.815

type UpdateInstanceConfigRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
	Config     string `position:"Query" name:"Config"`
}

UpdateInstanceConfigRequest is the request struct for api UpdateInstanceConfig

func CreateUpdateInstanceConfigRequest ¶ added in v1.61.815

func CreateUpdateInstanceConfigRequest() (request *UpdateInstanceConfigRequest)

CreateUpdateInstanceConfigRequest creates a request to invoke UpdateInstanceConfig API

type UpdateInstanceConfigResponse ¶ added in v1.61.815

type UpdateInstanceConfigResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

UpdateInstanceConfigResponse is the response struct for api UpdateInstanceConfig

func CreateUpdateInstanceConfigResponse ¶ added in v1.61.815

func CreateUpdateInstanceConfigResponse() (response *UpdateInstanceConfigResponse)

CreateUpdateInstanceConfigResponse creates a response to parse from UpdateInstanceConfig response

type UpdateTopicConfigRequest ¶ added in v1.62.711

type UpdateTopicConfigRequest struct {
	*requests.RpcRequest
	InstanceId string `position:"Query" name:"InstanceId"`
	Topic      string `position:"Query" name:"Topic"`
	Config     string `position:"Query" name:"Config"`
	Value      string `position:"Query" name:"Value"`
}

UpdateTopicConfigRequest is the request struct for api UpdateTopicConfig

func CreateUpdateTopicConfigRequest ¶ added in v1.62.711

func CreateUpdateTopicConfigRequest() (request *UpdateTopicConfigRequest)

CreateUpdateTopicConfigRequest creates a request to invoke UpdateTopicConfig API

type UpdateTopicConfigResponse ¶ added in v1.62.711

type UpdateTopicConfigResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Code      int64  `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	Data      string `json:"Data" xml:"Data"`
}

UpdateTopicConfigResponse is the response struct for api UpdateTopicConfig

func CreateUpdateTopicConfigResponse ¶ added in v1.62.711

func CreateUpdateTopicConfigResponse() (response *UpdateTopicConfigResponse)

CreateUpdateTopicConfigResponse creates a response to parse from UpdateTopicConfig response

type UpgradeInstanceVersionRequest ¶ added in v1.61.815

type UpgradeInstanceVersionRequest struct {
	*requests.RpcRequest
	TargetVersion string `position:"Query" name:"TargetVersion"`
	InstanceId    string `position:"Query" name:"InstanceId"`
}

UpgradeInstanceVersionRequest is the request struct for api UpgradeInstanceVersion

func CreateUpgradeInstanceVersionRequest ¶ added in v1.61.815

func CreateUpgradeInstanceVersionRequest() (request *UpgradeInstanceVersionRequest)

CreateUpgradeInstanceVersionRequest creates a request to invoke UpgradeInstanceVersion API

type UpgradeInstanceVersionResponse ¶ added in v1.61.815

type UpgradeInstanceVersionResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

UpgradeInstanceVersionResponse is the response struct for api UpgradeInstanceVersion

func CreateUpgradeInstanceVersionResponse ¶ added in v1.61.815

func CreateUpgradeInstanceVersionResponse() (response *UpgradeInstanceVersionResponse)

CreateUpgradeInstanceVersionResponse creates a response to parse from UpgradeInstanceVersion response

type UpgradePostPayOrderRequest ¶

type UpgradePostPayOrderRequest struct {
	*requests.RpcRequest
	ServerlessConfig UpgradePostPayOrderServerlessConfig `position:"Query" name:"ServerlessConfig"  type:"Struct"`
	DiskSize         requests.Integer                    `position:"Query" name:"DiskSize"`
	IoMax            requests.Integer                    `position:"Query" name:"IoMax"`
	EipModel         requests.Boolean                    `position:"Query" name:"EipModel"`
	IoMaxSpec        string                              `position:"Query" name:"IoMaxSpec"`
	TopicQuota       requests.Integer                    `position:"Query" name:"TopicQuota"`
	EipMax           requests.Integer                    `position:"Query" name:"EipMax"`
	SpecType         string                              `position:"Query" name:"SpecType"`
	InstanceId       string                              `position:"Query" name:"InstanceId"`
	PartitionNum     requests.Integer                    `position:"Query" name:"PartitionNum"`
}

UpgradePostPayOrderRequest is the request struct for api UpgradePostPayOrder

func CreateUpgradePostPayOrderRequest ¶

func CreateUpgradePostPayOrderRequest() (request *UpgradePostPayOrderRequest)

CreateUpgradePostPayOrderRequest creates a request to invoke UpgradePostPayOrder API

type UpgradePostPayOrderResponse ¶

type UpgradePostPayOrderResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

UpgradePostPayOrderResponse is the response struct for api UpgradePostPayOrder

func CreateUpgradePostPayOrderResponse ¶

func CreateUpgradePostPayOrderResponse() (response *UpgradePostPayOrderResponse)

CreateUpgradePostPayOrderResponse creates a response to parse from UpgradePostPayOrder response

type UpgradePostPayOrderServerlessConfig ¶ added in v1.62.711

type UpgradePostPayOrderServerlessConfig struct {
	ReservedPublishCapacity   string `name:"ReservedPublishCapacity"`
	ReservedSubscribeCapacity string `name:"ReservedSubscribeCapacity"`
}

UpgradePostPayOrderServerlessConfig is a repeated param struct in UpgradePostPayOrderRequest

type UpgradePrePayOrderConfluentConfig ¶ added in v1.62.711

type UpgradePrePayOrderConfluentConfig struct {
	KsqlStorage           string `name:"KsqlStorage"`
	ControlCenterStorage  string `name:"ControlCenterStorage"`
	KafkaRestProxyReplica string `name:"KafkaRestProxyReplica"`
	ZooKeeperReplica      string `name:"ZooKeeperReplica"`
	ConnectCU             string `name:"ConnectCU"`
	KafkaReplica          string `name:"KafkaReplica"`
	SchemaRegistryReplica string `name:"SchemaRegistryReplica"`
	KafkaCU               string `name:"KafkaCU"`
	ConnectReplica        string `name:"ConnectReplica"`
	ControlCenterCU       string `name:"ControlCenterCU"`
	KsqlReplica           string `name:"KsqlReplica"`
	ControlCenterReplica  string `name:"ControlCenterReplica"`
	KafkaStorage          string `name:"KafkaStorage"`
	ZooKeeperStorage      string `name:"ZooKeeperStorage"`
	KsqlCU                string `name:"KsqlCU"`
	SchemaRegistryCU      string `name:"SchemaRegistryCU"`
	ZooKeeperCU           string `name:"ZooKeeperCU"`
	KafkaRestProxyCU      string `name:"KafkaRestProxyCU"`
}

UpgradePrePayOrderConfluentConfig is a repeated param struct in UpgradePrePayOrderRequest

type UpgradePrePayOrderRequest ¶ added in v1.60.294

type UpgradePrePayOrderRequest struct {
	*requests.RpcRequest
	IoMax           requests.Integer                  `position:"Query" name:"IoMax"`
	EipModel        requests.Boolean                  `position:"Query" name:"EipModel"`
	EipMax          requests.Integer                  `position:"Query" name:"EipMax"`
	SpecType        string                            `position:"Query" name:"SpecType"`
	ConfluentConfig UpgradePrePayOrderConfluentConfig `position:"Query" name:"ConfluentConfig"  type:"Struct"`
	PartitionNum    requests.Integer                  `position:"Query" name:"PartitionNum"`
	PaidType        requests.Integer                  `position:"Query" name:"PaidType"`
	DiskSize        requests.Integer                  `position:"Query" name:"DiskSize"`
	IoMaxSpec       string                            `position:"Query" name:"IoMaxSpec"`
	TopicQuota      requests.Integer                  `position:"Query" name:"TopicQuota"`
	InstanceId      string                            `position:"Query" name:"InstanceId"`
}

UpgradePrePayOrderRequest is the request struct for api UpgradePrePayOrder

func CreateUpgradePrePayOrderRequest ¶ added in v1.60.294

func CreateUpgradePrePayOrderRequest() (request *UpgradePrePayOrderRequest)

CreateUpgradePrePayOrderRequest creates a request to invoke UpgradePrePayOrder API

type UpgradePrePayOrderResponse ¶ added in v1.60.294

type UpgradePrePayOrderResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

UpgradePrePayOrderResponse is the response struct for api UpgradePrePayOrder

func CreateUpgradePrePayOrderResponse ¶ added in v1.60.294

func CreateUpgradePrePayOrderResponse() (response *UpgradePrePayOrderResponse)

CreateUpgradePrePayOrderResponse creates a response to parse from UpgradePrePayOrder response

type UpgradeServiceDetailInfo ¶

type UpgradeServiceDetailInfo struct {
	Current2OpenSourceVersion string `json:"Current2OpenSourceVersion" xml:"Current2OpenSourceVersion"`
}

UpgradeServiceDetailInfo is a nested struct in alikafka response

type VpcList ¶ added in v1.61.349

type VpcList struct {
	IPListVO []IPListVO `json:"IPListVO" xml:"IPListVO"`
}

VpcList is a nested struct in alikafka response

Source Files ¶

View all Source files

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