Documentation
¶
Index ¶
- Variables
- func GetEndpointMap() map[string]string
- func GetEndpointType() string
- func SetClientProperty(client *Client, propertyName string, propertyValue interface{})
- func SetEndpointDataToClient(client *Client)
- type BindingDO
- type BindingVO
- type BindingsInListBindings
- type BindingsInListDownStreamBindings
- type BindingsInListExchangeUpStreamBindings
- type BindingsInListQueueUpStreamBindings
- type Client
- func NewClient() (client *Client, err error)
- func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
- func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)
- func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
- func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
- func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
- func NewClientWithRamRoleArnAndPolicy(regionId string, ...) (client *Client, err error)
- func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
- func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
- func (client *Client) CreateAccount(request *CreateAccountRequest) (response *CreateAccountResponse, err error)
- func (client *Client) CreateAccountWithCallback(request *CreateAccountRequest, ...) <-chan int
- func (client *Client) CreateAccountWithChan(request *CreateAccountRequest) (<-chan *CreateAccountResponse, <-chan error)
- func (client *Client) CreateBinding(request *CreateBindingRequest) (response *CreateBindingResponse, err error)
- func (client *Client) CreateBindingWithCallback(request *CreateBindingRequest, ...) <-chan int
- func (client *Client) CreateBindingWithChan(request *CreateBindingRequest) (<-chan *CreateBindingResponse, <-chan error)
- func (client *Client) CreateExchange(request *CreateExchangeRequest) (response *CreateExchangeResponse, err error)
- func (client *Client) CreateExchangeWithCallback(request *CreateExchangeRequest, ...) <-chan int
- func (client *Client) CreateExchangeWithChan(request *CreateExchangeRequest) (<-chan *CreateExchangeResponse, <-chan error)
- func (client *Client) CreateInstance(request *CreateInstanceRequest) (response *CreateInstanceResponse, err error)
- func (client *Client) CreateInstanceWithCallback(request *CreateInstanceRequest, ...) <-chan int
- func (client *Client) CreateInstanceWithChan(request *CreateInstanceRequest) (<-chan *CreateInstanceResponse, <-chan error)
- func (client *Client) CreateQueue(request *CreateQueueRequest) (response *CreateQueueResponse, err error)
- func (client *Client) CreateQueueWithCallback(request *CreateQueueRequest, ...) <-chan int
- func (client *Client) CreateQueueWithChan(request *CreateQueueRequest) (<-chan *CreateQueueResponse, <-chan error)
- func (client *Client) CreateVirtualHost(request *CreateVirtualHostRequest) (response *CreateVirtualHostResponse, err error)
- func (client *Client) CreateVirtualHostWithCallback(request *CreateVirtualHostRequest, ...) <-chan int
- func (client *Client) CreateVirtualHostWithChan(request *CreateVirtualHostRequest) (<-chan *CreateVirtualHostResponse, <-chan error)
- func (client *Client) DeleteAccount(request *DeleteAccountRequest) (response *DeleteAccountResponse, err error)
- func (client *Client) DeleteAccountWithCallback(request *DeleteAccountRequest, ...) <-chan int
- func (client *Client) DeleteAccountWithChan(request *DeleteAccountRequest) (<-chan *DeleteAccountResponse, <-chan error)
- func (client *Client) DeleteBinding(request *DeleteBindingRequest) (response *DeleteBindingResponse, err error)
- func (client *Client) DeleteBindingWithCallback(request *DeleteBindingRequest, ...) <-chan int
- func (client *Client) DeleteBindingWithChan(request *DeleteBindingRequest) (<-chan *DeleteBindingResponse, <-chan error)
- func (client *Client) DeleteExchange(request *DeleteExchangeRequest) (response *DeleteExchangeResponse, err error)
- func (client *Client) DeleteExchangeWithCallback(request *DeleteExchangeRequest, ...) <-chan int
- func (client *Client) DeleteExchangeWithChan(request *DeleteExchangeRequest) (<-chan *DeleteExchangeResponse, <-chan error)
- func (client *Client) DeleteQueue(request *DeleteQueueRequest) (response *DeleteQueueResponse, err error)
- func (client *Client) DeleteQueueWithCallback(request *DeleteQueueRequest, ...) <-chan int
- func (client *Client) DeleteQueueWithChan(request *DeleteQueueRequest) (<-chan *DeleteQueueResponse, <-chan error)
- func (client *Client) DeleteVirtualHost(request *DeleteVirtualHostRequest) (response *DeleteVirtualHostResponse, err error)
- func (client *Client) DeleteVirtualHostWithCallback(request *DeleteVirtualHostRequest, ...) <-chan int
- func (client *Client) DeleteVirtualHostWithChan(request *DeleteVirtualHostRequest) (<-chan *DeleteVirtualHostResponse, <-chan error)
- func (client *Client) GetMetadataAmount(request *GetMetadataAmountRequest) (response *GetMetadataAmountResponse, err error)
- func (client *Client) GetMetadataAmountWithCallback(request *GetMetadataAmountRequest, ...) <-chan int
- func (client *Client) GetMetadataAmountWithChan(request *GetMetadataAmountRequest) (<-chan *GetMetadataAmountResponse, <-chan error)
- func (client *Client) ListAccounts(request *ListAccountsRequest) (response *ListAccountsResponse, err error)
- func (client *Client) ListAccountsWithCallback(request *ListAccountsRequest, ...) <-chan int
- func (client *Client) ListAccountsWithChan(request *ListAccountsRequest) (<-chan *ListAccountsResponse, <-chan error)
- func (client *Client) ListBindings(request *ListBindingsRequest) (response *ListBindingsResponse, err error)
- func (client *Client) ListBindingsWithCallback(request *ListBindingsRequest, ...) <-chan int
- func (client *Client) ListBindingsWithChan(request *ListBindingsRequest) (<-chan *ListBindingsResponse, <-chan error)
- func (client *Client) ListDownStreamBindings(request *ListDownStreamBindingsRequest) (response *ListDownStreamBindingsResponse, err error)
- func (client *Client) ListDownStreamBindingsWithCallback(request *ListDownStreamBindingsRequest, ...) <-chan int
- func (client *Client) ListDownStreamBindingsWithChan(request *ListDownStreamBindingsRequest) (<-chan *ListDownStreamBindingsResponse, <-chan error)
- func (client *Client) ListExchangeUpStreamBindings(request *ListExchangeUpStreamBindingsRequest) (response *ListExchangeUpStreamBindingsResponse, err error)
- func (client *Client) ListExchangeUpStreamBindingsWithCallback(request *ListExchangeUpStreamBindingsRequest, ...) <-chan int
- func (client *Client) ListExchangeUpStreamBindingsWithChan(request *ListExchangeUpStreamBindingsRequest) (<-chan *ListExchangeUpStreamBindingsResponse, <-chan error)
- func (client *Client) ListExchanges(request *ListExchangesRequest) (response *ListExchangesResponse, err error)
- func (client *Client) ListExchangesWithCallback(request *ListExchangesRequest, ...) <-chan int
- func (client *Client) ListExchangesWithChan(request *ListExchangesRequest) (<-chan *ListExchangesResponse, <-chan error)
- func (client *Client) ListInstances(request *ListInstancesRequest) (response *ListInstancesResponse, err error)
- func (client *Client) ListInstancesWithCallback(request *ListInstancesRequest, ...) <-chan int
- func (client *Client) ListInstancesWithChan(request *ListInstancesRequest) (<-chan *ListInstancesResponse, <-chan error)
- func (client *Client) ListQueueConsumers(request *ListQueueConsumersRequest) (response *ListQueueConsumersResponse, err error)
- func (client *Client) ListQueueConsumersWithCallback(request *ListQueueConsumersRequest, ...) <-chan int
- func (client *Client) ListQueueConsumersWithChan(request *ListQueueConsumersRequest) (<-chan *ListQueueConsumersResponse, <-chan error)
- func (client *Client) ListQueueUpStreamBindings(request *ListQueueUpStreamBindingsRequest) (response *ListQueueUpStreamBindingsResponse, err error)
- func (client *Client) ListQueueUpStreamBindingsWithCallback(request *ListQueueUpStreamBindingsRequest, ...) <-chan int
- func (client *Client) ListQueueUpStreamBindingsWithChan(request *ListQueueUpStreamBindingsRequest) (<-chan *ListQueueUpStreamBindingsResponse, <-chan error)
- func (client *Client) ListQueues(request *ListQueuesRequest) (response *ListQueuesResponse, err error)
- func (client *Client) ListQueuesWithCallback(request *ListQueuesRequest, ...) <-chan int
- func (client *Client) ListQueuesWithChan(request *ListQueuesRequest) (<-chan *ListQueuesResponse, <-chan error)
- func (client *Client) ListVirtualHosts(request *ListVirtualHostsRequest) (response *ListVirtualHostsResponse, err error)
- func (client *Client) ListVirtualHostsWithCallback(request *ListVirtualHostsRequest, ...) <-chan int
- func (client *Client) ListVirtualHostsWithChan(request *ListVirtualHostsRequest) (<-chan *ListVirtualHostsResponse, <-chan error)
- func (client *Client) UpdateInstanceName(request *UpdateInstanceNameRequest) (response *UpdateInstanceNameResponse, err error)
- func (client *Client) UpdateInstanceNameWithCallback(request *UpdateInstanceNameRequest, ...) <-chan int
- func (client *Client) UpdateInstanceNameWithChan(request *UpdateInstanceNameRequest) (<-chan *UpdateInstanceNameResponse, <-chan error)
- type Consumers
- type CreateAccountRequest
- type CreateAccountResponse
- type CreateBindingRequest
- type CreateBindingResponse
- type CreateExchangeRequest
- type CreateExchangeResponse
- type CreateInstanceRequest
- type CreateInstanceResponse
- type CreateQueueRequest
- type CreateQueueResponse
- type CreateVirtualHostRequest
- type CreateVirtualHostResponse
- type Data
- type DataInListDownStreamBindings
- type DataInListExchangeUpStreamBindings
- type DataInListQueueUpStreamBindings
- type DeleteAccountRequest
- type DeleteAccountResponse
- type DeleteBindingRequest
- type DeleteBindingResponse
- type DeleteExchangeRequest
- type DeleteExchangeResponse
- type DeleteQueueRequest
- type DeleteQueueResponse
- type DeleteVirtualHostRequest
- type DeleteVirtualHostResponse
- type ExchangeVO
- type Exchanges
- type GetMetadataAmountRequest
- type GetMetadataAmountResponse
- type InstanceVO
- type Instances
- type ListAccountsRequest
- type ListAccountsResponse
- type ListBindingsRequest
- type ListBindingsResponse
- type ListDownStreamBindingsRequest
- type ListDownStreamBindingsResponse
- type ListExchangeUpStreamBindingsRequest
- type ListExchangeUpStreamBindingsResponse
- type ListExchangesRequest
- type ListExchangesResponse
- type ListInstancesRequest
- type ListInstancesResponse
- type ListQueueConsumersRequest
- type ListQueueConsumersResponse
- type ListQueueUpStreamBindingsRequest
- type ListQueueUpStreamBindingsResponse
- type ListQueuesRequest
- type ListQueuesResponse
- type ListVirtualHostsRequest
- type ListVirtualHostsResponse
- type QueueConsumerVO
- type QueueVO
- type Queues
- type Tags
- type TagsItem
- type UpdateInstanceNameRequest
- type UpdateInstanceNameResponse
- type VhostVO
- type VirtualHosts
Constants ¶
This section is empty.
Variables ¶
var EndpointMap map[string]string
EndpointMap Endpoint Data
var EndpointType = "regional"
EndpointType regional or central
Functions ¶
func SetClientProperty ¶
SetClientProperty Set Property by Reflect
func SetEndpointDataToClient ¶
func SetEndpointDataToClient(client *Client)
SetEndpointDataToClient Set EndpointMap and ENdpointType
Types ¶
type BindingDO ¶
type BindingDO struct { SourceExchange string `json:"SourceExchange" xml:"SourceExchange"` Argument string `json:"Argument" xml:"Argument"` BindingKey string `json:"BindingKey" xml:"BindingKey"` BindingType string `json:"BindingType" xml:"BindingType"` DestinationName string `json:"DestinationName" xml:"DestinationName"` }
BindingDO is a nested struct in amqp_open response
type BindingVO ¶
type BindingVO struct { DestinationName string `json:"DestinationName" xml:"DestinationName"` BindingKey string `json:"BindingKey" xml:"BindingKey"` Argument string `json:"Argument" xml:"Argument"` BindingType string `json:"BindingType" xml:"BindingType"` SourceExchange string `json:"SourceExchange" xml:"SourceExchange"` }
BindingVO is a nested struct in amqp_open response
type BindingsInListBindings ¶
type BindingsInListBindings struct {
BindingDO []BindingDO `json:"BindingDO" xml:"BindingDO"`
}
BindingsInListBindings is a nested struct in amqp_open response
type BindingsInListDownStreamBindings ¶
type BindingsInListDownStreamBindings struct {
BindingVO []BindingVO `json:"BindingVO" xml:"BindingVO"`
}
BindingsInListDownStreamBindings is a nested struct in amqp_open response
type BindingsInListExchangeUpStreamBindings ¶
type BindingsInListExchangeUpStreamBindings struct {
BindingVO []BindingVO `json:"BindingVO" xml:"BindingVO"`
}
BindingsInListExchangeUpStreamBindings is a nested struct in amqp_open response
type BindingsInListQueueUpStreamBindings ¶
type BindingsInListQueueUpStreamBindings struct {
BindingVO []BindingVO `json:"BindingVO" xml:"BindingVO"`
}
BindingsInListQueueUpStreamBindings is a nested struct in amqp_open response
type Client ¶
Client is the sdk client struct, each func corresponds to an OpenAPI
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 ¶
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) CreateAccount ¶ added in v1.62.604
func (client *Client) CreateAccount(request *CreateAccountRequest) (response *CreateAccountResponse, err error)
CreateAccount invokes the amqp_open.CreateAccount API synchronously
func (*Client) CreateAccountWithCallback ¶ added in v1.62.604
func (client *Client) CreateAccountWithCallback(request *CreateAccountRequest, callback func(response *CreateAccountResponse, err error)) <-chan int
CreateAccountWithCallback invokes the amqp_open.CreateAccount API asynchronously
func (*Client) CreateAccountWithChan ¶ added in v1.62.604
func (client *Client) CreateAccountWithChan(request *CreateAccountRequest) (<-chan *CreateAccountResponse, <-chan error)
CreateAccountWithChan invokes the amqp_open.CreateAccount API asynchronously
func (*Client) CreateBinding ¶
func (client *Client) CreateBinding(request *CreateBindingRequest) (response *CreateBindingResponse, err error)
CreateBinding invokes the amqp_open.CreateBinding API synchronously
func (*Client) CreateBindingWithCallback ¶
func (client *Client) CreateBindingWithCallback(request *CreateBindingRequest, callback func(response *CreateBindingResponse, err error)) <-chan int
CreateBindingWithCallback invokes the amqp_open.CreateBinding API asynchronously
func (*Client) CreateBindingWithChan ¶
func (client *Client) CreateBindingWithChan(request *CreateBindingRequest) (<-chan *CreateBindingResponse, <-chan error)
CreateBindingWithChan invokes the amqp_open.CreateBinding API asynchronously
func (*Client) CreateExchange ¶
func (client *Client) CreateExchange(request *CreateExchangeRequest) (response *CreateExchangeResponse, err error)
CreateExchange invokes the amqp_open.CreateExchange API synchronously
func (*Client) CreateExchangeWithCallback ¶
func (client *Client) CreateExchangeWithCallback(request *CreateExchangeRequest, callback func(response *CreateExchangeResponse, err error)) <-chan int
CreateExchangeWithCallback invokes the amqp_open.CreateExchange API asynchronously
func (*Client) CreateExchangeWithChan ¶
func (client *Client) CreateExchangeWithChan(request *CreateExchangeRequest) (<-chan *CreateExchangeResponse, <-chan error)
CreateExchangeWithChan invokes the amqp_open.CreateExchange API asynchronously
func (*Client) CreateInstance ¶ added in v1.62.604
func (client *Client) CreateInstance(request *CreateInstanceRequest) (response *CreateInstanceResponse, err error)
CreateInstance invokes the amqp_open.CreateInstance API synchronously
func (*Client) CreateInstanceWithCallback ¶ added in v1.62.604
func (client *Client) CreateInstanceWithCallback(request *CreateInstanceRequest, callback func(response *CreateInstanceResponse, err error)) <-chan int
CreateInstanceWithCallback invokes the amqp_open.CreateInstance API asynchronously
func (*Client) CreateInstanceWithChan ¶ added in v1.62.604
func (client *Client) CreateInstanceWithChan(request *CreateInstanceRequest) (<-chan *CreateInstanceResponse, <-chan error)
CreateInstanceWithChan invokes the amqp_open.CreateInstance API asynchronously
func (*Client) CreateQueue ¶
func (client *Client) CreateQueue(request *CreateQueueRequest) (response *CreateQueueResponse, err error)
CreateQueue invokes the amqp_open.CreateQueue API synchronously
func (*Client) CreateQueueWithCallback ¶
func (client *Client) CreateQueueWithCallback(request *CreateQueueRequest, callback func(response *CreateQueueResponse, err error)) <-chan int
CreateQueueWithCallback invokes the amqp_open.CreateQueue API asynchronously
func (*Client) CreateQueueWithChan ¶
func (client *Client) CreateQueueWithChan(request *CreateQueueRequest) (<-chan *CreateQueueResponse, <-chan error)
CreateQueueWithChan invokes the amqp_open.CreateQueue API asynchronously
func (*Client) CreateVirtualHost ¶
func (client *Client) CreateVirtualHost(request *CreateVirtualHostRequest) (response *CreateVirtualHostResponse, err error)
CreateVirtualHost invokes the amqp_open.CreateVirtualHost API synchronously
func (*Client) CreateVirtualHostWithCallback ¶
func (client *Client) CreateVirtualHostWithCallback(request *CreateVirtualHostRequest, callback func(response *CreateVirtualHostResponse, err error)) <-chan int
CreateVirtualHostWithCallback invokes the amqp_open.CreateVirtualHost API asynchronously
func (*Client) CreateVirtualHostWithChan ¶
func (client *Client) CreateVirtualHostWithChan(request *CreateVirtualHostRequest) (<-chan *CreateVirtualHostResponse, <-chan error)
CreateVirtualHostWithChan invokes the amqp_open.CreateVirtualHost API asynchronously
func (*Client) DeleteAccount ¶ added in v1.62.604
func (client *Client) DeleteAccount(request *DeleteAccountRequest) (response *DeleteAccountResponse, err error)
DeleteAccount invokes the amqp_open.DeleteAccount API synchronously
func (*Client) DeleteAccountWithCallback ¶ added in v1.62.604
func (client *Client) DeleteAccountWithCallback(request *DeleteAccountRequest, callback func(response *DeleteAccountResponse, err error)) <-chan int
DeleteAccountWithCallback invokes the amqp_open.DeleteAccount API asynchronously
func (*Client) DeleteAccountWithChan ¶ added in v1.62.604
func (client *Client) DeleteAccountWithChan(request *DeleteAccountRequest) (<-chan *DeleteAccountResponse, <-chan error)
DeleteAccountWithChan invokes the amqp_open.DeleteAccount API asynchronously
func (*Client) DeleteBinding ¶
func (client *Client) DeleteBinding(request *DeleteBindingRequest) (response *DeleteBindingResponse, err error)
DeleteBinding invokes the amqp_open.DeleteBinding API synchronously
func (*Client) DeleteBindingWithCallback ¶
func (client *Client) DeleteBindingWithCallback(request *DeleteBindingRequest, callback func(response *DeleteBindingResponse, err error)) <-chan int
DeleteBindingWithCallback invokes the amqp_open.DeleteBinding API asynchronously
func (*Client) DeleteBindingWithChan ¶
func (client *Client) DeleteBindingWithChan(request *DeleteBindingRequest) (<-chan *DeleteBindingResponse, <-chan error)
DeleteBindingWithChan invokes the amqp_open.DeleteBinding API asynchronously
func (*Client) DeleteExchange ¶
func (client *Client) DeleteExchange(request *DeleteExchangeRequest) (response *DeleteExchangeResponse, err error)
DeleteExchange invokes the amqp_open.DeleteExchange API synchronously
func (*Client) DeleteExchangeWithCallback ¶
func (client *Client) DeleteExchangeWithCallback(request *DeleteExchangeRequest, callback func(response *DeleteExchangeResponse, err error)) <-chan int
DeleteExchangeWithCallback invokes the amqp_open.DeleteExchange API asynchronously
func (*Client) DeleteExchangeWithChan ¶
func (client *Client) DeleteExchangeWithChan(request *DeleteExchangeRequest) (<-chan *DeleteExchangeResponse, <-chan error)
DeleteExchangeWithChan invokes the amqp_open.DeleteExchange API asynchronously
func (*Client) DeleteQueue ¶
func (client *Client) DeleteQueue(request *DeleteQueueRequest) (response *DeleteQueueResponse, err error)
DeleteQueue invokes the amqp_open.DeleteQueue API synchronously
func (*Client) DeleteQueueWithCallback ¶
func (client *Client) DeleteQueueWithCallback(request *DeleteQueueRequest, callback func(response *DeleteQueueResponse, err error)) <-chan int
DeleteQueueWithCallback invokes the amqp_open.DeleteQueue API asynchronously
func (*Client) DeleteQueueWithChan ¶
func (client *Client) DeleteQueueWithChan(request *DeleteQueueRequest) (<-chan *DeleteQueueResponse, <-chan error)
DeleteQueueWithChan invokes the amqp_open.DeleteQueue API asynchronously
func (*Client) DeleteVirtualHost ¶
func (client *Client) DeleteVirtualHost(request *DeleteVirtualHostRequest) (response *DeleteVirtualHostResponse, err error)
DeleteVirtualHost invokes the amqp_open.DeleteVirtualHost API synchronously
func (*Client) DeleteVirtualHostWithCallback ¶
func (client *Client) DeleteVirtualHostWithCallback(request *DeleteVirtualHostRequest, callback func(response *DeleteVirtualHostResponse, err error)) <-chan int
DeleteVirtualHostWithCallback invokes the amqp_open.DeleteVirtualHost API asynchronously
func (*Client) DeleteVirtualHostWithChan ¶
func (client *Client) DeleteVirtualHostWithChan(request *DeleteVirtualHostRequest) (<-chan *DeleteVirtualHostResponse, <-chan error)
DeleteVirtualHostWithChan invokes the amqp_open.DeleteVirtualHost API asynchronously
func (*Client) GetMetadataAmount ¶ added in v1.61.290
func (client *Client) GetMetadataAmount(request *GetMetadataAmountRequest) (response *GetMetadataAmountResponse, err error)
GetMetadataAmount invokes the amqp_open.GetMetadataAmount API synchronously
func (*Client) GetMetadataAmountWithCallback ¶ added in v1.61.290
func (client *Client) GetMetadataAmountWithCallback(request *GetMetadataAmountRequest, callback func(response *GetMetadataAmountResponse, err error)) <-chan int
GetMetadataAmountWithCallback invokes the amqp_open.GetMetadataAmount API asynchronously
func (*Client) GetMetadataAmountWithChan ¶ added in v1.61.290
func (client *Client) GetMetadataAmountWithChan(request *GetMetadataAmountRequest) (<-chan *GetMetadataAmountResponse, <-chan error)
GetMetadataAmountWithChan invokes the amqp_open.GetMetadataAmount API asynchronously
func (*Client) ListAccounts ¶ added in v1.62.604
func (client *Client) ListAccounts(request *ListAccountsRequest) (response *ListAccountsResponse, err error)
ListAccounts invokes the amqp_open.ListAccounts API synchronously
func (*Client) ListAccountsWithCallback ¶ added in v1.62.604
func (client *Client) ListAccountsWithCallback(request *ListAccountsRequest, callback func(response *ListAccountsResponse, err error)) <-chan int
ListAccountsWithCallback invokes the amqp_open.ListAccounts API asynchronously
func (*Client) ListAccountsWithChan ¶ added in v1.62.604
func (client *Client) ListAccountsWithChan(request *ListAccountsRequest) (<-chan *ListAccountsResponse, <-chan error)
ListAccountsWithChan invokes the amqp_open.ListAccounts API asynchronously
func (*Client) ListBindings ¶
func (client *Client) ListBindings(request *ListBindingsRequest) (response *ListBindingsResponse, err error)
ListBindings invokes the amqp_open.ListBindings API synchronously
func (*Client) ListBindingsWithCallback ¶
func (client *Client) ListBindingsWithCallback(request *ListBindingsRequest, callback func(response *ListBindingsResponse, err error)) <-chan int
ListBindingsWithCallback invokes the amqp_open.ListBindings API asynchronously
func (*Client) ListBindingsWithChan ¶
func (client *Client) ListBindingsWithChan(request *ListBindingsRequest) (<-chan *ListBindingsResponse, <-chan error)
ListBindingsWithChan invokes the amqp_open.ListBindings API asynchronously
func (*Client) ListDownStreamBindings ¶
func (client *Client) ListDownStreamBindings(request *ListDownStreamBindingsRequest) (response *ListDownStreamBindingsResponse, err error)
ListDownStreamBindings invokes the amqp_open.ListDownStreamBindings API synchronously
func (*Client) ListDownStreamBindingsWithCallback ¶
func (client *Client) ListDownStreamBindingsWithCallback(request *ListDownStreamBindingsRequest, callback func(response *ListDownStreamBindingsResponse, err error)) <-chan int
ListDownStreamBindingsWithCallback invokes the amqp_open.ListDownStreamBindings API asynchronously
func (*Client) ListDownStreamBindingsWithChan ¶
func (client *Client) ListDownStreamBindingsWithChan(request *ListDownStreamBindingsRequest) (<-chan *ListDownStreamBindingsResponse, <-chan error)
ListDownStreamBindingsWithChan invokes the amqp_open.ListDownStreamBindings API asynchronously
func (*Client) ListExchangeUpStreamBindings ¶
func (client *Client) ListExchangeUpStreamBindings(request *ListExchangeUpStreamBindingsRequest) (response *ListExchangeUpStreamBindingsResponse, err error)
ListExchangeUpStreamBindings invokes the amqp_open.ListExchangeUpStreamBindings API synchronously
func (*Client) ListExchangeUpStreamBindingsWithCallback ¶
func (client *Client) ListExchangeUpStreamBindingsWithCallback(request *ListExchangeUpStreamBindingsRequest, callback func(response *ListExchangeUpStreamBindingsResponse, err error)) <-chan int
ListExchangeUpStreamBindingsWithCallback invokes the amqp_open.ListExchangeUpStreamBindings API asynchronously
func (*Client) ListExchangeUpStreamBindingsWithChan ¶
func (client *Client) ListExchangeUpStreamBindingsWithChan(request *ListExchangeUpStreamBindingsRequest) (<-chan *ListExchangeUpStreamBindingsResponse, <-chan error)
ListExchangeUpStreamBindingsWithChan invokes the amqp_open.ListExchangeUpStreamBindings API asynchronously
func (*Client) ListExchanges ¶
func (client *Client) ListExchanges(request *ListExchangesRequest) (response *ListExchangesResponse, err error)
ListExchanges invokes the amqp_open.ListExchanges API synchronously
func (*Client) ListExchangesWithCallback ¶
func (client *Client) ListExchangesWithCallback(request *ListExchangesRequest, callback func(response *ListExchangesResponse, err error)) <-chan int
ListExchangesWithCallback invokes the amqp_open.ListExchanges API asynchronously
func (*Client) ListExchangesWithChan ¶
func (client *Client) ListExchangesWithChan(request *ListExchangesRequest) (<-chan *ListExchangesResponse, <-chan error)
ListExchangesWithChan invokes the amqp_open.ListExchanges API asynchronously
func (*Client) ListInstances ¶
func (client *Client) ListInstances(request *ListInstancesRequest) (response *ListInstancesResponse, err error)
ListInstances invokes the amqp_open.ListInstances API synchronously
func (*Client) ListInstancesWithCallback ¶
func (client *Client) ListInstancesWithCallback(request *ListInstancesRequest, callback func(response *ListInstancesResponse, err error)) <-chan int
ListInstancesWithCallback invokes the amqp_open.ListInstances API asynchronously
func (*Client) ListInstancesWithChan ¶
func (client *Client) ListInstancesWithChan(request *ListInstancesRequest) (<-chan *ListInstancesResponse, <-chan error)
ListInstancesWithChan invokes the amqp_open.ListInstances API asynchronously
func (*Client) ListQueueConsumers ¶ added in v1.61.290
func (client *Client) ListQueueConsumers(request *ListQueueConsumersRequest) (response *ListQueueConsumersResponse, err error)
ListQueueConsumers invokes the amqp_open.ListQueueConsumers API synchronously
func (*Client) ListQueueConsumersWithCallback ¶ added in v1.61.290
func (client *Client) ListQueueConsumersWithCallback(request *ListQueueConsumersRequest, callback func(response *ListQueueConsumersResponse, err error)) <-chan int
ListQueueConsumersWithCallback invokes the amqp_open.ListQueueConsumers API asynchronously
func (*Client) ListQueueConsumersWithChan ¶ added in v1.61.290
func (client *Client) ListQueueConsumersWithChan(request *ListQueueConsumersRequest) (<-chan *ListQueueConsumersResponse, <-chan error)
ListQueueConsumersWithChan invokes the amqp_open.ListQueueConsumers API asynchronously
func (*Client) ListQueueUpStreamBindings ¶
func (client *Client) ListQueueUpStreamBindings(request *ListQueueUpStreamBindingsRequest) (response *ListQueueUpStreamBindingsResponse, err error)
ListQueueUpStreamBindings invokes the amqp_open.ListQueueUpStreamBindings API synchronously
func (*Client) ListQueueUpStreamBindingsWithCallback ¶
func (client *Client) ListQueueUpStreamBindingsWithCallback(request *ListQueueUpStreamBindingsRequest, callback func(response *ListQueueUpStreamBindingsResponse, err error)) <-chan int
ListQueueUpStreamBindingsWithCallback invokes the amqp_open.ListQueueUpStreamBindings API asynchronously
func (*Client) ListQueueUpStreamBindingsWithChan ¶
func (client *Client) ListQueueUpStreamBindingsWithChan(request *ListQueueUpStreamBindingsRequest) (<-chan *ListQueueUpStreamBindingsResponse, <-chan error)
ListQueueUpStreamBindingsWithChan invokes the amqp_open.ListQueueUpStreamBindings API asynchronously
func (*Client) ListQueues ¶
func (client *Client) ListQueues(request *ListQueuesRequest) (response *ListQueuesResponse, err error)
ListQueues invokes the amqp_open.ListQueues API synchronously
func (*Client) ListQueuesWithCallback ¶
func (client *Client) ListQueuesWithCallback(request *ListQueuesRequest, callback func(response *ListQueuesResponse, err error)) <-chan int
ListQueuesWithCallback invokes the amqp_open.ListQueues API asynchronously
func (*Client) ListQueuesWithChan ¶
func (client *Client) ListQueuesWithChan(request *ListQueuesRequest) (<-chan *ListQueuesResponse, <-chan error)
ListQueuesWithChan invokes the amqp_open.ListQueues API asynchronously
func (*Client) ListVirtualHosts ¶
func (client *Client) ListVirtualHosts(request *ListVirtualHostsRequest) (response *ListVirtualHostsResponse, err error)
ListVirtualHosts invokes the amqp_open.ListVirtualHosts API synchronously
func (*Client) ListVirtualHostsWithCallback ¶
func (client *Client) ListVirtualHostsWithCallback(request *ListVirtualHostsRequest, callback func(response *ListVirtualHostsResponse, err error)) <-chan int
ListVirtualHostsWithCallback invokes the amqp_open.ListVirtualHosts API asynchronously
func (*Client) ListVirtualHostsWithChan ¶
func (client *Client) ListVirtualHostsWithChan(request *ListVirtualHostsRequest) (<-chan *ListVirtualHostsResponse, <-chan error)
ListVirtualHostsWithChan invokes the amqp_open.ListVirtualHosts API asynchronously
func (*Client) UpdateInstanceName ¶ added in v1.62.604
func (client *Client) UpdateInstanceName(request *UpdateInstanceNameRequest) (response *UpdateInstanceNameResponse, err error)
UpdateInstanceName invokes the amqp_open.UpdateInstanceName API synchronously
func (*Client) UpdateInstanceNameWithCallback ¶ added in v1.62.604
func (client *Client) UpdateInstanceNameWithCallback(request *UpdateInstanceNameRequest, callback func(response *UpdateInstanceNameResponse, err error)) <-chan int
UpdateInstanceNameWithCallback invokes the amqp_open.UpdateInstanceName API asynchronously
func (*Client) UpdateInstanceNameWithChan ¶ added in v1.62.604
func (client *Client) UpdateInstanceNameWithChan(request *UpdateInstanceNameRequest) (<-chan *UpdateInstanceNameResponse, <-chan error)
UpdateInstanceNameWithChan invokes the amqp_open.UpdateInstanceName API asynchronously
type Consumers ¶ added in v1.61.290
type Consumers struct {
QueueConsumerVO []QueueConsumerVO `json:"QueueConsumerVO" xml:"QueueConsumerVO"`
}
Consumers is a nested struct in amqp_open response
type CreateAccountRequest ¶ added in v1.62.604
type CreateAccountRequest struct { *requests.RpcRequest Signature string `position:"Query" name:"signature"` SecretSign string `position:"Query" name:"secretSign"` AccountAccessKey string `position:"Query" name:"accountAccessKey"` InstanceId string `position:"Query" name:"instanceId"` CreateTimestamp requests.Integer `position:"Query" name:"createTimestamp"` UserName string `position:"Query" name:"userName"` }
CreateAccountRequest is the request struct for api CreateAccount
func CreateCreateAccountRequest ¶ added in v1.62.604
func CreateCreateAccountRequest() (request *CreateAccountRequest)
CreateCreateAccountRequest creates a request to invoke CreateAccount API
type CreateAccountResponse ¶ added in v1.62.604
type CreateAccountResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
CreateAccountResponse is the response struct for api CreateAccount
func CreateCreateAccountResponse ¶ added in v1.62.604
func CreateCreateAccountResponse() (response *CreateAccountResponse)
CreateCreateAccountResponse creates a response to parse from CreateAccount response
type CreateBindingRequest ¶
type CreateBindingRequest struct { *requests.RpcRequest Argument string `position:"Body" name:"Argument"` DestinationName string `position:"Body" name:"DestinationName"` SourceExchange string `position:"Body" name:"SourceExchange"` BindingKey string `position:"Body" name:"BindingKey"` BindingType string `position:"Body" name:"BindingType"` InstanceId string `position:"Body" name:"InstanceId"` VirtualHost string `position:"Body" name:"VirtualHost"` }
CreateBindingRequest is the request struct for api CreateBinding
func CreateCreateBindingRequest ¶
func CreateCreateBindingRequest() (request *CreateBindingRequest)
CreateCreateBindingRequest creates a request to invoke CreateBinding API
type CreateBindingResponse ¶
type CreateBindingResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
CreateBindingResponse is the response struct for api CreateBinding
func CreateCreateBindingResponse ¶
func CreateCreateBindingResponse() (response *CreateBindingResponse)
CreateCreateBindingResponse creates a response to parse from CreateBinding response
type CreateExchangeRequest ¶
type CreateExchangeRequest struct { *requests.RpcRequest Internal requests.Boolean `position:"Body" name:"Internal"` ExchangeName string `position:"Body" name:"ExchangeName"` InstanceId string `position:"Body" name:"InstanceId"` AlternateExchange string `position:"Body" name:"AlternateExchange"` AutoDeleteState requests.Boolean `position:"Body" name:"AutoDeleteState"` ExchangeType string `position:"Body" name:"ExchangeType"` VirtualHost string `position:"Body" name:"VirtualHost"` }
CreateExchangeRequest is the request struct for api CreateExchange
func CreateCreateExchangeRequest ¶
func CreateCreateExchangeRequest() (request *CreateExchangeRequest)
CreateCreateExchangeRequest creates a request to invoke CreateExchange API
type CreateExchangeResponse ¶
type CreateExchangeResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
CreateExchangeResponse is the response struct for api CreateExchange
func CreateCreateExchangeResponse ¶
func CreateCreateExchangeResponse() (response *CreateExchangeResponse)
CreateCreateExchangeResponse creates a response to parse from CreateExchange response
type CreateInstanceRequest ¶ added in v1.62.604
type CreateInstanceRequest struct { *requests.RpcRequest MaxPrivateTps requests.Integer `position:"Query" name:"MaxPrivateTps"` ClientToken string `position:"Query" name:"ClientToken"` PeriodCycle string `position:"Query" name:"PeriodCycle"` StorageSize requests.Integer `position:"Query" name:"StorageSize"` QueueCapacity requests.Integer `position:"Query" name:"QueueCapacity"` TracingStorageTime requests.Integer `position:"Query" name:"TracingStorageTime"` MaxConnections requests.Integer `position:"Query" name:"MaxConnections"` SupportTracing requests.Boolean `position:"Query" name:"SupportTracing"` InstanceType string `position:"Query" name:"InstanceType"` AutoRenewPeriod requests.Integer `position:"Query" name:"AutoRenewPeriod"` Period requests.Integer `position:"Query" name:"Period"` AutoRenew requests.Boolean `position:"Query" name:"AutoRenew"` SupportEip requests.Boolean `position:"Query" name:"SupportEip"` MaxEipTps requests.Integer `position:"Query" name:"MaxEipTps"` PaymentType string `position:"Query" name:"PaymentType"` }
CreateInstanceRequest is the request struct for api CreateInstance
func CreateCreateInstanceRequest ¶ added in v1.62.604
func CreateCreateInstanceRequest() (request *CreateInstanceRequest)
CreateCreateInstanceRequest creates a request to invoke CreateInstance API
type CreateInstanceResponse ¶ added in v1.62.604
type CreateInstanceResponse struct {
*responses.BaseResponse
}
CreateInstanceResponse is the response struct for api CreateInstance
func CreateCreateInstanceResponse ¶ added in v1.62.604
func CreateCreateInstanceResponse() (response *CreateInstanceResponse)
CreateCreateInstanceResponse creates a response to parse from CreateInstance response
type CreateQueueRequest ¶
type CreateQueueRequest struct { *requests.RpcRequest QueueName string `position:"Body" name:"QueueName"` DeadLetterRoutingKey string `position:"Body" name:"DeadLetterRoutingKey"` MaxLength requests.Integer `position:"Body" name:"MaxLength"` AutoExpireState requests.Integer `position:"Body" name:"AutoExpireState"` DeadLetterExchange string `position:"Body" name:"DeadLetterExchange"` InstanceId string `position:"Body" name:"InstanceId"` ExclusiveState requests.Boolean `position:"Body" name:"ExclusiveState"` AutoDeleteState requests.Boolean `position:"Body" name:"AutoDeleteState"` MessageTTL requests.Integer `position:"Body" name:"MessageTTL"` VirtualHost string `position:"Body" name:"VirtualHost"` MaximumPriority requests.Integer `position:"Body" name:"MaximumPriority"` }
CreateQueueRequest is the request struct for api CreateQueue
func CreateCreateQueueRequest ¶
func CreateCreateQueueRequest() (request *CreateQueueRequest)
CreateCreateQueueRequest creates a request to invoke CreateQueue API
type CreateQueueResponse ¶
type CreateQueueResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
CreateQueueResponse is the response struct for api CreateQueue
func CreateCreateQueueResponse ¶
func CreateCreateQueueResponse() (response *CreateQueueResponse)
CreateCreateQueueResponse creates a response to parse from CreateQueue response
type CreateVirtualHostRequest ¶
type CreateVirtualHostRequest struct { *requests.RpcRequest InstanceId string `position:"Body" name:"InstanceId"` VirtualHost string `position:"Body" name:"VirtualHost"` }
CreateVirtualHostRequest is the request struct for api CreateVirtualHost
func CreateCreateVirtualHostRequest ¶
func CreateCreateVirtualHostRequest() (request *CreateVirtualHostRequest)
CreateCreateVirtualHostRequest creates a request to invoke CreateVirtualHost API
type CreateVirtualHostResponse ¶
type CreateVirtualHostResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
CreateVirtualHostResponse is the response struct for api CreateVirtualHost
func CreateCreateVirtualHostResponse ¶
func CreateCreateVirtualHostResponse() (response *CreateVirtualHostResponse)
CreateCreateVirtualHostResponse creates a response to parse from CreateVirtualHost response
type Data ¶
type Data struct { MasterUId int64 `json:"MasterUId" xml:"MasterUId"` CurrentVirtualHosts int `json:"CurrentVirtualHosts" xml:"CurrentVirtualHosts"` MaxQueues int `json:"MaxQueues" xml:"MaxQueues"` MaxVirtualHosts int `json:"MaxVirtualHosts" xml:"MaxVirtualHosts"` MaxExchanges int `json:"MaxExchanges" xml:"MaxExchanges"` Password string `json:"Password" xml:"Password"` CreateTimeStamp int64 `json:"CreateTimeStamp" xml:"CreateTimeStamp"` NextToken string `json:"NextToken" xml:"NextToken"` InstanceId string `json:"InstanceId" xml:"InstanceId"` CurrentExchanges int `json:"CurrentExchanges" xml:"CurrentExchanges"` UserName string `json:"UserName" xml:"UserName"` CurrentQueues int `json:"CurrentQueues" xml:"CurrentQueues"` AccessKey string `json:"AccessKey" xml:"AccessKey"` MaxResults int `json:"MaxResults" xml:"MaxResults"` Exchanges []ExchangeVO `json:"Exchanges" xml:"Exchanges"` Queues []QueueVO `json:"Queues" xml:"Queues"` Bindings []BindingDO `json:"Bindings" xml:"Bindings"` Consumers []QueueConsumerVO `json:"Consumers" xml:"Consumers"` VirtualHosts []VhostVO `json:"VirtualHosts" xml:"VirtualHosts"` Instances []InstanceVO `json:"Instances" xml:"Instances"` }
Data is a nested struct in amqp_open response
type DataInListDownStreamBindings ¶
type DataInListDownStreamBindings struct { MaxResults int `json:"MaxResults" xml:"MaxResults"` NextToken string `json:"NextToken" xml:"NextToken"` Bindings []BindingVO `json:"Bindings" xml:"Bindings"` }
DataInListDownStreamBindings is a nested struct in amqp_open response
type DataInListExchangeUpStreamBindings ¶
type DataInListExchangeUpStreamBindings struct { MaxResults int `json:"MaxResults" xml:"MaxResults"` NextToken string `json:"NextToken" xml:"NextToken"` Bindings []BindingVO `json:"Bindings" xml:"Bindings"` }
DataInListExchangeUpStreamBindings is a nested struct in amqp_open response
type DataInListQueueUpStreamBindings ¶
type DataInListQueueUpStreamBindings struct { MaxResults string `json:"MaxResults" xml:"MaxResults"` NextToken string `json:"NextToken" xml:"NextToken"` Bindings []BindingVO `json:"Bindings" xml:"Bindings"` }
DataInListQueueUpStreamBindings is a nested struct in amqp_open response
type DeleteAccountRequest ¶ added in v1.62.604
type DeleteAccountRequest struct { *requests.RpcRequest CreateTimestamp requests.Integer `position:"Query" name:"CreateTimestamp"` UserName string `position:"Query" name:"UserName"` }
DeleteAccountRequest is the request struct for api DeleteAccount
func CreateDeleteAccountRequest ¶ added in v1.62.604
func CreateDeleteAccountRequest() (request *DeleteAccountRequest)
CreateDeleteAccountRequest creates a request to invoke DeleteAccount API
type DeleteAccountResponse ¶ added in v1.62.604
type DeleteAccountResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Data bool `json:"Data" xml:"Data"` Success bool `json:"Success" xml:"Success"` }
DeleteAccountResponse is the response struct for api DeleteAccount
func CreateDeleteAccountResponse ¶ added in v1.62.604
func CreateDeleteAccountResponse() (response *DeleteAccountResponse)
CreateDeleteAccountResponse creates a response to parse from DeleteAccount response
type DeleteBindingRequest ¶
type DeleteBindingRequest struct { *requests.RpcRequest DestinationName string `position:"Body" name:"DestinationName"` SourceExchange string `position:"Body" name:"SourceExchange"` BindingKey string `position:"Body" name:"BindingKey"` BindingType string `position:"Body" name:"BindingType"` InstanceId string `position:"Body" name:"InstanceId"` VirtualHost string `position:"Body" name:"VirtualHost"` }
DeleteBindingRequest is the request struct for api DeleteBinding
func CreateDeleteBindingRequest ¶
func CreateDeleteBindingRequest() (request *DeleteBindingRequest)
CreateDeleteBindingRequest creates a request to invoke DeleteBinding API
type DeleteBindingResponse ¶
type DeleteBindingResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
DeleteBindingResponse is the response struct for api DeleteBinding
func CreateDeleteBindingResponse ¶
func CreateDeleteBindingResponse() (response *DeleteBindingResponse)
CreateDeleteBindingResponse creates a response to parse from DeleteBinding response
type DeleteExchangeRequest ¶
type DeleteExchangeRequest struct { *requests.RpcRequest ExchangeName string `position:"Body" name:"ExchangeName"` InstanceId string `position:"Body" name:"InstanceId"` VirtualHost string `position:"Body" name:"VirtualHost"` }
DeleteExchangeRequest is the request struct for api DeleteExchange
func CreateDeleteExchangeRequest ¶
func CreateDeleteExchangeRequest() (request *DeleteExchangeRequest)
CreateDeleteExchangeRequest creates a request to invoke DeleteExchange API
type DeleteExchangeResponse ¶
type DeleteExchangeResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
DeleteExchangeResponse is the response struct for api DeleteExchange
func CreateDeleteExchangeResponse ¶
func CreateDeleteExchangeResponse() (response *DeleteExchangeResponse)
CreateDeleteExchangeResponse creates a response to parse from DeleteExchange response
type DeleteQueueRequest ¶
type DeleteQueueRequest struct { *requests.RpcRequest QueueName string `position:"Body" name:"QueueName"` InstanceId string `position:"Body" name:"InstanceId"` VirtualHost string `position:"Body" name:"VirtualHost"` }
DeleteQueueRequest is the request struct for api DeleteQueue
func CreateDeleteQueueRequest ¶
func CreateDeleteQueueRequest() (request *DeleteQueueRequest)
CreateDeleteQueueRequest creates a request to invoke DeleteQueue API
type DeleteQueueResponse ¶
type DeleteQueueResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
DeleteQueueResponse is the response struct for api DeleteQueue
func CreateDeleteQueueResponse ¶
func CreateDeleteQueueResponse() (response *DeleteQueueResponse)
CreateDeleteQueueResponse creates a response to parse from DeleteQueue response
type DeleteVirtualHostRequest ¶
type DeleteVirtualHostRequest struct { *requests.RpcRequest InstanceId string `position:"Body" name:"InstanceId"` VirtualHost string `position:"Body" name:"VirtualHost"` }
DeleteVirtualHostRequest is the request struct for api DeleteVirtualHost
func CreateDeleteVirtualHostRequest ¶
func CreateDeleteVirtualHostRequest() (request *DeleteVirtualHostRequest)
CreateDeleteVirtualHostRequest creates a request to invoke DeleteVirtualHost API
type DeleteVirtualHostResponse ¶
type DeleteVirtualHostResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` }
DeleteVirtualHostResponse is the response struct for api DeleteVirtualHost
func CreateDeleteVirtualHostResponse ¶
func CreateDeleteVirtualHostResponse() (response *DeleteVirtualHostResponse)
CreateDeleteVirtualHostResponse creates a response to parse from DeleteVirtualHost response
type ExchangeVO ¶
type ExchangeVO struct { AutoDeleteState bool `json:"AutoDeleteState" xml:"AutoDeleteState"` CreateTime int64 `json:"CreateTime" xml:"CreateTime"` Attributes map[string]interface{} `json:"Attributes" xml:"Attributes"` VHostName string `json:"VHostName" xml:"VHostName"` Name string `json:"Name" xml:"Name"` ExchangeType string `json:"ExchangeType" xml:"ExchangeType"` }
ExchangeVO is a nested struct in amqp_open response
type Exchanges ¶
type Exchanges struct {
ExchangeVO []ExchangeVO `json:"ExchangeVO" xml:"ExchangeVO"`
}
Exchanges is a nested struct in amqp_open response
type GetMetadataAmountRequest ¶ added in v1.61.290
type GetMetadataAmountRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` }
GetMetadataAmountRequest is the request struct for api GetMetadataAmount
func CreateGetMetadataAmountRequest ¶ added in v1.61.290
func CreateGetMetadataAmountRequest() (request *GetMetadataAmountRequest)
CreateGetMetadataAmountRequest creates a request to invoke GetMetadataAmount API
type GetMetadataAmountResponse ¶ added in v1.61.290
type GetMetadataAmountResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data Data `json:"Data" xml:"Data"` }
GetMetadataAmountResponse is the response struct for api GetMetadataAmount
func CreateGetMetadataAmountResponse ¶ added in v1.61.290
func CreateGetMetadataAmountResponse() (response *GetMetadataAmountResponse)
CreateGetMetadataAmountResponse creates a response to parse from GetMetadataAmount response
type InstanceVO ¶
type InstanceVO struct { Status string `json:"Status" xml:"Status"` SupportEIP bool `json:"SupportEIP" xml:"SupportEIP"` ExpireTime int64 `json:"ExpireTime" xml:"ExpireTime"` OrderCreateTime int64 `json:"OrderCreateTime" xml:"OrderCreateTime"` PrivateEndpoint string `json:"PrivateEndpoint" xml:"PrivateEndpoint"` StorageSize int `json:"StorageSize" xml:"StorageSize"` MaxEipTps int `json:"MaxEipTps" xml:"MaxEipTps"` InstanceId string `json:"InstanceId" xml:"InstanceId"` InstanceType string `json:"InstanceType" xml:"InstanceType"` PublicEndpoint string `json:"PublicEndpoint" xml:"PublicEndpoint"` ClassicEndpoint string `json:"ClassicEndpoint" xml:"ClassicEndpoint"` MaxVhost int `json:"MaxVhost" xml:"MaxVhost"` MaxTps int `json:"MaxTps" xml:"MaxTps"` AutoRenewInstance bool `json:"AutoRenewInstance" xml:"AutoRenewInstance"` InstanceName string `json:"InstanceName" xml:"InstanceName"` MaxQueue int `json:"MaxQueue" xml:"MaxQueue"` OrderType string `json:"OrderType" xml:"OrderType"` Tags []TagsItem `json:"Tags" xml:"Tags"` }
InstanceVO is a nested struct in amqp_open response
type Instances ¶
type Instances struct {
InstanceVO []InstanceVO `json:"InstanceVO" xml:"InstanceVO"`
}
Instances is a nested struct in amqp_open response
type ListAccountsRequest ¶ added in v1.62.604
type ListAccountsRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` }
ListAccountsRequest is the request struct for api ListAccounts
func CreateListAccountsRequest ¶ added in v1.62.604
func CreateListAccountsRequest() (request *ListAccountsRequest)
CreateListAccountsRequest creates a request to invoke ListAccounts API
type ListAccountsResponse ¶ added in v1.62.604
type ListAccountsResponse struct {
*responses.BaseResponse
}
ListAccountsResponse is the response struct for api ListAccounts
func CreateListAccountsResponse ¶ added in v1.62.604
func CreateListAccountsResponse() (response *ListAccountsResponse)
CreateListAccountsResponse creates a response to parse from ListAccounts response
type ListBindingsRequest ¶
type ListBindingsRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` NextToken string `position:"Query" name:"NextToken"` MaxResults requests.Integer `position:"Query" name:"MaxResults"` VirtualHost string `position:"Query" name:"VirtualHost"` }
ListBindingsRequest is the request struct for api ListBindings
func CreateListBindingsRequest ¶
func CreateListBindingsRequest() (request *ListBindingsRequest)
CreateListBindingsRequest creates a request to invoke ListBindings API
type ListBindingsResponse ¶
type ListBindingsResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data Data `json:"Data" xml:"Data"` }
ListBindingsResponse is the response struct for api ListBindings
func CreateListBindingsResponse ¶
func CreateListBindingsResponse() (response *ListBindingsResponse)
CreateListBindingsResponse creates a response to parse from ListBindings response
type ListDownStreamBindingsRequest ¶
type ListDownStreamBindingsRequest struct { *requests.RpcRequest ExchangeName string `position:"Query" name:"ExchangeName"` InstanceId string `position:"Query" name:"InstanceId"` NextToken string `position:"Query" name:"NextToken"` MaxResults requests.Integer `position:"Query" name:"MaxResults"` VirtualHost string `position:"Query" name:"VirtualHost"` }
ListDownStreamBindingsRequest is the request struct for api ListDownStreamBindings
func CreateListDownStreamBindingsRequest ¶
func CreateListDownStreamBindingsRequest() (request *ListDownStreamBindingsRequest)
CreateListDownStreamBindingsRequest creates a request to invoke ListDownStreamBindings API
type ListDownStreamBindingsResponse ¶
type ListDownStreamBindingsResponse 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"` Data DataInListDownStreamBindings `json:"Data" xml:"Data"` }
ListDownStreamBindingsResponse is the response struct for api ListDownStreamBindings
func CreateListDownStreamBindingsResponse ¶
func CreateListDownStreamBindingsResponse() (response *ListDownStreamBindingsResponse)
CreateListDownStreamBindingsResponse creates a response to parse from ListDownStreamBindings response
type ListExchangeUpStreamBindingsRequest ¶
type ListExchangeUpStreamBindingsRequest struct { *requests.RpcRequest ExchangeName string `position:"Query" name:"ExchangeName"` InstanceId string `position:"Query" name:"InstanceId"` NextToken string `position:"Query" name:"NextToken"` MaxResults requests.Integer `position:"Query" name:"MaxResults"` VirtualHost string `position:"Query" name:"VirtualHost"` }
ListExchangeUpStreamBindingsRequest is the request struct for api ListExchangeUpStreamBindings
func CreateListExchangeUpStreamBindingsRequest ¶
func CreateListExchangeUpStreamBindingsRequest() (request *ListExchangeUpStreamBindingsRequest)
CreateListExchangeUpStreamBindingsRequest creates a request to invoke ListExchangeUpStreamBindings API
type ListExchangeUpStreamBindingsResponse ¶
type ListExchangeUpStreamBindingsResponse 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"` Data DataInListExchangeUpStreamBindings `json:"Data" xml:"Data"` }
ListExchangeUpStreamBindingsResponse is the response struct for api ListExchangeUpStreamBindings
func CreateListExchangeUpStreamBindingsResponse ¶
func CreateListExchangeUpStreamBindingsResponse() (response *ListExchangeUpStreamBindingsResponse)
CreateListExchangeUpStreamBindingsResponse creates a response to parse from ListExchangeUpStreamBindings response
type ListExchangesRequest ¶
type ListExchangesRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` NextToken string `position:"Query" name:"NextToken"` MaxResults requests.Integer `position:"Query" name:"MaxResults"` VirtualHost string `position:"Query" name:"VirtualHost"` }
ListExchangesRequest is the request struct for api ListExchanges
func CreateListExchangesRequest ¶
func CreateListExchangesRequest() (request *ListExchangesRequest)
CreateListExchangesRequest creates a request to invoke ListExchanges API
type ListExchangesResponse ¶
type ListExchangesResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data Data `json:"Data" xml:"Data"` }
ListExchangesResponse is the response struct for api ListExchanges
func CreateListExchangesResponse ¶
func CreateListExchangesResponse() (response *ListExchangesResponse)
CreateListExchangesResponse creates a response to parse from ListExchanges response
type ListInstancesRequest ¶
type ListInstancesRequest struct { *requests.RpcRequest NextToken string `position:"Query" name:"NextToken"` MaxResults requests.Integer `position:"Query" name:"MaxResults"` }
ListInstancesRequest is the request struct for api ListInstances
func CreateListInstancesRequest ¶
func CreateListInstancesRequest() (request *ListInstancesRequest)
CreateListInstancesRequest creates a request to invoke ListInstances API
type ListInstancesResponse ¶
type ListInstancesResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data Data `json:"Data" xml:"Data"` }
ListInstancesResponse is the response struct for api ListInstances
func CreateListInstancesResponse ¶
func CreateListInstancesResponse() (response *ListInstancesResponse)
CreateListInstancesResponse creates a response to parse from ListInstances response
type ListQueueConsumersRequest ¶ added in v1.61.290
type ListQueueConsumersRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` NextToken string `position:"Query" name:"NextToken"` QueryCount requests.Integer `position:"Query" name:"QueryCount"` VirtualHost string `position:"Query" name:"VirtualHost"` Queue string `position:"Query" name:"Queue"` }
ListQueueConsumersRequest is the request struct for api ListQueueConsumers
func CreateListQueueConsumersRequest ¶ added in v1.61.290
func CreateListQueueConsumersRequest() (request *ListQueueConsumersRequest)
CreateListQueueConsumersRequest creates a request to invoke ListQueueConsumers API
type ListQueueConsumersResponse ¶ added in v1.61.290
type ListQueueConsumersResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data Data `json:"Data" xml:"Data"` }
ListQueueConsumersResponse is the response struct for api ListQueueConsumers
func CreateListQueueConsumersResponse ¶ added in v1.61.290
func CreateListQueueConsumersResponse() (response *ListQueueConsumersResponse)
CreateListQueueConsumersResponse creates a response to parse from ListQueueConsumers response
type ListQueueUpStreamBindingsRequest ¶
type ListQueueUpStreamBindingsRequest struct { *requests.RpcRequest QueueName string `position:"Query" name:"QueueName"` InstanceId string `position:"Query" name:"InstanceId"` NextToken string `position:"Query" name:"NextToken"` MaxResults requests.Integer `position:"Query" name:"MaxResults"` VirtualHost string `position:"Query" name:"VirtualHost"` }
ListQueueUpStreamBindingsRequest is the request struct for api ListQueueUpStreamBindings
func CreateListQueueUpStreamBindingsRequest ¶
func CreateListQueueUpStreamBindingsRequest() (request *ListQueueUpStreamBindingsRequest)
CreateListQueueUpStreamBindingsRequest creates a request to invoke ListQueueUpStreamBindings API
type ListQueueUpStreamBindingsResponse ¶
type ListQueueUpStreamBindingsResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data DataInListQueueUpStreamBindings `json:"Data" xml:"Data"` }
ListQueueUpStreamBindingsResponse is the response struct for api ListQueueUpStreamBindings
func CreateListQueueUpStreamBindingsResponse ¶
func CreateListQueueUpStreamBindingsResponse() (response *ListQueueUpStreamBindingsResponse)
CreateListQueueUpStreamBindingsResponse creates a response to parse from ListQueueUpStreamBindings response
type ListQueuesRequest ¶
type ListQueuesRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` NextToken string `position:"Query" name:"NextToken"` MaxResults requests.Integer `position:"Query" name:"MaxResults"` VirtualHost string `position:"Query" name:"VirtualHost"` }
ListQueuesRequest is the request struct for api ListQueues
func CreateListQueuesRequest ¶
func CreateListQueuesRequest() (request *ListQueuesRequest)
CreateListQueuesRequest creates a request to invoke ListQueues API
type ListQueuesResponse ¶
type ListQueuesResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data Data `json:"Data" xml:"Data"` }
ListQueuesResponse is the response struct for api ListQueues
func CreateListQueuesResponse ¶
func CreateListQueuesResponse() (response *ListQueuesResponse)
CreateListQueuesResponse creates a response to parse from ListQueues response
type ListVirtualHostsRequest ¶
type ListVirtualHostsRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` NextToken string `position:"Query" name:"NextToken"` MaxResults requests.Integer `position:"Query" name:"MaxResults"` }
ListVirtualHostsRequest is the request struct for api ListVirtualHosts
func CreateListVirtualHostsRequest ¶
func CreateListVirtualHostsRequest() (request *ListVirtualHostsRequest)
CreateListVirtualHostsRequest creates a request to invoke ListVirtualHosts API
type ListVirtualHostsResponse ¶
type ListVirtualHostsResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Data Data `json:"Data" xml:"Data"` }
ListVirtualHostsResponse is the response struct for api ListVirtualHosts
func CreateListVirtualHostsResponse ¶
func CreateListVirtualHostsResponse() (response *ListVirtualHostsResponse)
CreateListVirtualHostsResponse creates a response to parse from ListVirtualHosts response
type QueueConsumerVO ¶ added in v1.61.290
type QueueConsumerVO struct {
ConsumerTag string `json:"ConsumerTag" xml:"ConsumerTag"`
}
QueueConsumerVO is a nested struct in amqp_open response
type QueueVO ¶
type QueueVO struct { ExclusiveState bool `json:"ExclusiveState" xml:"ExclusiveState"` AutoDeleteState bool `json:"AutoDeleteState" xml:"AutoDeleteState"` CreateTime int64 `json:"CreateTime" xml:"CreateTime"` Attributes map[string]interface{} `json:"Attributes" xml:"Attributes"` VHostName string `json:"VHostName" xml:"VHostName"` Name string `json:"Name" xml:"Name"` OwnerId string `json:"OwnerId" xml:"OwnerId"` LastConsumeTime int64 `json:"LastConsumeTime" xml:"LastConsumeTime"` }
QueueVO is a nested struct in amqp_open response
type Queues ¶
type Queues struct {
QueueVO []QueueVO `json:"QueueVO" xml:"QueueVO"`
}
Queues is a nested struct in amqp_open response
type Tags ¶ added in v1.62.604
type Tags struct {
TagsItem []TagsItem `json:"tags" xml:"tags"`
}
Tags is a nested struct in amqp_open response
type UpdateInstanceNameRequest ¶ added in v1.62.604
type UpdateInstanceNameRequest struct { *requests.RpcRequest InstanceId string `position:"Query" name:"InstanceId"` InstanceName string `position:"Query" name:"InstanceName"` }
UpdateInstanceNameRequest is the request struct for api UpdateInstanceName
func CreateUpdateInstanceNameRequest ¶ added in v1.62.604
func CreateUpdateInstanceNameRequest() (request *UpdateInstanceNameRequest)
CreateUpdateInstanceNameRequest creates a request to invoke UpdateInstanceName API
type UpdateInstanceNameResponse ¶ added in v1.62.604
type UpdateInstanceNameResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Data string `json:"Data" xml:"Data"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
UpdateInstanceNameResponse is the response struct for api UpdateInstanceName
func CreateUpdateInstanceNameResponse ¶ added in v1.62.604
func CreateUpdateInstanceNameResponse() (response *UpdateInstanceNameResponse)
CreateUpdateInstanceNameResponse creates a response to parse from UpdateInstanceName response
type VhostVO ¶
type VhostVO struct {
Name string `json:"Name" xml:"Name"`
}
VhostVO is a nested struct in amqp_open response
type VirtualHosts ¶
type VirtualHosts struct {
VhostVO []VhostVO `json:"VhostVO" xml:"VhostVO"`
}
VirtualHosts is a nested struct in amqp_open response
Source Files
¶
- client.go
- create_account.go
- create_binding.go
- create_exchange.go
- create_instance.go
- create_queue.go
- create_virtual_host.go
- delete_account.go
- delete_binding.go
- delete_exchange.go
- delete_queue.go
- delete_virtual_host.go
- endpoint.go
- get_metadata_amount.go
- list_accounts.go
- list_bindings.go
- list_down_stream_bindings.go
- list_exchange_up_stream_bindings.go
- list_exchanges.go
- list_instances.go
- list_queue_consumers.go
- list_queue_up_stream_bindings.go
- list_queues.go
- list_virtual_hosts.go
- struct_binding_do.go
- struct_binding_vo.go
- struct_bindings_in_list_bindings.go
- struct_bindings_in_list_down_stream_bindings.go
- struct_bindings_in_list_exchange_up_stream_bindings.go
- struct_bindings_in_list_queue_up_stream_bindings.go
- struct_consumers.go
- struct_data.go
- struct_data_in_list_down_stream_bindings.go
- struct_data_in_list_exchange_up_stream_bindings.go
- struct_data_in_list_queue_up_stream_bindings.go
- struct_exchange_vo.go
- struct_exchanges.go
- struct_instance_vo.go
- struct_instances.go
- struct_queue_consumer_vo.go
- struct_queue_vo.go
- struct_queues.go
- struct_tags.go
- struct_tags_item.go
- struct_vhost_vo.go
- struct_virtual_hosts.go
- update_instance_name.go