amqp_open

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 BindingDO 

type BindingDO struct {
	SourceExchange  string `json:"SourceExchange" xml:"SourceExchange"`
	DestinationName string `json:"DestinationName" xml:"DestinationName"`
	BindingType     string `json:"BindingType" xml:"BindingType"`
	BindingKey      string `json:"BindingKey" xml:"BindingKey"`
	Argument        string `json:"Argument" xml:"Argument"`
}

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 

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

func (client *Client) CreateBinding(request *CreateBindingRequest) (response *CreateBindingResponse, err error)

CreateBinding invokes the amqp_open.CreateBinding API synchronously api document: https://help.aliyun.com/api/amqp-open/createbinding.html

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 api document: https://help.aliyun.com/api/amqp-open/createbinding.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) CreateBindingWithChan 

func (client *Client) CreateBindingWithChan(request *CreateBindingRequest) (<-chan *CreateBindingResponse, <-chan error)

CreateBindingWithChan invokes the amqp_open.CreateBinding API asynchronously api document: https://help.aliyun.com/api/amqp-open/createbinding.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) CreateExchange 

func (client *Client) CreateExchange(request *CreateExchangeRequest) (response *CreateExchangeResponse, err error)

CreateExchange invokes the amqp_open.CreateExchange API synchronously api document: https://help.aliyun.com/api/amqp-open/createexchange.html

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 api document: https://help.aliyun.com/api/amqp-open/createexchange.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) CreateExchangeWithChan 

func (client *Client) CreateExchangeWithChan(request *CreateExchangeRequest) (<-chan *CreateExchangeResponse, <-chan error)

CreateExchangeWithChan invokes the amqp_open.CreateExchange API asynchronously api document: https://help.aliyun.com/api/amqp-open/createexchange.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) CreateQueue 

func (client *Client) CreateQueue(request *CreateQueueRequest) (response *CreateQueueResponse, err error)

CreateQueue invokes the amqp_open.CreateQueue API synchronously api document: https://help.aliyun.com/api/amqp-open/createqueue.html

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 api document: https://help.aliyun.com/api/amqp-open/createqueue.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) CreateQueueWithChan 

func (client *Client) CreateQueueWithChan(request *CreateQueueRequest) (<-chan *CreateQueueResponse, <-chan error)

CreateQueueWithChan invokes the amqp_open.CreateQueue API asynchronously api document: https://help.aliyun.com/api/amqp-open/createqueue.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) CreateVirtualHost 

func (client *Client) CreateVirtualHost(request *CreateVirtualHostRequest) (response *CreateVirtualHostResponse, err error)

CreateVirtualHost invokes the amqp_open.CreateVirtualHost API synchronously api document: https://help.aliyun.com/api/amqp-open/createvirtualhost.html

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 api document: https://help.aliyun.com/api/amqp-open/createvirtualhost.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) CreateVirtualHostWithChan 

func (client *Client) CreateVirtualHostWithChan(request *CreateVirtualHostRequest) (<-chan *CreateVirtualHostResponse, <-chan error)

CreateVirtualHostWithChan invokes the amqp_open.CreateVirtualHost API asynchronously api document: https://help.aliyun.com/api/amqp-open/createvirtualhost.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) DeleteBinding 

func (client *Client) DeleteBinding(request *DeleteBindingRequest) (response *DeleteBindingResponse, err error)

DeleteBinding invokes the amqp_open.DeleteBinding API synchronously api document: https://help.aliyun.com/api/amqp-open/deletebinding.html

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 api document: https://help.aliyun.com/api/amqp-open/deletebinding.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) DeleteBindingWithChan 

func (client *Client) DeleteBindingWithChan(request *DeleteBindingRequest) (<-chan *DeleteBindingResponse, <-chan error)

DeleteBindingWithChan invokes the amqp_open.DeleteBinding API asynchronously api document: https://help.aliyun.com/api/amqp-open/deletebinding.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) DeleteExchange 

func (client *Client) DeleteExchange(request *DeleteExchangeRequest) (response *DeleteExchangeResponse, err error)

