mns_open

package
v1.63.61 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 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 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) CreateQueue 

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

CreateQueue invokes the mns_open.CreateQueue API synchronously

func (*Client) CreateQueueWithCallback 

func (client *Client) CreateQueueWithCallback(request *CreateQueueRequest, callback func(response *CreateQueueResponse, err error)) <-chan int

CreateQueueWithCallback invokes the mns_open.CreateQueue API asynchronously

func (*Client) CreateQueueWithChan 

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

CreateQueueWithChan invokes the mns_open.CreateQueue API asynchronously

func (*Client) CreateTopic 

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

CreateTopic invokes the mns_open.CreateTopic API synchronously

func (*Client) CreateTopicWithCallback 

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

CreateTopicWithCallback invokes the mns_open.CreateTopic API asynchronously

func (*Client) CreateTopicWithChan 

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

CreateTopicWithChan invokes the mns_open.CreateTopic API asynchronously

func (*Client) DeleteQueue 

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

DeleteQueue invokes the mns_open.DeleteQueue API synchronously

func (*Client) DeleteQueueWithCallback 

func (client *Client) DeleteQueueWithCallback(request *DeleteQueueRequest, callback func(response *DeleteQueueResponse, err error)) <-chan int

DeleteQueueWithCallback invokes the mns_open.DeleteQueue API asynchronously

func (*Client) DeleteQueueWithChan 

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

DeleteQueueWithChan invokes the mns_open.DeleteQueue API asynchronously

func (*Client) DeleteTopic 

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

DeleteTopic invokes the mns_open.DeleteTopic API synchronously

func (*Client) DeleteTopicWithCallback 

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

DeleteTopicWithCallback invokes the mns_open.DeleteTopic API asynchronously

func (*Client) DeleteTopicWithChan 

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

DeleteTopicWithChan invokes the mns_open.DeleteTopic API asynchronously

func (*Client) GetQueueAttributes 

func (client *Client) GetQueueAttributes(request *GetQueueAttributesRequest) (response *GetQueueAttributesResponse, err error)

GetQueueAttributes invokes the mns_open.GetQueueAttributes API synchronously

func (*Client) GetQueueAttributesWithCallback 

func (client *Client) GetQueueAttributesWithCallback(request *GetQueueAttributesRequest, callback func(response *GetQueueAttributesResponse, err error)) <-chan int

GetQueueAttributesWithCallback invokes the mns_open.GetQueueAttributes API asynchronously

func (*Client) GetQueueAttributesWithChan 

func (client *Client) GetQueueAttributesWithChan(request *GetQueueAttributesRequest) (<-chan *GetQueueAttributesResponse, <-chan error)

GetQueueAttributesWithChan invokes the mns_open.GetQueueAttributes API asynchronously

func (*Client) GetSubscriptionAttributes 

func (client *Client) GetSubscriptionAttributes(request *GetSubscriptionAttributesRequest) (response *GetSubscriptionAttributesResponse, err error)

GetSubscriptionAttributes invokes the mns_open.GetSubscriptionAttributes API synchronously

func (*Client) GetSubscriptionAttributesWithCallback 

func (client *Client) GetSubscriptionAttributesWithCallback(request *GetSubscriptionAttributesRequest, callback func(response *GetSubscriptionAttributesResponse, err error)) <-chan int

GetSubscriptionAttributesWithCallback invokes the mns_open.GetSubscriptionAttributes API asynchronously

func (*Client) GetSubscriptionAttributesWithChan 

func (client *Client) GetSubscriptionAttributesWithChan(request *GetSubscriptionAttributesRequest) (<-chan *GetSubscriptionAttributesResponse, <-chan error)

GetSubscriptionAttributesWithChan invokes the mns_open.GetSubscriptionAttributes API asynchronously

func (*Client) GetTopicAttributes 

func (client *Client) GetTopicAttributes(request *GetTopicAttributesRequest) (response *GetTopicAttributesResponse, err error)

GetTopicAttributes invokes the mns_open.GetTopicAttributes API synchronously

func (*Client) GetTopicAttributesWithCallback 

func (client *Client) GetTopicAttributesWithCallback(request *GetTopicAttributesRequest, callback func(response *GetTopicAttributesResponse, err error)) <-chan int

GetTopicAttributesWithCallback invokes the mns_open.GetTopicAttributes API asynchronously

func (*Client) GetTopicAttributesWithChan 

