alikafka

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

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 

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

AllowedIpListInGetAllowedIpList is a nested struct in alikafka response

type AllowedList 

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 

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 

func CreateChangeResourceGroupRequest() (request *ChangeResourceGroupRequest)

CreateChangeResourceGroupRequest creates a request to invoke ChangeResourceGroup API

type ChangeResourceGroupResponse 

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 

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 

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

ChangeResourceGroup invokes the alikafka.ChangeResourceGroup API synchronously

func (*Client) ChangeResourceGroupWithCallback 

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

ChangeResourceGroupWithCallback invokes the alikafka.ChangeResourceGroup API asynchronously

func (*Client) ChangeResourceGroupWithChan 

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 

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

CreateAcl invokes the alikafka.CreateAcl API synchronously

func (*Client) CreateAclWithCallback 

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

CreateAclWithCallback invokes the alikafka.CreateAcl API asynchronously

func (*Client) CreateAclWithChan 

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 

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

CreatePrePayOrder invokes the alikafka.CreatePrePayOrder API synchronously

func (*Client) CreatePrePayOrderWithCallback 

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

CreatePrePayOrderWithCallback invokes the alikafka.CreatePrePayOrder API asynchronously

func (*Client) CreatePrePayOrderWithChan 

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

CreatePrePayOrderWithChan invokes the alikafka.CreatePrePayOrder API asynchronously

func (*Client) CreateSaslUser 

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

CreateSaslUser invokes the alikafka.CreateSaslUser API synchronously

func (*Client) CreateSaslUserWithCallback 

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

CreateSaslUserWithCallback invokes the alikafka.CreateSaslUser API asynchronously

func (*Client) CreateSaslUserWithChan 

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 

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

DeleteAcl invokes the alikafka.DeleteAcl API synchronously

func (*Client) DeleteAclWithCallback 

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

DeleteAclWithCallback invokes the alikafka.DeleteAcl API asynchronously

func (*Client) DeleteAclWithChan 

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 

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

DeleteInstance invokes the alikafka.DeleteInstance API synchronously

func (*Client) DeleteInstanceWithCallback 

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

DeleteInstanceWithCallback invokes the alikafka.DeleteInstance API asynchronously

func (*Client) DeleteInstanceWithChan 

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

DeleteInstanceWithChan invokes the alikafka.DeleteInstance API asynchronously

func (*Client) DeleteSaslUser 

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

DeleteSaslUser invokes the alikafka.DeleteSaslUser API synchronously

func (*Client) DeleteSaslUserWithCallback 

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

DeleteSaslUserWithCallback invokes the alikafka.DeleteSaslUser API asynchronously

func (*Client) DeleteSaslUserWithChan 

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 

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

DescribeAcls invokes the alikafka.DescribeAcls API synchronously

func (*Client) DescribeAclsWithCallback 

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

DescribeAclsWithCallback invokes the alikafka.DescribeAcls API asynchronously

func (*Client) DescribeAclsWithChan 

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

DescribeAclsWithChan invokes the alikafka.DescribeAcls API asynchronously

func (*Client) DescribeSaslUsers 

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

DescribeSaslUsers invokes the alikafka.DescribeSaslUsers API synchronously

func (*Client) DescribeSaslUsersWithCallback 

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

DescribeSaslUsersWithCallback invokes the alikafka.DescribeSaslUsers API asynchronously

func (*Client) DescribeSaslUsersWithChan 

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

DescribeSaslUsersWithChan invokes the alikafka.DescribeSaslUsers API asynchronously

func (*Client) GetAllInstanceIdList 

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

GetAllInstanceIdList invokes the alikafka.GetAllInstanceIdList API synchronously

func (*Client) GetAllInstanceIdListWithCallback 

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

GetAllInstanceIdListWithCallback invokes the alikafka.GetAllInstanceIdList API asynchronously

func (*Client) GetAllInstanceIdListWithChan 

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

GetAllInstanceIdListWithChan invokes the alikafka.GetAllInstanceIdList API asynchronously

func (*Client) GetAllowedIpList 

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

GetAllowedIpList invokes the alikafka.GetAllowedIpList API synchronously

func (*Client) GetAllowedIpListWithCallback 

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