DeleteExchange invokes the amqp_open.DeleteExchange API synchronously api document: https://help.aliyun.com/api/amqp-open/deleteexchange.html

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 api document: https://help.aliyun.com/api/amqp-open/deleteexchange.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) DeleteExchangeWithChan 

func (client *Client) DeleteExchangeWithChan(request *DeleteExchangeRequest) (<-chan *DeleteExchangeResponse, <-chan error)

DeleteExchangeWithChan invokes the amqp_open.DeleteExchange API asynchronously api document: https://help.aliyun.com/api/amqp-open/deleteexchange.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) DeleteQueue 

func (client *Client) DeleteQueue(request *DeleteQueueRequest) (response *DeleteQueueResponse, err error)

DeleteQueue invokes the amqp_open.DeleteQueue API synchronously api document: https://help.aliyun.com/api/amqp-open/deletequeue.html

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 api document: https://help.aliyun.com/api/amqp-open/deletequeue.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) DeleteQueueWithChan 

func (client *Client) DeleteQueueWithChan(request *DeleteQueueRequest) (<-chan *DeleteQueueResponse, <-chan error)

DeleteQueueWithChan invokes the amqp_open.DeleteQueue API asynchronously api document: https://help.aliyun.com/api/amqp-open/deletequeue.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) DeleteVirtualHost 

func (client *Client) DeleteVirtualHost(request *DeleteVirtualHostRequest) (response *DeleteVirtualHostResponse, err error)

DeleteVirtualHost invokes the amqp_open.DeleteVirtualHost API synchronously api document: https://help.aliyun.com/api/amqp-open/deletevirtualhost.html

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 api document: https://help.aliyun.com/api/amqp-open/deletevirtualhost.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) DeleteVirtualHostWithChan 

func (client *Client) DeleteVirtualHostWithChan(request *DeleteVirtualHostRequest) (<-chan *DeleteVirtualHostResponse, <-chan error)

DeleteVirtualHostWithChan invokes the amqp_open.DeleteVirtualHost API asynchronously api document: https://help.aliyun.com/api/amqp-open/deletevirtualhost.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) GetMetadataAmount 

func (client *Client) GetMetadataAmount(request *GetMetadataAmountRequest) (response *GetMetadataAmountResponse, err error)

GetMetadataAmount invokes the amqp_open.GetMetadataAmount API synchronously api document: https://help.aliyun.com/api/amqp-open/getmetadataamount.html

func (*Client) GetMetadataAmountWithCallback 

func (client *Client) GetMetadataAmountWithCallback(request *GetMetadataAmountRequest, callback func(response *GetMetadataAmountResponse, err error)) <-chan int

GetMetadataAmountWithCallback invokes the amqp_open.GetMetadataAmount API asynchronously api document: https://help.aliyun.com/api/amqp-open/getmetadataamount.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) GetMetadataAmountWithChan 

func (client *Client) GetMetadataAmountWithChan(request *GetMetadataAmountRequest) (<-chan *GetMetadataAmountResponse, <-chan error)

GetMetadataAmountWithChan invokes the amqp_open.GetMetadataAmount API asynchronously api document: https://help.aliyun.com/api/amqp-open/getmetadataamount.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListBindings 

func (client *Client) ListBindings(request *ListBindingsRequest) (response *ListBindingsResponse, err error)

ListBindings invokes the amqp_open.ListBindings API synchronously api document: https://help.aliyun.com/api/amqp-open/listbindings.html

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 api document: https://help.aliyun.com/api/amqp-open/listbindings.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListBindingsWithChan 

func (client *Client) ListBindingsWithChan(request *ListBindingsRequest) (<-chan *ListBindingsResponse, <-chan error)

ListBindingsWithChan invokes the amqp_open.ListBindings API asynchronously api document: https://help.aliyun.com/api/amqp-open/listbindings.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListDownStreamBindings 

func (client *Client) ListDownStreamBindings(request *ListDownStreamBindingsRequest) (response *ListDownStreamBindingsResponse, err error)

