alikafka

package
v1.62.733 Latest Latest
Warning

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

Go to latest
Published: May 8, 2024 License: Apache-2.0 Imports: 6 Imported by: 9

Documentation

Index

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

Jump to

Keyboard shortcuts

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