func (client *Client) GetTopicAttributesWithChan(request *GetTopicAttributesRequest) (<-chan *GetTopicAttributesResponse, <-chan error)

GetTopicAttributesWithChan invokes the mns_open.GetTopicAttributes API asynchronously

func (*Client) ListQueue 

func (client *Client) ListQueue(request *ListQueueRequest) (response *ListQueueResponse, err error)

ListQueue invokes the mns_open.ListQueue API synchronously

func (*Client) ListQueueWithCallback 

func (client *Client) ListQueueWithCallback(request *ListQueueRequest, callback func(response *ListQueueResponse, err error)) <-chan int

ListQueueWithCallback invokes the mns_open.ListQueue API asynchronously

func (*Client) ListQueueWithChan 

func (client *Client) ListQueueWithChan(request *ListQueueRequest) (<-chan *ListQueueResponse, <-chan error)

ListQueueWithChan invokes the mns_open.ListQueue API asynchronously

func (*Client) ListSubscriptionByTopic 

func (client *Client) ListSubscriptionByTopic(request *ListSubscriptionByTopicRequest) (response *ListSubscriptionByTopicResponse, err error)

ListSubscriptionByTopic invokes the mns_open.ListSubscriptionByTopic API synchronously

func (*Client) ListSubscriptionByTopicWithCallback 

func (client *Client) ListSubscriptionByTopicWithCallback(request *ListSubscriptionByTopicRequest, callback func(response *ListSubscriptionByTopicResponse, err error)) <-chan int

ListSubscriptionByTopicWithCallback invokes the mns_open.ListSubscriptionByTopic API asynchronously

func (*Client) ListSubscriptionByTopicWithChan 

func (client *Client) ListSubscriptionByTopicWithChan(request *ListSubscriptionByTopicRequest) (<-chan *ListSubscriptionByTopicResponse, <-chan error)

ListSubscriptionByTopicWithChan invokes the mns_open.ListSubscriptionByTopic API asynchronously

func (*Client) ListTopic 

func (client *Client) ListTopic(request *ListTopicRequest) (response *ListTopicResponse, err error)

ListTopic invokes the mns_open.ListTopic API synchronously

func (*Client) ListTopicWithCallback 

func (client *Client) ListTopicWithCallback(request *ListTopicRequest, callback func(response *ListTopicResponse, err error)) <-chan int

ListTopicWithCallback invokes the mns_open.ListTopic API asynchronously

func (*Client) ListTopicWithChan 

func (client *Client) ListTopicWithChan(request *ListTopicRequest) (<-chan *ListTopicResponse, <-chan error)

ListTopicWithChan invokes the mns_open.ListTopic API asynchronously

func (*Client) SetQueueAttributes 

func (client *Client) SetQueueAttributes(request *SetQueueAttributesRequest) (response *SetQueueAttributesResponse, err error)

SetQueueAttributes invokes the mns_open.SetQueueAttributes API synchronously

func (*Client) SetQueueAttributesWithCallback 

func (client *Client) SetQueueAttributesWithCallback(request *SetQueueAttributesRequest, callback func(response *SetQueueAttributesResponse, err error)) <-chan int

SetQueueAttributesWithCallback invokes the mns_open.SetQueueAttributes API asynchronously

func (*Client) SetQueueAttributesWithChan 

func (client *Client) SetQueueAttributesWithChan(request *SetQueueAttributesRequest) (<-chan *SetQueueAttributesResponse, <-chan error)

SetQueueAttributesWithChan invokes the mns_open.SetQueueAttributes API asynchronously

func (*Client) SetSubscriptionAttributes 

func (client *Client) SetSubscriptionAttributes(request *SetSubscriptionAttributesRequest) (response *SetSubscriptionAttributesResponse, err error)

SetSubscriptionAttributes invokes the mns_open.SetSubscriptionAttributes API synchronously

func (*Client) SetSubscriptionAttributesWithCallback 

func (client *Client) SetSubscriptionAttributesWithCallback(request *SetSubscriptionAttributesRequest, callback func(response *SetSubscriptionAttributesResponse, err error)) <-chan int

SetSubscriptionAttributesWithCallback invokes the mns_open.SetSubscriptionAttributes API asynchronously

func (*Client) SetSubscriptionAttributesWithChan 

func (client *Client) SetSubscriptionAttributesWithChan(request *SetSubscriptionAttributesRequest) (<-chan *SetSubscriptionAttributesResponse, <-chan error)