GetAllowedIpListWithCallback invokes the alikafka.GetAllowedIpList API asynchronously

func (*Client) GetAllowedIpListWithChan 

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 

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

GetQuotaTip invokes the alikafka.GetQuotaTip API synchronously

func (*Client) GetQuotaTipWithCallback 

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

GetQuotaTipWithCallback invokes the alikafka.GetQuotaTip API asynchronously

func (*Client) GetQuotaTipWithChan 

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) 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 

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

ModifyPartitionNum invokes the alikafka.ModifyPartitionNum API synchronously

func (*Client) ModifyPartitionNumWithCallback 

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

ModifyPartitionNumWithCallback invokes the alikafka.ModifyPartitionNum API asynchronously

func (*Client) ModifyPartitionNumWithChan 

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

ModifyPartitionNumWithChan invokes the alikafka.ModifyPartitionNum API asynchronously

func (*Client) ModifyTopicRemark 

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

ModifyTopicRemark invokes the alikafka.ModifyTopicRemark API synchronously

func (*Client) ModifyTopicRemarkWithCallback 

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

ModifyTopicRemarkWithCallback invokes the alikafka.ModifyTopicRemark API asynchronously

func (*Client) ModifyTopicRemarkWithChan 

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

ModifyTopicRemarkWithChan invokes the alikafka.ModifyTopicRemark 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) 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) 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 

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

UpdateAllowedIp invokes the alikafka.UpdateAllowedIp API synchronously

func (*Client) UpdateAllowedIpWithCallback 

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

UpdateAllowedIpWithCallback invokes the alikafka.UpdateAllowedIp API asynchronously

func (*Client) UpdateAllowedIpWithChan 

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

UpdateAllowedIpWithChan invokes the alikafka.UpdateAllowedIp API asynchronously

func (*Client) UpdateInstanceConfig 

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

UpdateInstanceConfig invokes the alikafka.UpdateInstanceConfig API synchronously

func (*Client) UpdateInstanceConfigWithCallback 

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

UpdateInstanceConfigWithCallback invokes the alikafka.UpdateInstanceConfig API asynchronously

func (*Client) UpdateInstanceConfigWithChan 

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

UpdateInstanceConfigWithChan invokes the alikafka.UpdateInstanceConfig API asynchronously

func (*Client) UpgradeInstanceVersion 

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

UpgradeInstanceVersion invokes the alikafka.UpgradeInstanceVersion API synchronously

func (*Client) UpgradeInstanceVersionWithCallback 

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

UpgradeInstanceVersionWithCallback invokes the alikafka.UpgradeInstanceVersion API asynchronously

func (*Client) UpgradeInstanceVersionWithChan 

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 

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

UpgradePrePayOrder invokes the alikafka.UpgradePrePayOrder API synchronously

func (*Client) UpgradePrePayOrderWithCallback 

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

UpgradePrePayOrderWithCallback invokes the alikafka.UpgradePrePayOrder API asynchronously

func (*Client) UpgradePrePayOrderWithChan 

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

UpgradePrePayOrderWithChan invokes the alikafka.UpgradePrePayOrder API asynchronously

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"`
}

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"`
	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 

type CreateAclRequest 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"`
	Username               string `position:"Query" name:"Username"`
}

CreateAclRequest is the request struct for api CreateAcl

func CreateCreateAclRequest 

func CreateCreateAclRequest() (request *CreateAclRequest)

CreateCreateAclRequest creates a request to invoke CreateAcl API

type CreateAclResponse 

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 

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 

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 

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

CreatePostPayOrderTag is a repeated param struct in CreatePostPayOrderRequest

type CreatePrePayOrderRequest 

type CreatePrePayOrderRequest 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             *[]CreatePrePayOrderTag `position:"Query" name:"Tag"  type:"Repeated"`
	PartitionNum    requests.Integer        `position:"Query" name:"PartitionNum"`
	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 

func CreateCreatePrePayOrderRequest() (request *CreatePrePayOrderRequest)

CreateCreatePrePayOrderRequest creates a request to invoke CreatePrePayOrder API

type CreatePrePayOrderResponse 

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 

func CreateCreatePrePayOrderResponse() (response *CreatePrePayOrderResponse)