ListDownStreamBindings invokes the amqp_open.ListDownStreamBindings API synchronously api document: https://help.aliyun.com/api/amqp-open/listdownstreambindings.html

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 api document: https://help.aliyun.com/api/amqp-open/listdownstreambindings.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListDownStreamBindingsWithChan 

func (client *Client) ListDownStreamBindingsWithChan(request *ListDownStreamBindingsRequest) (<-chan *ListDownStreamBindingsResponse, <-chan error)

ListDownStreamBindingsWithChan invokes the amqp_open.ListDownStreamBindings API asynchronously api document: https://help.aliyun.com/api/amqp-open/listdownstreambindings.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListExchangeUpStreamBindings 

func (client *Client) ListExchangeUpStreamBindings(request *ListExchangeUpStreamBindingsRequest) (response *ListExchangeUpStreamBindingsResponse, err error)

ListExchangeUpStreamBindings invokes the amqp_open.ListExchangeUpStreamBindings API synchronously api document: https://help.aliyun.com/api/amqp-open/listexchangeupstreambindings.html

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 api document: https://help.aliyun.com/api/amqp-open/listexchangeupstreambindings.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListExchangeUpStreamBindingsWithChan 

func (client *Client) ListExchangeUpStreamBindingsWithChan(request *ListExchangeUpStreamBindingsRequest) (<-chan *ListExchangeUpStreamBindingsResponse, <-chan error)

ListExchangeUpStreamBindingsWithChan invokes the amqp_open.ListExchangeUpStreamBindings API asynchronously api document: https://help.aliyun.com/api/amqp-open/listexchangeupstreambindings.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListExchanges 

func (client *Client) ListExchanges(request *ListExchangesRequest) (response *ListExchangesResponse, err error)

ListExchanges invokes the amqp_open.ListExchanges API synchronously api document: https://help.aliyun.com/api/amqp-open/listexchanges.html

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 api document: https://help.aliyun.com/api/amqp-open/listexchanges.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListExchangesWithChan 

func (client *Client) ListExchangesWithChan(request *ListExchangesRequest) (<-chan *ListExchangesResponse, <-chan error)

ListExchangesWithChan invokes the amqp_open.ListExchanges API asynchronously api document: https://help.aliyun.com/api/amqp-open/listexchanges.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListInstances 

func (client *Client) ListInstances(request *ListInstancesRequest) (response *ListInstancesResponse, err error)

ListInstances invokes the amqp_open.ListInstances API synchronously api document: https://help.aliyun.com/api/amqp-open/listinstances.html

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 api document: https://help.aliyun.com/api/amqp-open/listinstances.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListInstancesWithChan 

func (client *Client) ListInstancesWithChan(request *ListInstancesRequest) (<-chan *ListInstancesResponse, <-chan error)

ListInstancesWithChan invokes the amqp_open.ListInstances API asynchronously api document: https://help.aliyun.com/api/amqp-open/listinstances.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListQueueConsumers 

func (client *Client) ListQueueConsumers(request *ListQueueConsumersRequest) (response *ListQueueConsumersResponse, err error)

ListQueueConsumers invokes the amqp_open.ListQueueConsumers API synchronously api document: https://help.aliyun.com/api/amqp-open/listqueueconsumers.html

func (*Client) ListQueueConsumersWithCallback 

func (client *Client) ListQueueConsumersWithCallback(request *ListQueueConsumersRequest, callback func(response *ListQueueConsumersResponse, err error)) <-chan int

ListQueueConsumersWithCallback invokes the amqp_open.ListQueueConsumers API asynchronously api document: https://help.aliyun.com/api/amqp-open/listqueueconsumers.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListQueueConsumersWithChan 

func (client *Client) ListQueueConsumersWithChan(request *ListQueueConsumersRequest) (<-chan *ListQueueConsumersResponse, <-chan error)

ListQueueConsumersWithChan invokes the amqp_open.ListQueueConsumers API asynchronously api document: https://help.aliyun.com/api/amqp-open/listqueueconsumers.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListQueueUpStreamBindings 

func (client *Client) ListQueueUpStreamBindings(request *ListQueueUpStreamBindingsRequest) (response *ListQueueUpStreamBindingsResponse, err error)