SetSubscriptionAttributesWithChan invokes the mns_open.SetSubscriptionAttributes API asynchronously

func (*Client) SetTopicAttributes 

func (client *Client) SetTopicAttributes(request *SetTopicAttributesRequest) (response *SetTopicAttributesResponse, err error)

SetTopicAttributes invokes the mns_open.SetTopicAttributes API synchronously

func (*Client) SetTopicAttributesWithCallback 

func (client *Client) SetTopicAttributesWithCallback(request *SetTopicAttributesRequest, callback func(response *SetTopicAttributesResponse, err error)) <-chan int

SetTopicAttributesWithCallback invokes the mns_open.SetTopicAttributes API asynchronously

func (*Client) SetTopicAttributesWithChan 

func (client *Client) SetTopicAttributesWithChan(request *SetTopicAttributesRequest) (<-chan *SetTopicAttributesResponse, <-chan error)

SetTopicAttributesWithChan invokes the mns_open.SetTopicAttributes API asynchronously

func (*Client) Subscribe 

func (client *Client) Subscribe(request *SubscribeRequest) (response *SubscribeResponse, err error)

Subscribe invokes the mns_open.Subscribe API synchronously

func (*Client) SubscribeWithCallback 

func (client *Client) SubscribeWithCallback(request *SubscribeRequest, callback func(response *SubscribeResponse, err error)) <-chan int

SubscribeWithCallback invokes the mns_open.Subscribe API asynchronously

func (*Client) SubscribeWithChan 

func (client *Client) SubscribeWithChan(request *SubscribeRequest) (<-chan *SubscribeResponse, <-chan error)

SubscribeWithChan invokes the mns_open.Subscribe API asynchronously

func (*Client) Unsubscribe 

func (client *Client) Unsubscribe(request *UnsubscribeRequest) (response *UnsubscribeResponse, err error)

Unsubscribe invokes the mns_open.Unsubscribe API synchronously

func (*Client) UnsubscribeWithCallback 

func (client *Client) UnsubscribeWithCallback(request *UnsubscribeRequest, callback func(response *UnsubscribeResponse, err error)) <-chan int

UnsubscribeWithCallback invokes the mns_open.Unsubscribe API asynchronously

func (*Client) UnsubscribeWithChan 

func (client *Client) UnsubscribeWithChan(request *UnsubscribeRequest) (<-chan *UnsubscribeResponse, <-chan error)

UnsubscribeWithChan invokes the mns_open.Unsubscribe API asynchronously

type CreateQueueRequest 