CreateCreatePrePayOrderResponse creates a response to parse from CreatePrePayOrder response

type CreatePrePayOrderTag 

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

CreatePrePayOrderTag is a repeated param struct in CreatePrePayOrderRequest

type CreateSaslUserRequest 

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

CreateSaslUserRequest is the request struct for api CreateSaslUser

func CreateCreateSaslUserRequest 

func CreateCreateSaslUserRequest() (request *CreateSaslUserRequest)

CreateCreateSaslUserRequest creates a request to invoke CreateSaslUser API

type CreateSaslUserResponse 

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 

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 

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

CreateTopicTag is a repeated param struct in CreateTopicRequest

type DeleteAclRequest 

type DeleteAclRequest 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"`
	Username               string `position:"Query" name:"Username"`
}

DeleteAclRequest is the request struct for api DeleteAcl

func CreateDeleteAclRequest 

func CreateDeleteAclRequest() (request *DeleteAclRequest)

CreateDeleteAclRequest creates a request to invoke DeleteAcl API

type DeleteAclResponse 

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 

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 

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

DeleteInstanceRequest is the request struct for api DeleteInstance

func CreateDeleteInstanceRequest 

func CreateDeleteInstanceRequest() (request *DeleteInstanceRequest)

CreateDeleteInstanceRequest creates a request to invoke DeleteInstance API

type DeleteInstanceResponse 

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 

func CreateDeleteInstanceResponse() (response *DeleteInstanceResponse)

CreateDeleteInstanceResponse creates a response to parse from DeleteInstance response

type DeleteSaslUserRequest 

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

DeleteSaslUserRequest is the request struct for api DeleteSaslUser

func CreateDeleteSaslUserRequest 

func CreateDeleteSaslUserRequest() (request *DeleteSaslUserRequest)

CreateDeleteSaslUserRequest creates a request to invoke DeleteSaslUser API

type DeleteSaslUserResponse 

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 

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 

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

DescribeAclsRequest is the request struct for api DescribeAcls

func CreateDescribeAclsRequest 

func CreateDescribeAclsRequest() (request *DescribeAclsRequest)

CreateDescribeAclsRequest creates a request to invoke DescribeAcls API

type DescribeAclsResponse 

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 

func CreateDescribeAclsResponse() (response *DescribeAclsResponse)

CreateDescribeAclsResponse creates a response to parse from DescribeAcls response

type DescribeSaslUsersRequest 

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

DescribeSaslUsersRequest is the request struct for api DescribeSaslUsers

func CreateDescribeSaslUsersRequest 

func CreateDescribeSaslUsersRequest() (request *DescribeSaslUsersRequest)

CreateDescribeSaslUsersRequest creates a request to invoke DescribeSaslUsers API

type DescribeSaslUsersResponse 

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 

func CreateDescribeSaslUsersResponse() (response *DescribeSaslUsersResponse)

CreateDescribeSaslUsersResponse creates a response to parse from DescribeSaslUsers response

type GetAllInstanceIdListRequest 

type GetAllInstanceIdListRequest struct {
	*requests.RpcRequest
}

GetAllInstanceIdListRequest is the request struct for api GetAllInstanceIdList

func CreateGetAllInstanceIdListRequest 

func CreateGetAllInstanceIdListRequest() (request *GetAllInstanceIdListRequest)

CreateGetAllInstanceIdListRequest creates a request to invoke GetAllInstanceIdList API

type GetAllInstanceIdListResponse 

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 

func CreateGetAllInstanceIdListResponse() (response *GetAllInstanceIdListResponse)

CreateGetAllInstanceIdListResponse creates a response to parse from GetAllInstanceIdList response

type GetAllowedIpListRequest 

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

GetAllowedIpListRequest is the request struct for api GetAllowedIpList

func CreateGetAllowedIpListRequest 

func CreateGetAllowedIpListRequest() (request *GetAllowedIpListRequest)

CreateGetAllowedIpListRequest creates a request to invoke GetAllowedIpList API

type GetAllowedIpListResponse 

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 

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"`
	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 

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

GetInstanceListTag is a repeated param struct in GetInstanceListRequest

type GetQuotaTipRequest 

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