ListQueueUpStreamBindings invokes the amqp_open.ListQueueUpStreamBindings API synchronously api document: https://help.aliyun.com/api/amqp-open/listqueueupstreambindings.html

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 api document: https://help.aliyun.com/api/amqp-open/listqueueupstreambindings.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListQueueUpStreamBindingsWithChan 

func (client *Client) ListQueueUpStreamBindingsWithChan(request *ListQueueUpStreamBindingsRequest) (<-chan *ListQueueUpStreamBindingsResponse, <-chan error)

ListQueueUpStreamBindingsWithChan invokes the amqp_open.ListQueueUpStreamBindings API asynchronously api document: https://help.aliyun.com/api/amqp-open/listqueueupstreambindings.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListQueues 

func (client *Client) ListQueues(request *ListQueuesRequest) (response *ListQueuesResponse, err error)

ListQueues invokes the amqp_open.ListQueues API synchronously api document: https://help.aliyun.com/api/amqp-open/listqueues.html

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 api document: https://help.aliyun.com/api/amqp-open/listqueues.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListQueuesWithChan 

func (client *Client) ListQueuesWithChan(request *ListQueuesRequest) (<-chan *ListQueuesResponse, <-chan error)

ListQueuesWithChan invokes the amqp_open.ListQueues API asynchronously api document: https://help.aliyun.com/api/amqp-open/listqueues.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListVirtualHosts 

func (client *Client) ListVirtualHosts(request *ListVirtualHostsRequest) (response *ListVirtualHostsResponse, err error)

ListVirtualHosts invokes the amqp_open.ListVirtualHosts API synchronously api document: https://help.aliyun.com/api/amqp-open/listvirtualhosts.html

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 api document: https://help.aliyun.com/api/amqp-open/listvirtualhosts.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

func (*Client) ListVirtualHostsWithChan 

func (client *Client) ListVirtualHostsWithChan(request *ListVirtualHostsRequest) (<-chan *ListVirtualHostsResponse, <-chan error)

ListVirtualHostsWithChan invokes the amqp_open.ListVirtualHosts API asynchronously api document: https://help.aliyun.com/api/amqp-open/listvirtualhosts.html asynchronous document: https://help.aliyun.com/document_detail/66220.html

type Consumers 

type Consumers struct {
	QueueConsumerVO []QueueConsumerVO `json:"QueueConsumerVO" xml:"QueueConsumerVO"`
}

Consumers is a nested struct in amqp_open 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 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 {
	CurrentVirtualHosts int               `json:"CurrentVirtualHosts" xml:"CurrentVirtualHosts"`
	MaxQueues           int               `json:"MaxQueues" xml:"MaxQueues"`
	MaxVirtualHosts     int               `json:"MaxVirtualHosts" xml:"MaxVirtualHosts"`
	MaxExchanges        int               `json:"MaxExchanges" xml:"MaxExchanges"`
	NextToken           string            `json:"NextToken" xml:"NextToken"`
	CurrentExchanges    int               `json:"CurrentExchanges" xml:"CurrentExchanges"`
	CurrentQueues       int               `json:"CurrentQueues" xml:"CurrentQueues"`
	MaxResults          int               `json:"MaxResults" xml:"MaxResults"`
	Instances           []InstanceVO      `json:"Instances" xml:"Instances"`
	Queues              []QueueVO         `json:"Queues" xml:"Queues"`
	Exchanges           []ExchangeVO      `json:"Exchanges" xml:"Exchanges"`
	Consumers           []QueueConsumerVO `json:"Consumers" xml:"Consumers"`
	Bindings            []BindingDO       `json:"Bindings" xml:"Bindings"`
	VirtualHosts        []VhostVO         `json:"VirtualHosts" xml:"VirtualHosts"`
}

Data is a nested struct in amqp_open response

type DataInListDownStreamBindings 

type DataInListDownStreamBindings struct {
	NextToken  string      `json:"NextToken" xml:"NextToken"`
	MaxResults int         `json:"MaxResults" xml:"MaxResults"`
	Bindings   []BindingVO `json:"Bindings" xml:"Bindings"`
}