type CreateQueueRequest struct {
	*requests.RpcRequest
	QueueName              string           `position:"Query" name:"QueueName"`
	MessageRetentionPeriod requests.Integer `position:"Query" name:"MessageRetentionPeriod"`
	EnableLogging          requests.Boolean `position:"Query" name:"EnableLogging"`
	VisibilityTimeout      requests.Integer `position:"Query" name:"VisibilityTimeout"`
	MaximumMessageSize     requests.Integer `position:"Query" name:"MaximumMessageSize"`
	DelaySeconds           requests.Integer `position:"Query" name:"DelaySeconds"`
	PollingWaitSeconds     requests.Integer `position:"Query" name:"PollingWaitSeconds"`
}

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"`
	Code      int64  `json:"Code" xml:"Code"`
	Status    string `json:"Status" xml:"Status"`
	Message   string `json:"Message" xml:"Message"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

CreateQueueResponse is the response struct for api CreateQueue

func CreateCreateQueueResponse 

func CreateCreateQueueResponse() (response *CreateQueueResponse)

CreateCreateQueueResponse creates a response to parse from CreateQueue response

type CreateTopicRequest 

type CreateTopicRequest struct {
	*requests.RpcRequest
	TopicName      string           `position:"Body" name:"TopicName"`
	MaxMessageSize requests.Integer `position:"Body" name:"MaxMessageSize"`
	EnableLogging  requests.Boolean `position:"Body" name:"EnableLogging"`
}

CreateTopicRequest is the request struct for api CreateTopic

func CreateCreateTopicRequest 

func CreateCreateTopicRequest() (request *CreateTopicRequest)

CreateCreateTopicRequest creates a request to invoke CreateTopic API

type CreateTopicResponse 

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

CreateTopicResponse is the response struct for api CreateTopic

func CreateCreateTopicResponse 

func CreateCreateTopicResponse() (response *CreateTopicResponse)

CreateCreateTopicResponse creates a response to parse from CreateTopic response

type Data 

type Data struct {
	LastModifyTime         int64          `json:"LastModifyTime" xml:"LastModifyTime"`
	QueueName              string         `json:"QueueName" xml:"QueueName"`
	PollingWaitSeconds     int64          `json:"PollingWaitSeconds" xml:"PollingWaitSeconds"`
	PageSize               int64          `json:"PageSize" xml:"PageSize"`
	CreateTime             int64          `json:"CreateTime" xml:"CreateTime"`
	NotifyContentFormat    string         `json:"NotifyContentFormat" xml:"NotifyContentFormat"`
	Endpoint               string         `json:"Endpoint" xml:"Endpoint"`
	MaxMessageSize         int64          `json:"MaxMessageSize" xml:"MaxMessageSize"`
	Pages                  int64          `json:"Pages" xml:"Pages"`
	Size                   int64          `json:"Size" xml:"Size"`
	ActiveMessages         int64          `json:"ActiveMessages" xml:"ActiveMessages"`
	InactiveMessages       int64          `json:"InactiveMessages" xml:"InactiveMessages"`
	TopicOwner             string         `json:"TopicOwner" xml:"TopicOwner"`
	TopicName              string         `json:"TopicName" xml:"TopicName"`
	NotifyStrategy         string         `json:"NotifyStrategy" xml:"NotifyStrategy"`
	VisibilityTimeout      int64          `json:"VisibilityTimeout" xml:"VisibilityTimeout"`
	SubscriptionName       string         `json:"SubscriptionName" xml:"SubscriptionName"`
	Message                string         `json:"Message" xml:"Message"`
	MessageRetentionPeriod int64          `json:"MessageRetentionPeriod" xml:"MessageRetentionPeriod"`
	MessageCount           int64          `json:"MessageCount" xml:"MessageCount"`
	DelaySeconds           int64          `json:"DelaySeconds" xml:"DelaySeconds"`
	MaximumMessageSize     int64          `json:"MaximumMessageSize" xml:"MaximumMessageSize"`
	Code                   int64          `json:"Code" xml:"Code"`
	PageNum                int64          `json:"PageNum" xml:"PageNum"`
	Success                bool           `json:"Success" xml:"Success"`
	FilterTag              string         `json:"FilterTag" xml:"FilterTag"`
	Total                  int64          `json:"Total" xml:"Total"`
	DelayMessages          int64          `json:"DelayMessages" xml:"DelayMessages"`
	LoggingEnabled         bool           `json:"LoggingEnabled" xml:"LoggingEnabled"`
	PageData               []PageDataItem `json:"PageData" xml:"PageData"`
}

Data is a nested struct in mns_open response

type DeleteQueueRequest 

type DeleteQueueRequest struct {
	*requests.RpcRequest
	QueueName string `position:"Query" name:"QueueName"`
}

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"`
	Code      int64  `json:"Code" xml:"Code"`
	Status    string `json:"Status" xml:"Status"`
	Message   string `json:"Message" xml:"Message"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

DeleteQueueResponse is the response struct for api DeleteQueue

func CreateDeleteQueueResponse 

func CreateDeleteQueueResponse() (response *DeleteQueueResponse)

CreateDeleteQueueResponse creates a response to parse from DeleteQueue response

type DeleteTopicRequest 

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

DeleteTopicRequest is the request struct for api DeleteTopic

func CreateDeleteTopicRequest 

func CreateDeleteTopicRequest() (request *DeleteTopicRequest)

CreateDeleteTopicRequest creates a request to invoke DeleteTopic API

type DeleteTopicResponse 

type DeleteTopicResponse struct {
	*responses.BaseResponse
	RequestId string                 `json:"RequestId" xml:"RequestId"`
	Code      int64                  `json:"Code" xml:"Code"`
	Status    string                 `json:"Status" xml:"Status"`
	Message   string                 `json:"Message" xml:"Message"`
	Success   bool                   `json:"Success" xml:"Success"`
	Data      map[string]interface{} `json:"Data" xml:"Data"`
}

DeleteTopicResponse is the response struct for api DeleteTopic

func CreateDeleteTopicResponse 

func CreateDeleteTopicResponse() (response *DeleteTopicResponse)

CreateDeleteTopicResponse creates a response to parse from DeleteTopic response

type GetQueueAttributesRequest 

type GetQueueAttributesRequest struct {
	*requests.RpcRequest
	QueueName string `position:"Query" name:"QueueName"`
}

GetQueueAttributesRequest is the request struct for api GetQueueAttributes

func CreateGetQueueAttributesRequest 

func CreateGetQueueAttributesRequest() (request *GetQueueAttributesRequest)

CreateGetQueueAttributesRequest creates a request to invoke GetQueueAttributes API

type GetQueueAttributesResponse 

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

GetQueueAttributesResponse is the response struct for api GetQueueAttributes

func CreateGetQueueAttributesResponse 

func CreateGetQueueAttributesResponse() (response *GetQueueAttributesResponse)

CreateGetQueueAttributesResponse creates a response to parse from GetQueueAttributes response

type GetSubscriptionAttributesRequest 

type GetSubscriptionAttributesRequest struct {
	*requests.RpcRequest
	SubscriptionName string `position:"Query" name:"SubscriptionName"`
	TopicName        string `position:"Query" name:"TopicName"`
}

GetSubscriptionAttributesRequest is the request struct for api GetSubscriptionAttributes

func CreateGetSubscriptionAttributesRequest 

func CreateGetSubscriptionAttributesRequest() (request *GetSubscriptionAttributesRequest)

CreateGetSubscriptionAttributesRequest creates a request to invoke GetSubscriptionAttributes API

type GetSubscriptionAttributesResponse 

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

GetSubscriptionAttributesResponse is the response struct for api GetSubscriptionAttributes

func CreateGetSubscriptionAttributesResponse 

func CreateGetSubscriptionAttributesResponse() (response *GetSubscriptionAttributesResponse)

CreateGetSubscriptionAttributesResponse creates a response to parse from GetSubscriptionAttributes response

type GetTopicAttributesRequest 

type GetTopicAttributesRequest struct {
	*requests.RpcRequest
	TopicName string `position:"Query" name:"TopicName"`
}

GetTopicAttributesRequest is the request struct for api GetTopicAttributes

func CreateGetTopicAttributesRequest 

func CreateGetTopicAttributesRequest() (request *GetTopicAttributesRequest)

CreateGetTopicAttributesRequest creates a request to invoke GetTopicAttributes API

type GetTopicAttributesResponse 

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

GetTopicAttributesResponse is the response struct for api GetTopicAttributes

func CreateGetTopicAttributesResponse 

func CreateGetTopicAttributesResponse() (response *GetTopicAttributesResponse)

CreateGetTopicAttributesResponse creates a response to parse from GetTopicAttributes response

type ListQueueRequest 

type ListQueueRequest struct {
	*requests.RpcRequest
	QueueName string           `position:"Query" name:"QueueName"`
	PageNum   requests.Integer `position:"Query" name:"PageNum"`
	PageSize  requests.Integer `position:"Query" name:"PageSize"`
}

ListQueueRequest is the request struct for api ListQueue

func CreateListQueueRequest 

func CreateListQueueRequest() (request *ListQueueRequest)

CreateListQueueRequest creates a request to invoke ListQueue API

type ListQueueResponse 

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

ListQueueResponse is the response struct for api ListQueue

func CreateListQueueResponse 

func CreateListQueueResponse() (response *ListQueueResponse)

CreateListQueueResponse creates a response to parse from ListQueue response

type ListSubscriptionByTopicRequest 

type ListSubscriptionByTopicRequest struct {
	*requests.RpcRequest
	SubscriptionName string           `position:"Query" name:"SubscriptionName"`
	TopicName        string           `position:"Query" name:"TopicName"`
	PageNum          requests.Integer `position:"Query" name:"PageNum"`
	PageSize         requests.Integer `position:"Query" name:"PageSize"`
}

ListSubscriptionByTopicRequest is the request struct for api ListSubscriptionByTopic

func CreateListSubscriptionByTopicRequest 

func CreateListSubscriptionByTopicRequest() (request *ListSubscriptionByTopicRequest)

CreateListSubscriptionByTopicRequest creates a request to invoke ListSubscriptionByTopic API

type ListSubscriptionByTopicResponse 

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

ListSubscriptionByTopicResponse is the response struct for api ListSubscriptionByTopic

func CreateListSubscriptionByTopicResponse 

func CreateListSubscriptionByTopicResponse() (response *ListSubscriptionByTopicResponse)

CreateListSubscriptionByTopicResponse creates a response to parse from ListSubscriptionByTopic response

type ListTopicRequest 

type ListTopicRequest struct {
	*requests.RpcRequest
	TopicName string           `position:"Query" name:"TopicName"`
	PageNum   requests.Integer `position:"Query" name:"PageNum"`
	PageSize  requests.Integer `position:"Query" name:"PageSize"`
}

ListTopicRequest is the request struct for api ListTopic

func CreateListTopicRequest 

func CreateListTopicRequest() (request *ListTopicRequest)

CreateListTopicRequest creates a request to invoke ListTopic API

type ListTopicResponse 

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

ListTopicResponse is the response struct for api ListTopic

func CreateListTopicResponse 

func CreateListTopicResponse() (response *ListTopicResponse)

CreateListTopicResponse creates a response to parse from ListTopic response

type PageDataInListQueue 

type PageDataInListQueue struct {
	PageDataItem []PageDataItem `json:"pageData" xml:"pageData"`
}

PageDataInListQueue is a nested struct in mns_open response

type PageDataInListSubscriptionByTopic 

type PageDataInListSubscriptionByTopic struct {
	PageDataItem []PageDataItem `json:"pageData" xml:"pageData"`
}

PageDataInListSubscriptionByTopic is a nested struct in mns_open response

type PageDataInListTopic 

type PageDataInListTopic struct {
	PageDataItem []PageDataItem `json:"pageData" xml:"pageData"`
}

PageDataInListTopic is a nested struct in mns_open response

type PageDataItem added in v1.62.172 

type PageDataItem struct {
	LastModifyTime         int64  `json:"LastModifyTime" xml:"LastModifyTime"`
	TopicName              string `json:"TopicName" xml:"TopicName"`
	NotifyStrategy         string `json:"NotifyStrategy" xml:"NotifyStrategy"`
	QueueName              string `json:"QueueName" xml:"QueueName"`
	VisibilityTimeout      int64  `json:"VisibilityTimeout" xml:"VisibilityTimeout"`
	PollingWaitSeconds     int64  `json:"PollingWaitSeconds" xml:"PollingWaitSeconds"`
	SubscriptionName       string `json:"SubscriptionName" xml:"SubscriptionName"`
	MessageRetentionPeriod int64  `json:"MessageRetentionPeriod" xml:"MessageRetentionPeriod"`
	MessageCount           int64  `json:"MessageCount" xml:"MessageCount"`
	DelaySeconds           int64  `json:"DelaySeconds" xml:"DelaySeconds"`
	MaximumMessageSize     int64  `json:"MaximumMessageSize" xml:"MaximumMessageSize"`
	CreateTime             int64  `json:"CreateTime" xml:"CreateTime"`
	NotifyContentFormat    string `json:"NotifyContentFormat" xml:"NotifyContentFormat"`
	Endpoint               string `json:"Endpoint" xml:"Endpoint"`
	MaxMessageSize         int64  `json:"MaxMessageSize" xml:"MaxMessageSize"`
	FilterTag              string `json:"FilterTag" xml:"FilterTag"`
	ActiveMessages         int64  `json:"ActiveMessages" xml:"ActiveMessages"`
	InactiveMessages       int64  `json:"InactiveMessages" xml:"InactiveMessages"`
	DelayMessages          int64  `json:"DelayMessages" xml:"DelayMessages"`
	LoggingEnabled         bool   `json:"LoggingEnabled" xml:"LoggingEnabled"`
	TopicOwner             string `json:"TopicOwner" xml:"TopicOwner"`
}

PageDataItem is a nested struct in mns_open response

type SetQueueAttributesRequest 

type SetQueueAttributesRequest struct {
	*requests.RpcRequest
	QueueName              string           `position:"Query" name:"QueueName"`
	MessageRetentionPeriod requests.Integer `position:"Query" name:"MessageRetentionPeriod"`
	EnableLogging          requests.Boolean `position:"Query" name:"EnableLogging"`
	VisibilityTimeout      requests.Integer `position:"Query" name:"VisibilityTimeout"`
	DelaySeconds           requests.Integer `position:"Query" name:"DelaySeconds"`
	MaximumMessageSize     requests.Integer `position:"Query" name:"MaximumMessageSize"`
	PollingWaitSeconds     requests.Integer `position:"Query" name:"PollingWaitSeconds"`
}

SetQueueAttributesRequest is the request struct for api SetQueueAttributes

func CreateSetQueueAttributesRequest 

func CreateSetQueueAttributesRequest() (request *SetQueueAttributesRequest)

CreateSetQueueAttributesRequest creates a request to invoke SetQueueAttributes API

type SetQueueAttributesResponse 

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

SetQueueAttributesResponse is the response struct for api SetQueueAttributes

func CreateSetQueueAttributesResponse 

func CreateSetQueueAttributesResponse() (response *SetQueueAttributesResponse)

CreateSetQueueAttributesResponse creates a response to parse from SetQueueAttributes response

type SetSubscriptionAttributesRequest 

type SetSubscriptionAttributesRequest struct {
	*requests.RpcRequest
	SubscriptionName string `position:"Query" name:"SubscriptionName"`
	TopicName        string `position:"Query" name:"TopicName"`
	NotifyStrategy   string `position:"Query" name:"NotifyStrategy"`
}

SetSubscriptionAttributesRequest is the request struct for api SetSubscriptionAttributes

func CreateSetSubscriptionAttributesRequest 

func CreateSetSubscriptionAttributesRequest() (request *SetSubscriptionAttributesRequest)

CreateSetSubscriptionAttributesRequest creates a request to invoke SetSubscriptionAttributes API

type SetSubscriptionAttributesResponse 

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

SetSubscriptionAttributesResponse is the response struct for api SetSubscriptionAttributes

func CreateSetSubscriptionAttributesResponse 

func CreateSetSubscriptionAttributesResponse() (response *SetSubscriptionAttributesResponse)

CreateSetSubscriptionAttributesResponse creates a response to parse from SetSubscriptionAttributes response

type SetTopicAttributesRequest 

type SetTopicAttributesRequest struct {
	*requests.RpcRequest
	TopicName      string           `position:"Query" name:"TopicName"`
	MaxMessageSize requests.Integer `position:"Query" name:"MaxMessageSize"`
	EnableLogging  requests.Boolean `position:"Query" name:"EnableLogging"`
}

SetTopicAttributesRequest is the request struct for api SetTopicAttributes

func CreateSetTopicAttributesRequest 

func CreateSetTopicAttributesRequest() (request *SetTopicAttributesRequest)

CreateSetTopicAttributesRequest creates a request to invoke SetTopicAttributes API

type SetTopicAttributesResponse 

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

SetTopicAttributesResponse is the response struct for api SetTopicAttributes

func CreateSetTopicAttributesResponse 

func CreateSetTopicAttributesResponse() (response *SetTopicAttributesResponse)

CreateSetTopicAttributesResponse creates a response to parse from SetTopicAttributes response

type SubscribeRequest 

type SubscribeRequest struct {
	*requests.RpcRequest
	TopicName           string `position:"Query" name:"TopicName"`
	MessageTag          string `position:"Query" name:"MessageTag"`
	Endpoint            string `position:"Query" name:"Endpoint"`
	SubscriptionName    string `position:"Query" name:"SubscriptionName"`
	NotifyStrategy      string `position:"Query" name:"NotifyStrategy"`
	NotifyContentFormat string `position:"Query" name:"NotifyContentFormat"`
	PushType            string `position:"Query" name:"PushType"`
}

SubscribeRequest is the request struct for api Subscribe

func CreateSubscribeRequest 

func CreateSubscribeRequest() (request *SubscribeRequest)

CreateSubscribeRequest creates a request to invoke Subscribe API

type SubscribeResponse 

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

SubscribeResponse is the response struct for api Subscribe

func CreateSubscribeResponse 

func CreateSubscribeResponse() (response *SubscribeResponse)

CreateSubscribeResponse creates a response to parse from Subscribe response

type UnsubscribeRequest 

type UnsubscribeRequest struct {
	*requests.RpcRequest
	SubscriptionName string `position:"Query" name:"SubscriptionName"`
	TopicName        string `position:"Query" name:"TopicName"`
}

UnsubscribeRequest is the request struct for api Unsubscribe

func CreateUnsubscribeRequest 

func CreateUnsubscribeRequest() (request *UnsubscribeRequest)

CreateUnsubscribeRequest creates a request to invoke Unsubscribe API

type UnsubscribeResponse 

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

UnsubscribeResponse is the response struct for api Unsubscribe

func CreateUnsubscribeResponse 

func CreateUnsubscribeResponse() (response *UnsubscribeResponse)

CreateUnsubscribeResponse creates a response to parse from Unsubscribe 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.