GetQuotaTipRequest is the request struct for api GetQuotaTip

func CreateGetQuotaTipRequest 

func CreateGetQuotaTipRequest() (request *GetQuotaTipRequest)

CreateGetQuotaTipRequest creates a request to invoke GetQuotaTip API

type GetQuotaTipResponse 

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 

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 IPListVO 

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"`
	UpgradeServiceDetailInfo UpgradeServiceDetailInfo `json:"UpgradeServiceDetailInfo" xml:"UpgradeServiceDetailInfo"`
	Tags                     TagsInGetInstanceList    `json:"Tags" xml:"Tags"`
}

InstanceVO is a nested struct in alikafka response

type InternetList 

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

InternetList is a nested struct in alikafka response

type KafkaAclList 

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

KafkaAclList is a nested struct in alikafka response

type KafkaAclVO 

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"`
}

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 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 

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 

func CreateModifyPartitionNumRequest() (request *ModifyPartitionNumRequest)

CreateModifyPartitionNumRequest creates a request to invoke ModifyPartitionNum API

type ModifyPartitionNumResponse 

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 

func CreateModifyPartitionNumResponse() (response *ModifyPartitionNumResponse)

CreateModifyPartitionNumResponse creates a response to parse from ModifyPartitionNum response

type ModifyTopicRemarkRequest 

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

ModifyTopicRemarkRequest is the request struct for api ModifyTopicRemark

func CreateModifyTopicRemarkRequest 

func CreateModifyTopicRemarkRequest() (request *ModifyTopicRemarkRequest)

CreateModifyTopicRemarkRequest creates a request to invoke ModifyTopicRemark API

type ModifyTopicRemarkResponse 

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 

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 QuotaData 

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"`
}

QuotaData 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 SaslUserList 

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

SaslUserList is a nested struct in alikafka response

type SaslUserVO 

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

SaslUserVO is a nested struct in alikafka response

type StartInstanceRequest 

type StartInstanceRequest struct {
	*requests.RpcRequest
	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 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 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"`
	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 

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 

func CreateUpdateAllowedIpRequest() (request *UpdateAllowedIpRequest)

CreateUpdateAllowedIpRequest creates a request to invoke UpdateAllowedIp API

type UpdateAllowedIpResponse 

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 

func CreateUpdateAllowedIpResponse() (response *UpdateAllowedIpResponse)

CreateUpdateAllowedIpResponse creates a response to parse from UpdateAllowedIp response

type UpdateInstanceConfigRequest 

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 

func CreateUpdateInstanceConfigRequest() (request *UpdateInstanceConfigRequest)

CreateUpdateInstanceConfigRequest creates a request to invoke UpdateInstanceConfig API

type UpdateInstanceConfigResponse 

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 

func CreateUpdateInstanceConfigResponse() (response *UpdateInstanceConfigResponse)

CreateUpdateInstanceConfigResponse creates a response to parse from UpdateInstanceConfig response

type UpgradeInstanceVersionRequest 

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 

func CreateUpgradeInstanceVersionRequest() (request *UpgradeInstanceVersionRequest)

CreateUpgradeInstanceVersionRequest creates a request to invoke UpgradeInstanceVersion API

type UpgradeInstanceVersionResponse 

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 

func CreateUpgradeInstanceVersionResponse() (response *UpgradeInstanceVersionResponse)

CreateUpgradeInstanceVersionResponse creates a response to parse from UpgradeInstanceVersion response

type UpgradePostPayOrderRequest 

type UpgradePostPayOrderRequest struct {
	*requests.RpcRequest
	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 UpgradePrePayOrderRequest 

type UpgradePrePayOrderRequest struct {
	*requests.RpcRequest
	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"`
}

UpgradePrePayOrderRequest is the request struct for api UpgradePrePayOrder

func CreateUpgradePrePayOrderRequest 

func CreateUpgradePrePayOrderRequest() (request *UpgradePrePayOrderRequest)

CreateUpgradePrePayOrderRequest creates a request to invoke UpgradePrePayOrder API

type UpgradePrePayOrderResponse 

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 

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 

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

VpcList is a nested struct in alikafka response

Source Files

View all Source files

Jump to

Keyboard shortcuts

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