DataInListDownStreamBindings is a nested struct in amqp_open response

type DataInListExchangeUpStreamBindings 

type DataInListExchangeUpStreamBindings struct {
	NextToken  string      `json:"NextToken" xml:"NextToken"`
	MaxResults int         `json:"MaxResults" xml:"MaxResults"`
	Bindings   []BindingVO `json:"Bindings" xml:"Bindings"`
}

DataInListExchangeUpStreamBindings is a nested struct in amqp_open response

type DataInListQueueUpStreamBindings 

type DataInListQueueUpStreamBindings struct {
	NextToken  string      `json:"NextToken" xml:"NextToken"`
	MaxResults string      `json:"MaxResults" xml:"MaxResults"`
	Bindings   []BindingVO `json:"Bindings" xml:"Bindings"`
}

DataInListQueueUpStreamBindings is a nested struct in amqp_open 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 {
	Name            string                 `json:"Name" xml:"Name"`
	VHostName       string                 `json:"VHostName" xml:"VHostName"`
	ExchangeType    string                 `json:"ExchangeType" xml:"ExchangeType"`
	AutoDeleteState bool                   `json:"AutoDeleteState" xml:"AutoDeleteState"`
	Attributes      map[string]interface{} `json:"Attributes" xml:"Attributes"`
	CreateTime      int64                  `json:"CreateTime" xml:"CreateTime"`
}

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 

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

GetMetadataAmountRequest is the request struct for api GetMetadataAmount

func CreateGetMetadataAmountRequest 

func CreateGetMetadataAmountRequest() (request *GetMetadataAmountRequest)

CreateGetMetadataAmountRequest creates a request to invoke GetMetadataAmount API

type GetMetadataAmountResponse 

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 

func CreateGetMetadataAmountResponse() (response *GetMetadataAmountResponse)

CreateGetMetadataAmountResponse creates a response to parse from GetMetadataAmount response

type InstanceVO 

type InstanceVO struct {
	InstanceId        string `json:"InstanceId" xml:"InstanceId"`
	InstanceName      string `json:"InstanceName" xml:"InstanceName"`
	InstanceType      string `json:"InstanceType" xml:"InstanceType"`
	Status            string `json:"Status" xml:"Status"`
	OrderType         string `json:"OrderType" xml:"OrderType"`
	OrderCreateTime   int64  `json:"OrderCreateTime" xml:"OrderCreateTime"`
	ExpireTime        int64  `json:"ExpireTime" xml:"ExpireTime"`
	AutoRenewInstance bool   `json:"AutoRenewInstance" xml:"AutoRenewInstance"`
	SupportEIP        bool   `json:"SupportEIP" xml:"SupportEIP"`
	PrivateEndpoint   string `json:"PrivateEndpoint" xml:"PrivateEndpoint"`
	PublicEndpoint    string `json:"PublicEndpoint" xml:"PublicEndpoint"`
}

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

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 

func CreateListQueueConsumersRequest() (request *ListQueueConsumersRequest)

CreateListQueueConsumersRequest creates a request to invoke ListQueueConsumers API

type ListQueueConsumersResponse 

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 

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 

type QueueConsumerVO struct {
	ConsumerTag string `json:"ConsumerTag" xml:"ConsumerTag"`
}

QueueConsumerVO is a nested struct in amqp_open response

type QueueVO 

type QueueVO struct {
	Name            string                 `json:"Name" xml:"Name"`
	OwnerId         string                 `json:"OwnerId" xml:"OwnerId"`
	VHostName       string                 `json:"VHostName" xml:"VHostName"`
	AutoDeleteState bool                   `json:"AutoDeleteState" xml:"AutoDeleteState"`
	ExclusiveState  bool                   `json:"ExclusiveState" xml:"ExclusiveState"`
	CreateTime      int64                  `json:"CreateTime" xml:"CreateTime"`
	LastConsumeTime int64                  `json:"LastConsumeTime" xml:"LastConsumeTime"`
	Attributes      map[string]interface{} `json:"Attributes" xml:"Attributes"`
}

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

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.