v20190304

package
v3.0.1095+incompatible Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// Operation failed.
	FAILEDOPERATION = "FailedOperation"

	// The operation is in progress. Please try again later.
	FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"

	// Invalid parameter.
	INVALIDPARAMETER = "InvalidParameter"

	// The task ID does not exist.
	INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"

	// The quota limit is exceeded.
	LIMITEXCEEDED = "LimitExceeded"

	// The resource is in use.
	RESOURCEINUSE = "ResourceInUse"

	// The resource does not exist.
	RESOURCENOTFOUND = "ResourceNotFound"

	// The resource is unavailable.
	RESOURCEUNAVAILABLE = "ResourceUnavailable"

	// The resources have been sold out.
	RESOURCESSOLDOUT = "ResourcesSoldOut"

	// Unauthorized operation.
	UNAUTHORIZEDOPERATION = "UnauthorizedOperation"
)
View Source 
const APIVersion = "2019-03-04"

Variables

This section is empty.

Functions

This section is empty.

Types

type ClearQueueRequest 

type ClearQueueRequest struct {
	*tchttp.BaseRequest

	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

func NewClearQueueRequest 

func NewClearQueueRequest() (request *ClearQueueRequest)

func (*ClearQueueRequest) FromJsonString 

func (r *ClearQueueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ClearQueueRequest) ToJsonString 

func (r *ClearQueueRequest) ToJsonString() string

type ClearQueueRequestParams 

type ClearQueueRequestParams struct {
	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

Predefined struct for user

type ClearQueueResponse 

type ClearQueueResponse struct {
	*tchttp.BaseResponse
	Response *ClearQueueResponseParams `json:"Response"`
}

func NewClearQueueResponse 

func NewClearQueueResponse() (response *ClearQueueResponse)

func (*ClearQueueResponse) FromJsonString 

func (r *ClearQueueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ClearQueueResponse) ToJsonString 

func (r *ClearQueueResponse) ToJsonString() string

type ClearQueueResponseParams 

type ClearQueueResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ClearSubscriptionFilterTagsRequest 

type ClearSubscriptionFilterTagsRequest struct {
	*tchttp.BaseRequest

	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Subscription name, which is unique in the same topic under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`
}

func NewClearSubscriptionFilterTagsRequest 

func NewClearSubscriptionFilterTagsRequest() (request *ClearSubscriptionFilterTagsRequest)

func (*ClearSubscriptionFilterTagsRequest) FromJsonString 

func (r *ClearSubscriptionFilterTagsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ClearSubscriptionFilterTagsRequest) ToJsonString 

func (r *ClearSubscriptionFilterTagsRequest) ToJsonString() string

type ClearSubscriptionFilterTagsRequestParams 

type ClearSubscriptionFilterTagsRequestParams struct {
	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Subscription name, which is unique in the same topic under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`
}

Predefined struct for user

type ClearSubscriptionFilterTagsResponse 

type ClearSubscriptionFilterTagsResponse struct {
	*tchttp.BaseResponse
	Response *ClearSubscriptionFilterTagsResponseParams `json:"Response"`
}

func NewClearSubscriptionFilterTagsResponse 

func NewClearSubscriptionFilterTagsResponse() (response *ClearSubscriptionFilterTagsResponse)

func (*ClearSubscriptionFilterTagsResponse) FromJsonString 

func (r *ClearSubscriptionFilterTagsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ClearSubscriptionFilterTagsResponse) ToJsonString 

func (r *ClearSubscriptionFilterTagsResponse) ToJsonString() string

type ClearSubscriptionFilterTagsResponseParams 

type ClearSubscriptionFilterTagsResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type Client 

type Client struct {
	common.Client
}

func NewClient 

func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)

func NewClientWithSecretId 

func NewClientWithSecretId(secretId, secretKey, region string) (client *Client, err error)

Deprecated

func (*Client) ClearQueue 

func (c *Client) ClearQueue(request *ClearQueueRequest) (response *ClearQueueResponse, err error)

ClearQueue This API is used to clear all messages in a queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ClearQueueWithContext 

func (c *Client) ClearQueueWithContext(ctx context.Context, request *ClearQueueRequest) (response *ClearQueueResponse, err error)

ClearQueue This API is used to clear all messages in a queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ClearSubscriptionFilterTags 

func (c *Client) ClearSubscriptionFilterTags(request *ClearSubscriptionFilterTagsRequest) (response *ClearSubscriptionFilterTagsResponse, err error)

ClearSubscriptionFilterTags This API is used to clear the message tags of a subscriber.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ClearSubscriptionFilterTagsWithContext 

func (c *Client) ClearSubscriptionFilterTagsWithContext(ctx context.Context, request *ClearSubscriptionFilterTagsRequest) (response *ClearSubscriptionFilterTagsResponse, err error)

ClearSubscriptionFilterTags This API is used to clear the message tags of a subscriber.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) CreateQueue 

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

CreateQueue This API is used to create a queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) CreateQueueWithContext 

func (c *Client) CreateQueueWithContext(ctx context.Context, request *CreateQueueRequest) (response *CreateQueueResponse, err error)

CreateQueue This API is used to create a queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) CreateSubscribe 

func (c *Client) CreateSubscribe(request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)

CreateSubscribe This API is used to create a subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) CreateSubscribeWithContext 

func (c *Client) CreateSubscribeWithContext(ctx context.Context, request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)

CreateSubscribe This API is used to create a subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) CreateTopic 

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

CreateTopic This API is used to create a topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) CreateTopicWithContext 

func (c *Client) CreateTopicWithContext(ctx context.Context, request *CreateTopicRequest) (response *CreateTopicResponse, err error)

CreateTopic This API is used to create a topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DeleteQueue 

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

DeleteQueue This API is used to delete a queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INVALIDPARAMETER = "InvalidParameter"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DeleteQueueWithContext 

func (c *Client) DeleteQueueWithContext(ctx context.Context, request *DeleteQueueRequest) (response *DeleteQueueResponse, err error)

DeleteQueue This API is used to delete a queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
INVALIDPARAMETER = "InvalidParameter"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DeleteSubscribe 

func (c *Client) DeleteSubscribe(request *DeleteSubscribeRequest) (response *DeleteSubscribeResponse, err error)

DeleteSubscribe This API is used to delete a subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DeleteSubscribeWithContext 

func (c *Client) DeleteSubscribeWithContext(ctx context.Context, request *DeleteSubscribeRequest) (response *DeleteSubscribeResponse, err error)

DeleteSubscribe This API is used to delete a subscription.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DeleteTopic 

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

DeleteTopic This API is used to delete a topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DeleteTopicWithContext 

func (c *Client) DeleteTopicWithContext(ctx context.Context, request *DeleteTopicRequest) (response *DeleteTopicResponse, err error)

DeleteTopic This API is used to delete a topic.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DescribeDeadLetterSourceQueues 

func (c *Client) DescribeDeadLetterSourceQueues(request *DescribeDeadLetterSourceQueuesRequest) (response *DescribeDeadLetterSourceQueuesResponse, err error)

DescribeDeadLetterSourceQueues This API is used to enumerate the source queues of a dead letter queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DescribeDeadLetterSourceQueuesWithContext 

func (c *Client) DescribeDeadLetterSourceQueuesWithContext(ctx context.Context, request *DescribeDeadLetterSourceQueuesRequest) (response *DescribeDeadLetterSourceQueuesResponse, err error)

DescribeDeadLetterSourceQueues This API is used to enumerate the source queues of a dead letter queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DescribeQueueDetail 

func (c *Client) DescribeQueueDetail(request *DescribeQueueDetailRequest) (response *DescribeQueueDetailResponse, err error)

DescribeQueueDetail This API is used to enumerate queues.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DescribeQueueDetailWithContext 

func (c *Client) DescribeQueueDetailWithContext(ctx context.Context, request *DescribeQueueDetailRequest) (response *DescribeQueueDetailResponse, err error)

DescribeQueueDetail This API is used to enumerate queues.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DescribeSubscriptionDetail 

func (c *Client) DescribeSubscriptionDetail(request *DescribeSubscriptionDetailRequest) (response *DescribeSubscriptionDetailResponse, err error)

DescribeSubscriptionDetail This API is used to query subscription details.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DescribeSubscriptionDetailWithContext 

func (c *Client) DescribeSubscriptionDetailWithContext(ctx context.Context, request *DescribeSubscriptionDetailRequest) (response *DescribeSubscriptionDetailResponse, err error)

DescribeSubscriptionDetail This API is used to query subscription details.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DescribeTopicDetail 

func (c *Client) DescribeTopicDetail(request *DescribeTopicDetailRequest) (response *DescribeTopicDetailResponse, err error)

DescribeTopicDetail This API is used to query topic details.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) DescribeTopicDetailWithContext 

func (c *Client) DescribeTopicDetailWithContext(ctx context.Context, request *DescribeTopicDetailRequest) (response *DescribeTopicDetailResponse, err error)

DescribeTopicDetail This API is used to query topic details.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ModifyQueueAttribute 

func (c *Client) ModifyQueueAttribute(request *ModifyQueueAttributeRequest) (response *ModifyQueueAttributeResponse, err error)

ModifyQueueAttribute This API is used to modify queue attributes.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ModifyQueueAttributeWithContext 

func (c *Client) ModifyQueueAttributeWithContext(ctx context.Context, request *ModifyQueueAttributeRequest) (response *ModifyQueueAttributeResponse, err error)

ModifyQueueAttribute This API is used to modify queue attributes.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ModifySubscriptionAttribute 

func (c *Client) ModifySubscriptionAttribute(request *ModifySubscriptionAttributeRequest) (response *ModifySubscriptionAttributeResponse, err error)

ModifySubscriptionAttribute This API is used to modify subscription attributes.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ModifySubscriptionAttributeWithContext 

func (c *Client) ModifySubscriptionAttributeWithContext(ctx context.Context, request *ModifySubscriptionAttributeRequest) (response *ModifySubscriptionAttributeResponse, err error)

ModifySubscriptionAttribute This API is used to modify subscription attributes.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ModifyTopicAttribute 

func (c *Client) ModifyTopicAttribute(request *ModifyTopicAttributeRequest) (response *ModifyTopicAttributeResponse, err error)

ModifyTopicAttribute This API is used to modify topic attributes.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) ModifyTopicAttributeWithContext 

func (c *Client) ModifyTopicAttributeWithContext(ctx context.Context, request *ModifyTopicAttributeRequest) (response *ModifyTopicAttributeResponse, err error)

ModifyTopicAttribute This API is used to modify topic attributes.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) RewindQueue 

func (c *Client) RewindQueue(request *RewindQueueRequest) (response *RewindQueueResponse, err error)

RewindQueue This API is used to rewind a queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) RewindQueueWithContext 

func (c *Client) RewindQueueWithContext(ctx context.Context, request *RewindQueueRequest) (response *RewindQueueResponse, err error)

RewindQueue This API is used to rewind a queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) UnbindDeadLetter 

func (c *Client) UnbindDeadLetter(request *UnbindDeadLetterRequest) (response *UnbindDeadLetterResponse, err error)

UnbindDeadLetter This API is used to unbind a dead letter queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

func (*Client) UnbindDeadLetterWithContext 

func (c *Client) UnbindDeadLetterWithContext(ctx context.Context, request *UnbindDeadLetterRequest) (response *UnbindDeadLetterResponse, err error)

UnbindDeadLetter This API is used to unbind a dead letter queue.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_TRYLATER = "FailedOperation.TryLater"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_NOTASKID = "InvalidParameterValue.NoTaskId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCESSOLDOUT = "ResourcesSoldOut"
UNAUTHORIZEDOPERATION = "UnauthorizedOperation"

type CreateQueueRequest 

type CreateQueueRequest struct {
	*tchttp.BaseRequest

	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`

	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitnil,omitempty" name:"MaxMsgHeapNum"`

	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitnil,omitempty" name:"PollingWaitSeconds"`

	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitnil,omitempty" name:"VisibilityTimeout"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60-1296000 seconds (i.e., 1 minute-15 days). Default value: 345600 (i.e., 4 days).
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable the message rewinding feature for a queue. Value range: 0-msgRetentionSeconds, where 0 means not to enable this feature, while `msgRetentionSeconds` indicates that the maximum rewindable period is the message retention period of the queue.
	RewindSeconds *uint64 `json:"RewindSeconds,omitnil,omitempty" name:"RewindSeconds"`

	// 1: transaction queue, 0: general queue
	Transaction *uint64 `json:"Transaction,omitnil,omitempty" name:"Transaction"`

	// First lookback interval
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitnil,omitempty" name:"FirstQueryInterval"`

	// Maximum number of lookbacks
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitnil,omitempty" name:"MaxQueryCount"`

	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitnil,omitempty" name:"DeadLetterQueueName"`

	// Dead letter policy. 0: message has been consumed multiple times but not deleted, 1: `Time-To-Live` has elapsed
	Policy *uint64 `json:"Policy,omitnil,omitempty" name:"Policy"`

	// Maximum receipt times. Value range: 1-1000
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitnil,omitempty" name:"MaxReceiveCount"`

	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period)
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitnil,omitempty" name:"MaxTimeToLive"`

	// Whether to enable message trace. true: yes, false: no. If this field is not set, the feature will not be enabled
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

func NewCreateQueueRequest 

func NewCreateQueueRequest() (request *CreateQueueRequest)

func (*CreateQueueRequest) FromJsonString 

func (r *CreateQueueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateQueueRequest) ToJsonString 

func (r *CreateQueueRequest) ToJsonString() string

type CreateQueueRequestParams 

type CreateQueueRequestParams struct {
	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`

	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitnil,omitempty" name:"MaxMsgHeapNum"`

	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitnil,omitempty" name:"PollingWaitSeconds"`

	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitnil,omitempty" name:"VisibilityTimeout"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60-1296000 seconds (i.e., 1 minute-15 days). Default value: 345600 (i.e., 4 days).
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable the message rewinding feature for a queue. Value range: 0-msgRetentionSeconds, where 0 means not to enable this feature, while `msgRetentionSeconds` indicates that the maximum rewindable period is the message retention period of the queue.
	RewindSeconds *uint64 `json:"RewindSeconds,omitnil,omitempty" name:"RewindSeconds"`

	// 1: transaction queue, 0: general queue
	Transaction *uint64 `json:"Transaction,omitnil,omitempty" name:"Transaction"`

	// First lookback interval
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitnil,omitempty" name:"FirstQueryInterval"`

	// Maximum number of lookbacks
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitnil,omitempty" name:"MaxQueryCount"`

	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitnil,omitempty" name:"DeadLetterQueueName"`

	// Dead letter policy. 0: message has been consumed multiple times but not deleted, 1: `Time-To-Live` has elapsed
	Policy *uint64 `json:"Policy,omitnil,omitempty" name:"Policy"`

	// Maximum receipt times. Value range: 1-1000
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitnil,omitempty" name:"MaxReceiveCount"`

	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period)
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitnil,omitempty" name:"MaxTimeToLive"`

	// Whether to enable message trace. true: yes, false: no. If this field is not set, the feature will not be enabled
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

Predefined struct for user

type CreateQueueResponse 

type CreateQueueResponse struct {
	*tchttp.BaseResponse
	Response *CreateQueueResponseParams `json:"Response"`
}

func NewCreateQueueResponse 

func NewCreateQueueResponse() (response *CreateQueueResponse)

func (*CreateQueueResponse) FromJsonString 

func (r *CreateQueueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateQueueResponse) ToJsonString 

func (r *CreateQueueResponse) ToJsonString() string

type CreateQueueResponseParams 

type CreateQueueResponseParams struct {
	// "queueId" of a successfully created queue
	QueueId *string `json:"QueueId,omitnil,omitempty" name:"QueueId"`

	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateSubscribeRequest 

type CreateSubscribeRequest struct {
	*tchttp.BaseRequest

	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Subscription name, which is unique in the same topic under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`

	// Subscription protocol. Currently, two protocols are supported: http and queue. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol *string `json:"Protocol,omitnil,omitempty" name:"Protocol"`

	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Please note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and basic network.
	Endpoint *string `json:"Endpoint,omitnil,omitempty" name:"Endpoint"`

	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	NotifyStrategy *string `json:"NotifyStrategy,omitnil,omitempty" name:"NotifyStrategy"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not set, no matter whether `MsgTag` is set, the subscription will receive all messages published to the topic; 2. If the `FilterTag` array has a value, only when at least one of the values in the array also exists in the `MsgTag` array (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the `FilterTag` array has a value, but `MsgTag` is not set, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTag []*string `json:"FilterTag,omitnil,omitempty" name:"FilterTag"`

	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` can contain up to 15 `.`, i.e., up to 16 phrases.
	BindingKey []*string `json:"BindingKey,omitnil,omitempty" name:"BindingKey"`

	// Push content format. Valid values: 1. JSON, 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat *string `json:"NotifyContentFormat,omitnil,omitempty" name:"NotifyContentFormat"`
}

func NewCreateSubscribeRequest 

func NewCreateSubscribeRequest() (request *CreateSubscribeRequest)

func (*CreateSubscribeRequest) FromJsonString 

func (r *CreateSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateSubscribeRequest) ToJsonString 

func (r *CreateSubscribeRequest) ToJsonString() string

type CreateSubscribeRequestParams 

type CreateSubscribeRequestParams struct {
	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Subscription name, which is unique in the same topic under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`

	// Subscription protocol. Currently, two protocols are supported: http and queue. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol *string `json:"Protocol,omitnil,omitempty" name:"Protocol"`

	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Please note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and basic network.
	Endpoint *string `json:"Endpoint,omitnil,omitempty" name:"Endpoint"`

	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	NotifyStrategy *string `json:"NotifyStrategy,omitnil,omitempty" name:"NotifyStrategy"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not set, no matter whether `MsgTag` is set, the subscription will receive all messages published to the topic; 2. If the `FilterTag` array has a value, only when at least one of the values in the array also exists in the `MsgTag` array (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the `FilterTag` array has a value, but `MsgTag` is not set, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTag []*string `json:"FilterTag,omitnil,omitempty" name:"FilterTag"`

	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` can contain up to 15 `.`, i.e., up to 16 phrases.
	BindingKey []*string `json:"BindingKey,omitnil,omitempty" name:"BindingKey"`

	// Push content format. Valid values: 1. JSON, 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat *string `json:"NotifyContentFormat,omitnil,omitempty" name:"NotifyContentFormat"`
}

Predefined struct for user

type CreateSubscribeResponse 

type CreateSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *CreateSubscribeResponseParams `json:"Response"`
}

func NewCreateSubscribeResponse 

func NewCreateSubscribeResponse() (response *CreateSubscribeResponse)

func (*CreateSubscribeResponse) FromJsonString 

func (r *CreateSubscribeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateSubscribeResponse) ToJsonString 

func (r *CreateSubscribeResponse) ToJsonString() string

type CreateSubscribeResponseParams 

type CreateSubscribeResponseParams struct {
	// SubscriptionId
	SubscriptionId *string `json:"SubscriptionId,omitnil,omitempty" name:"SubscriptionId"`

	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateTopicRequest 

type CreateTopicRequest struct {
	*tchttp.BaseRequest

	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Message match policy for a specified topic.
	FilterType *uint64 `json:"FilterType,omitnil,omitempty" name:"FilterType"`

	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable message trace. true: yes, false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

func NewCreateTopicRequest 

func NewCreateTopicRequest() (request *CreateTopicRequest)

func (*CreateTopicRequest) FromJsonString 

func (r *CreateTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTopicRequest) ToJsonString 

func (r *CreateTopicRequest) ToJsonString() string

type CreateTopicRequestParams 

type CreateTopicRequestParams struct {
	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Message match policy for a specified topic.
	FilterType *uint64 `json:"FilterType,omitnil,omitempty" name:"FilterType"`

	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable message trace. true: yes, false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

Predefined struct for user

type CreateTopicResponse 

type CreateTopicResponse struct {
	*tchttp.BaseResponse
	Response *CreateTopicResponseParams `json:"Response"`
}

func NewCreateTopicResponse 

func NewCreateTopicResponse() (response *CreateTopicResponse)

func (*CreateTopicResponse) FromJsonString 

func (r *CreateTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTopicResponse) ToJsonString 

func (r *CreateTopicResponse) ToJsonString() string

type CreateTopicResponseParams 

type CreateTopicResponseParams struct {
	// TopicName
	TopicId *string `json:"TopicId,omitnil,omitempty" name:"TopicId"`

	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeadLetterPolicy 

type DeadLetterPolicy struct {
	// DeadLetterQueueName
	// Note: this field may return null, indicating that no valid values can be obtained.
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitnil,omitempty" name:"DeadLetterQueueName"`

	// DeadLetterQueue
	// Note: this field may return null, indicating that no valid values can be obtained.
	DeadLetterQueue *string `json:"DeadLetterQueue,omitnil,omitempty" name:"DeadLetterQueue"`

	// Policy
	// Note: this field may return null, indicating that no valid values can be obtained.
	Policy *uint64 `json:"Policy,omitnil,omitempty" name:"Policy"`

	// MaxTimeToLive
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitnil,omitempty" name:"MaxTimeToLive"`

	// MaxReceiveCount
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitnil,omitempty" name:"MaxReceiveCount"`
}

type DeadLetterSource 

type DeadLetterSource struct {
	// QueueId
	// Note: this field may return null, indicating that no valid values can be obtained.
	QueueId *string `json:"QueueId,omitnil,omitempty" name:"QueueId"`

	// QueueName
	// Note: this field may return null, indicating that no valid values can be obtained.
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

type DeleteQueueRequest 

type DeleteQueueRequest struct {
	*tchttp.BaseRequest

	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

func NewDeleteQueueRequest 

func NewDeleteQueueRequest() (request *DeleteQueueRequest)

func (*DeleteQueueRequest) FromJsonString 

func (r *DeleteQueueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteQueueRequest) ToJsonString 

func (r *DeleteQueueRequest) ToJsonString() string

type DeleteQueueRequestParams 

type DeleteQueueRequestParams struct {
	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

Predefined struct for user

type DeleteQueueResponse 

type DeleteQueueResponse struct {
	*tchttp.BaseResponse
	Response *DeleteQueueResponseParams `json:"Response"`
}

func NewDeleteQueueResponse 

func NewDeleteQueueResponse() (response *DeleteQueueResponse)

func (*DeleteQueueResponse) FromJsonString 

func (r *DeleteQueueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteQueueResponse) ToJsonString 

func (r *DeleteQueueResponse) ToJsonString() string

type DeleteQueueResponseParams 

type DeleteQueueResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteSubscribeRequest 

type DeleteSubscribeRequest struct {
	*tchttp.BaseRequest

	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Subscription name, which is unique in the same topic under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`
}

func NewDeleteSubscribeRequest 

func NewDeleteSubscribeRequest() (request *DeleteSubscribeRequest)

func (*DeleteSubscribeRequest) FromJsonString 

func (r *DeleteSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteSubscribeRequest) ToJsonString 

func (r *DeleteSubscribeRequest) ToJsonString() string

type DeleteSubscribeRequestParams 

type DeleteSubscribeRequestParams struct {
	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Subscription name, which is unique in the same topic under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`
}

Predefined struct for user

type DeleteSubscribeResponse 

type DeleteSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *DeleteSubscribeResponseParams `json:"Response"`
}

func NewDeleteSubscribeResponse 

func NewDeleteSubscribeResponse() (response *DeleteSubscribeResponse)

func (*DeleteSubscribeResponse) FromJsonString 

func (r *DeleteSubscribeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteSubscribeResponse) ToJsonString 

func (r *DeleteSubscribeResponse) ToJsonString() string

type DeleteSubscribeResponseParams 

type DeleteSubscribeResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteTopicRequest 

type DeleteTopicRequest struct {
	*tchttp.BaseRequest

	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`
}

func NewDeleteTopicRequest 

func NewDeleteTopicRequest() (request *DeleteTopicRequest)

func (*DeleteTopicRequest) FromJsonString 

func (r *DeleteTopicRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTopicRequest) ToJsonString 

func (r *DeleteTopicRequest) ToJsonString() string

type DeleteTopicRequestParams 

type DeleteTopicRequestParams struct {
	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`
}

Predefined struct for user

type DeleteTopicResponse 

type DeleteTopicResponse struct {
	*tchttp.BaseResponse
	Response *DeleteTopicResponseParams `json:"Response"`
}

func NewDeleteTopicResponse 

func NewDeleteTopicResponse() (response *DeleteTopicResponse)

func (*DeleteTopicResponse) FromJsonString 

func (r *DeleteTopicResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTopicResponse) ToJsonString 

func (r *DeleteTopicResponse) ToJsonString() string

type DeleteTopicResponseParams 

type DeleteTopicResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeDeadLetterSourceQueuesRequest 

type DescribeDeadLetterSourceQueuesRequest struct {
	*tchttp.BaseRequest

	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitnil,omitempty" name:"DeadLetterQueueName"`

	// Starting position of topic list to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default.
	Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// Filters source queue name of dead letter queue. Currently, only filtering by `SourceQueueName` is supported
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`
}

func NewDescribeDeadLetterSourceQueuesRequest 

func NewDescribeDeadLetterSourceQueuesRequest() (request *DescribeDeadLetterSourceQueuesRequest)

func (*DescribeDeadLetterSourceQueuesRequest) FromJsonString 

func (r *DescribeDeadLetterSourceQueuesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeDeadLetterSourceQueuesRequest) ToJsonString 

func (r *DescribeDeadLetterSourceQueuesRequest) ToJsonString() string

type DescribeDeadLetterSourceQueuesRequestParams 

type DescribeDeadLetterSourceQueuesRequestParams struct {
	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitnil,omitempty" name:"DeadLetterQueueName"`

	// Starting position of topic list to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default.
	Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// Filters source queue name of dead letter queue. Currently, only filtering by `SourceQueueName` is supported
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`
}

Predefined struct for user

type DescribeDeadLetterSourceQueuesResponse 

type DescribeDeadLetterSourceQueuesResponse struct {
	*tchttp.BaseResponse
	Response *DescribeDeadLetterSourceQueuesResponseParams `json:"Response"`
}

func NewDescribeDeadLetterSourceQueuesResponse 

func NewDescribeDeadLetterSourceQueuesResponse() (response *DescribeDeadLetterSourceQueuesResponse)

func (*DescribeDeadLetterSourceQueuesResponse) FromJsonString 

func (r *DescribeDeadLetterSourceQueuesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeDeadLetterSourceQueuesResponse) ToJsonString 

func (r *DescribeDeadLetterSourceQueuesResponse) ToJsonString() string

type DescribeDeadLetterSourceQueuesResponseParams 

type DescribeDeadLetterSourceQueuesResponseParams struct {
	// Number of eligible queues
	TotalCount *uint64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"`

	// Source queues of dead letter queue
	QueueSet []*DeadLetterSource `json:"QueueSet,omitnil,omitempty" name:"QueueSet"`

	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeQueueDetailRequest 

type DescribeQueueDetailRequest struct {
	*tchttp.BaseRequest

	// Starting position of queue list to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default
	Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// Number of queues to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// Filter parameter. Currently, filtering by `QueueName` is supported, and only one keyword is allowed
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`

	// Tag search
	TagKey *string `json:"TagKey,omitnil,omitempty" name:"TagKey"`

	// Exact match by `QueueName`
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

func NewDescribeQueueDetailRequest 

func NewDescribeQueueDetailRequest() (request *DescribeQueueDetailRequest)

func (*DescribeQueueDetailRequest) FromJsonString 

func (r *DescribeQueueDetailRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeQueueDetailRequest) ToJsonString 

func (r *DescribeQueueDetailRequest) ToJsonString() string

type DescribeQueueDetailRequestParams 

type DescribeQueueDetailRequestParams struct {
	// Starting position of queue list to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default
	Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// Number of queues to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// Filter parameter. Currently, filtering by `QueueName` is supported, and only one keyword is allowed
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`

	// Tag search
	TagKey *string `json:"TagKey,omitnil,omitempty" name:"TagKey"`

	// Exact match by `QueueName`
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

Predefined struct for user

type DescribeQueueDetailResponse 

type DescribeQueueDetailResponse struct {
	*tchttp.BaseResponse
	Response *DescribeQueueDetailResponseParams `json:"Response"`
}

func NewDescribeQueueDetailResponse 

func NewDescribeQueueDetailResponse() (response *DescribeQueueDetailResponse)

func (*DescribeQueueDetailResponse) FromJsonString 

func (r *DescribeQueueDetailResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeQueueDetailResponse) ToJsonString 

func (r *DescribeQueueDetailResponse) ToJsonString() string

type DescribeQueueDetailResponseParams 

type DescribeQueueDetailResponseParams struct {
	// Total number of queues
	TotalCount *uint64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"`

	// Queue list
	QueueSet []*QueueSet `json:"QueueSet,omitnil,omitempty" name:"QueueSet"`

	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeSubscriptionDetailRequest 

type DescribeSubscriptionDetailRequest struct {
	*tchttp.BaseRequest

	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Starting position of topic list to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default
	Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// Filter parameter. Currently, only filtering by `SubscriptionName` is supported, and only one keyword is allowed.
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`
}

func NewDescribeSubscriptionDetailRequest 

func NewDescribeSubscriptionDetailRequest() (request *DescribeSubscriptionDetailRequest)

func (*DescribeSubscriptionDetailRequest) FromJsonString 

func (r *DescribeSubscriptionDetailRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeSubscriptionDetailRequest) ToJsonString 

func (r *DescribeSubscriptionDetailRequest) ToJsonString() string

type DescribeSubscriptionDetailRequestParams 

type DescribeSubscriptionDetailRequestParams struct {
	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Starting position of topic list to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default
	Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// Filter parameter. Currently, only filtering by `SubscriptionName` is supported, and only one keyword is allowed.
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`
}

Predefined struct for user

type DescribeSubscriptionDetailResponse 

type DescribeSubscriptionDetailResponse struct {
	*tchttp.BaseResponse
	Response *DescribeSubscriptionDetailResponseParams `json:"Response"`
}

func NewDescribeSubscriptionDetailResponse 

func NewDescribeSubscriptionDetailResponse() (response *DescribeSubscriptionDetailResponse)

func (*DescribeSubscriptionDetailResponse) FromJsonString 

func (r *DescribeSubscriptionDetailResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeSubscriptionDetailResponse) ToJsonString 

func (r *DescribeSubscriptionDetailResponse) ToJsonString() string

type DescribeSubscriptionDetailResponseParams 

type DescribeSubscriptionDetailResponseParams struct {
	// Total number
	TotalCount *uint64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"`

	// Subscription attribute set
	// Note: this field may return null, indicating that no valid values can be obtained.
	SubscriptionSet []*Subscription `json:"SubscriptionSet,omitnil,omitempty" name:"SubscriptionSet"`

	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeTopicDetailRequest 

type DescribeTopicDetailRequest struct {
	*tchttp.BaseRequest

	// Starting position of queue list to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default.
	Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// Number of queues to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// Currently, only filtering by `TopicName` is supported, and only one filter value can be entered
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`

	// Tag match
	TagKey *string `json:"TagKey,omitnil,omitempty" name:"TagKey"`

	// Exact match by `TopicName`
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`
}

func NewDescribeTopicDetailRequest 

func NewDescribeTopicDetailRequest() (request *DescribeTopicDetailRequest)

func (*DescribeTopicDetailRequest) FromJsonString 

func (r *DescribeTopicDetailRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeTopicDetailRequest) ToJsonString 

func (r *DescribeTopicDetailRequest) ToJsonString() string

type DescribeTopicDetailRequestParams 

type DescribeTopicDetailRequestParams struct {
	// Starting position of queue list to be returned on the current page in case of paginated return. If a value is entered, `limit` is required. If this parameter is left empty, 0 will be used by default.
	Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// Number of queues to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// Currently, only filtering by `TopicName` is supported, and only one filter value can be entered
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`

	// Tag match
	TagKey *string `json:"TagKey,omitnil,omitempty" name:"TagKey"`

	// Exact match by `TopicName`
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`
}

Predefined struct for user

type DescribeTopicDetailResponse 

type DescribeTopicDetailResponse struct {
	*tchttp.BaseResponse
	Response *DescribeTopicDetailResponseParams `json:"Response"`
}

func NewDescribeTopicDetailResponse 

func NewDescribeTopicDetailResponse() (response *DescribeTopicDetailResponse)

func (*DescribeTopicDetailResponse) FromJsonString 

func (r *DescribeTopicDetailResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeTopicDetailResponse) ToJsonString 

func (r *DescribeTopicDetailResponse) ToJsonString() string

type DescribeTopicDetailResponseParams 

type DescribeTopicDetailResponseParams struct {
	// TotalCount
	TotalCount *uint64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"`

	// TopicSet
	TopicSet []*TopicSet `json:"TopicSet,omitnil,omitempty" name:"TopicSet"`

	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type Filter 

type Filter struct {
	// Filter parameter name
	Name *string `json:"Name,omitnil,omitempty" name:"Name"`

	// Value
	Values []*string `json:"Values,omitnil,omitempty" name:"Values"`
}

type ModifyQueueAttributeRequest 

type ModifyQueueAttributeRequest struct {
	*tchttp.BaseRequest

	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`

	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitnil,omitempty" name:"MaxMsgHeapNum"`

	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitnil,omitempty" name:"PollingWaitSeconds"`

	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitnil,omitempty" name:"VisibilityTimeout"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60-1296000 seconds (i.e., 1 minute-15 days). Default value: 345600 (i.e., 4 days).
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// Maximum message rewindable period. Value range: 0-msgRetentionSeconds (maximum message retention period of a queue). 0 means not to enable message rewinding.
	RewindSeconds *uint64 `json:"RewindSeconds,omitnil,omitempty" name:"RewindSeconds"`

	// First query time
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitnil,omitempty" name:"FirstQueryInterval"`

	// Maximum number of queries
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitnil,omitempty" name:"MaxQueryCount"`

	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitnil,omitempty" name:"DeadLetterQueueName"`

	// Maximum period in seconds before an unconsumed message expires, which is required if `MaxTimeToLivepolicy` is 1. Value range: 300-43200. This value should be smaller than `MsgRetentionSeconds` (maximum message retention period)
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitnil,omitempty" name:"MaxTimeToLive"`

	// Maximum number of receipts
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitnil,omitempty" name:"MaxReceiveCount"`

	// Dead letter queue policy
	Policy *uint64 `json:"Policy,omitnil,omitempty" name:"Policy"`

	// Whether to enable message trace. true: yes, false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

func NewModifyQueueAttributeRequest 

func NewModifyQueueAttributeRequest() (request *ModifyQueueAttributeRequest)

func (*ModifyQueueAttributeRequest) FromJsonString 

func (r *ModifyQueueAttributeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyQueueAttributeRequest) ToJsonString 

func (r *ModifyQueueAttributeRequest) ToJsonString() string

type ModifyQueueAttributeRequestParams 

type ModifyQueueAttributeRequestParams struct {
	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`

	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitnil,omitempty" name:"MaxMsgHeapNum"`

	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitnil,omitempty" name:"PollingWaitSeconds"`

	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitnil,omitempty" name:"VisibilityTimeout"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60-1296000 seconds (i.e., 1 minute-15 days). Default value: 345600 (i.e., 4 days).
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// Maximum message rewindable period. Value range: 0-msgRetentionSeconds (maximum message retention period of a queue). 0 means not to enable message rewinding.
	RewindSeconds *uint64 `json:"RewindSeconds,omitnil,omitempty" name:"RewindSeconds"`

	// First query time
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitnil,omitempty" name:"FirstQueryInterval"`

	// Maximum number of queries
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitnil,omitempty" name:"MaxQueryCount"`

	// Dead letter queue name
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitnil,omitempty" name:"DeadLetterQueueName"`

	// Maximum period in seconds before an unconsumed message expires, which is required if `MaxTimeToLivepolicy` is 1. Value range: 300-43200. This value should be smaller than `MsgRetentionSeconds` (maximum message retention period)
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitnil,omitempty" name:"MaxTimeToLive"`

	// Maximum number of receipts
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitnil,omitempty" name:"MaxReceiveCount"`

	// Dead letter queue policy
	Policy *uint64 `json:"Policy,omitnil,omitempty" name:"Policy"`

	// Whether to enable message trace. true: yes, false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

Predefined struct for user

type ModifyQueueAttributeResponse 

type ModifyQueueAttributeResponse struct {
	*tchttp.BaseResponse
	Response *ModifyQueueAttributeResponseParams `json:"Response"`
}

func NewModifyQueueAttributeResponse 

func NewModifyQueueAttributeResponse() (response *ModifyQueueAttributeResponse)

func (*ModifyQueueAttributeResponse) FromJsonString 

func (r *ModifyQueueAttributeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyQueueAttributeResponse) ToJsonString 

func (r *ModifyQueueAttributeResponse) ToJsonString() string

type ModifyQueueAttributeResponseParams 

type ModifyQueueAttributeResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ModifySubscriptionAttributeRequest 

type ModifySubscriptionAttributeRequest struct {
	*tchttp.BaseRequest

	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Subscription name, which is unique in the same topic under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`

	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values:
	// 1. BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message.
	// 2. EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	NotifyStrategy *string `json:"NotifyStrategy,omitnil,omitempty" name:"NotifyStrategy"`

	// Push content format. Valid values: 1. JSON, 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `HTTP`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat *string `json:"NotifyContentFormat,omitnil,omitempty" name:"NotifyContentFormat"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not set, no matter whether `MsgTag` is set, the subscription will receive all messages published to the topic; 2. If the `FilterTag` array has a value, only when at least one of the values in the array also exists in the `MsgTag` array (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the `FilterTag` array has a value, but `MsgTag` is not set, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTags []*string `json:"FilterTags,omitnil,omitempty" name:"FilterTags"`

	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` can contain up to 15 `.`, i.e., up to 16 phrases.
	BindingKey []*string `json:"BindingKey,omitnil,omitempty" name:"BindingKey"`
}

func NewModifySubscriptionAttributeRequest 

func NewModifySubscriptionAttributeRequest() (request *ModifySubscriptionAttributeRequest)

func (*ModifySubscriptionAttributeRequest) FromJsonString 

func (r *ModifySubscriptionAttributeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifySubscriptionAttributeRequest) ToJsonString 

func (r *ModifySubscriptionAttributeRequest) ToJsonString() string

type ModifySubscriptionAttributeRequestParams 

type ModifySubscriptionAttributeRequestParams struct {
	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Subscription name, which is unique in the same topic under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`

	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values:
	// 1. BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message.
	// 2. EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	NotifyStrategy *string `json:"NotifyStrategy,omitnil,omitempty" name:"NotifyStrategy"`

	// Push content format. Valid values: 1. JSON, 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `HTTP`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat *string `json:"NotifyContentFormat,omitnil,omitempty" name:"NotifyContentFormat"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not set, no matter whether `MsgTag` is set, the subscription will receive all messages published to the topic; 2. If the `FilterTag` array has a value, only when at least one of the values in the array also exists in the `MsgTag` array (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the `FilterTag` array has a value, but `MsgTag` is not set, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTags []*string `json:"FilterTags,omitnil,omitempty" name:"FilterTags"`

	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` can contain up to 15 `.`, i.e., up to 16 phrases.
	BindingKey []*string `json:"BindingKey,omitnil,omitempty" name:"BindingKey"`
}

Predefined struct for user

type ModifySubscriptionAttributeResponse 

type ModifySubscriptionAttributeResponse struct {
	*tchttp.BaseResponse
	Response *ModifySubscriptionAttributeResponseParams `json:"Response"`
}

func NewModifySubscriptionAttributeResponse 

func NewModifySubscriptionAttributeResponse() (response *ModifySubscriptionAttributeResponse)

func (*ModifySubscriptionAttributeResponse) FromJsonString 

func (r *ModifySubscriptionAttributeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifySubscriptionAttributeResponse) ToJsonString 

func (r *ModifySubscriptionAttributeResponse) ToJsonString() string

type ModifySubscriptionAttributeResponseParams 

type ModifySubscriptionAttributeResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ModifyTopicAttributeRequest 

type ModifyTopicAttributeRequest struct {
	*tchttp.BaseRequest

	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable message trace. true: yes, false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

func NewModifyTopicAttributeRequest 

func NewModifyTopicAttributeRequest() (request *ModifyTopicAttributeRequest)

func (*ModifyTopicAttributeRequest) FromJsonString 

func (r *ModifyTopicAttributeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyTopicAttributeRequest) ToJsonString 

func (r *ModifyTopicAttributeRequest) ToJsonString() string

type ModifyTopicAttributeRequestParams 

type ModifyTopicAttributeRequestParams struct {
	// Topic name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// Whether to enable message trace. true: yes, false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

Predefined struct for user

type ModifyTopicAttributeResponse 

type ModifyTopicAttributeResponse struct {
	*tchttp.BaseResponse
	Response *ModifyTopicAttributeResponseParams `json:"Response"`
}

func NewModifyTopicAttributeResponse 

func NewModifyTopicAttributeResponse() (response *ModifyTopicAttributeResponse)

func (*ModifyTopicAttributeResponse) FromJsonString 

func (r *ModifyTopicAttributeResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyTopicAttributeResponse) ToJsonString 

func (r *ModifyTopicAttributeResponse) ToJsonString() string

type ModifyTopicAttributeResponseParams 

type ModifyTopicAttributeResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type QueueSet 

type QueueSet struct {
	// QueueId
	QueueId *string `json:"QueueId,omitnil,omitempty" name:"QueueId"`

	// QueueName
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`

	// Qps
	// Note: this field may return null, indicating that no valid values can be obtained.
	Qps *uint64 `json:"Qps,omitnil,omitempty" name:"Qps"`

	// Bps
	// Note: this field may return null, indicating that no valid values can be obtained.
	Bps *uint64 `json:"Bps,omitnil,omitempty" name:"Bps"`

	// MaxDelaySeconds
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxDelaySeconds *uint64 `json:"MaxDelaySeconds,omitnil,omitempty" name:"MaxDelaySeconds"`

	// MaxMsgHeapNum
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitnil,omitempty" name:"MaxMsgHeapNum"`

	// PollingWaitSeconds
	// Note: this field may return null, indicating that no valid values can be obtained.
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitnil,omitempty" name:"PollingWaitSeconds"`

	// MsgRetentionSeconds
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// VisibilityTimeout
	// Note: this field may return null, indicating that no valid values can be obtained.
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitnil,omitempty" name:"VisibilityTimeout"`

	// MaxMsgSize
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// RewindSeconds
	// Note: this field may return null, indicating that no valid values can be obtained.
	RewindSeconds *uint64 `json:"RewindSeconds,omitnil,omitempty" name:"RewindSeconds"`

	// CreateTime
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateTime *uint64 `json:"CreateTime,omitnil,omitempty" name:"CreateTime"`

	// LastModifyTime
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastModifyTime *uint64 `json:"LastModifyTime,omitnil,omitempty" name:"LastModifyTime"`

	// ActiveMsgNum
	// Note: this field may return null, indicating that no valid values can be obtained.
	ActiveMsgNum *uint64 `json:"ActiveMsgNum,omitnil,omitempty" name:"ActiveMsgNum"`

	// InactiveMsgNum
	// Note: this field may return null, indicating that no valid values can be obtained.
	InactiveMsgNum *uint64 `json:"InactiveMsgNum,omitnil,omitempty" name:"InactiveMsgNum"`

	// DelayMsgNum
	// Note: this field may return null, indicating that no valid values can be obtained.
	DelayMsgNum *uint64 `json:"DelayMsgNum,omitnil,omitempty" name:"DelayMsgNum"`

	// RewindMsgNum
	// Note: this field may return null, indicating that no valid values can be obtained.
	RewindMsgNum *uint64 `json:"RewindMsgNum,omitnil,omitempty" name:"RewindMsgNum"`

	// MinMsgTime
	// Note: this field may return null, indicating that no valid values can be obtained.
	MinMsgTime *uint64 `json:"MinMsgTime,omitnil,omitempty" name:"MinMsgTime"`

	// Transaction
	// Note: this field may return null, indicating that no valid values can be obtained.
	Transaction *bool `json:"Transaction,omitnil,omitempty" name:"Transaction"`

	// DeadLetterSource
	// Note: this field may return null, indicating that no valid values can be obtained.
	DeadLetterSource []*DeadLetterSource `json:"DeadLetterSource,omitnil,omitempty" name:"DeadLetterSource"`

	// DeadLetterPolicy
	// Note: this field may return null, indicating that no valid values can be obtained.
	DeadLetterPolicy *DeadLetterPolicy `json:"DeadLetterPolicy,omitnil,omitempty" name:"DeadLetterPolicy"`

	// TransactionPolicy
	// Note: this field may return null, indicating that no valid values can be obtained.
	TransactionPolicy *TransactionPolicy `json:"TransactionPolicy,omitnil,omitempty" name:"TransactionPolicy"`

	// Creator `uin`
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateUin *uint64 `json:"CreateUin,omitnil,omitempty" name:"CreateUin"`

	// Tag
	// Note: this field may return null, indicating that no valid values can be obtained.
	Tags []*Tag `json:"Tags,omitnil,omitempty" name:"Tags"`

	// Message trace flag. true: enabled, false: not enabled
	// Note: this field may return null, indicating that no valid values can be obtained.
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

type RewindQueueRequest 

type RewindQueueRequest struct {
	*tchttp.BaseRequest

	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`

	// After this time is set, the `(Batch)receiveMessage` API will consume the messages received after this timestamp in the order in which they are produced.
	StartConsumeTime *uint64 `json:"StartConsumeTime,omitnil,omitempty" name:"StartConsumeTime"`
}

func NewRewindQueueRequest 

func NewRewindQueueRequest() (request *RewindQueueRequest)

func (*RewindQueueRequest) FromJsonString 

func (r *RewindQueueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*RewindQueueRequest) ToJsonString 

func (r *RewindQueueRequest) ToJsonString() string

type RewindQueueRequestParams 

type RewindQueueRequestParams struct {
	// Queue name, which is unique under the same account in an individual region. It is a string of up to 64 characters, which must begin with a letter and can contain letters, digits, and dashes (`-`).
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`

	// After this time is set, the `(Batch)receiveMessage` API will consume the messages received after this timestamp in the order in which they are produced.
	StartConsumeTime *uint64 `json:"StartConsumeTime,omitnil,omitempty" name:"StartConsumeTime"`
}

Predefined struct for user

type RewindQueueResponse 

type RewindQueueResponse struct {
	*tchttp.BaseResponse
	Response *RewindQueueResponseParams `json:"Response"`
}

func NewRewindQueueResponse 

func NewRewindQueueResponse() (response *RewindQueueResponse)

func (*RewindQueueResponse) FromJsonString 

func (r *RewindQueueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*RewindQueueResponse) ToJsonString 

func (r *RewindQueueResponse) ToJsonString() string

type RewindQueueResponseParams 

type RewindQueueResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type Subscription 

type Subscription struct {
	// SubscriptionName
	// Note: this field may return null, indicating that no valid values can be obtained.
	SubscriptionName *string `json:"SubscriptionName,omitnil,omitempty" name:"SubscriptionName"`

	// SubscriptionId
	// Note: this field may return null, indicating that no valid values can be obtained.
	SubscriptionId *string `json:"SubscriptionId,omitnil,omitempty" name:"SubscriptionId"`

	// TopicOwner
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicOwner *uint64 `json:"TopicOwner,omitnil,omitempty" name:"TopicOwner"`

	// MsgCount
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgCount *uint64 `json:"MsgCount,omitnil,omitempty" name:"MsgCount"`

	// LastModifyTime
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastModifyTime *uint64 `json:"LastModifyTime,omitnil,omitempty" name:"LastModifyTime"`

	// CreateTime
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateTime *uint64 `json:"CreateTime,omitnil,omitempty" name:"CreateTime"`

	// BindingKey
	// Note: this field may return null, indicating that no valid values can be obtained.
	BindingKey []*string `json:"BindingKey,omitnil,omitempty" name:"BindingKey"`

	// Endpoint
	// Note: this field may return null, indicating that no valid values can be obtained.
	Endpoint *string `json:"Endpoint,omitnil,omitempty" name:"Endpoint"`

	// FilterTags
	// Note: this field may return null, indicating that no valid values can be obtained.
	FilterTags []*string `json:"FilterTags,omitnil,omitempty" name:"FilterTags"`

	// Protocol
	// Note: this field may return null, indicating that no valid values can be obtained.
	Protocol *string `json:"Protocol,omitnil,omitempty" name:"Protocol"`

	// NotifyStrategy
	// Note: this field may return null, indicating that no valid values can be obtained.
	NotifyStrategy *string `json:"NotifyStrategy,omitnil,omitempty" name:"NotifyStrategy"`

	// NotifyContentFormat
	// Note: this field may return null, indicating that no valid values can be obtained.
	NotifyContentFormat *string `json:"NotifyContentFormat,omitnil,omitempty" name:"NotifyContentFormat"`
}

type Tag 

type Tag struct {
	// Tag key
	// Note: this field may return null, indicating that no valid values can be obtained.
	TagKey *string `json:"TagKey,omitnil,omitempty" name:"TagKey"`

	// Tag value
	// Note: this field may return null, indicating that no valid values can be obtained.
	TagValue *string `json:"TagValue,omitnil,omitempty" name:"TagValue"`
}

type TopicSet 

type TopicSet struct {
	// TopicId
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicId *string `json:"TopicId,omitnil,omitempty" name:"TopicId"`

	// TopicName
	// Note: this field may return null, indicating that no valid values can be obtained.
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// MsgRetentionSeconds
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitnil,omitempty" name:"MsgRetentionSeconds"`

	// MaxMsgSize
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitnil,omitempty" name:"MaxMsgSize"`

	// Qps
	// Note: this field may return null, indicating that no valid values can be obtained.
	Qps *uint64 `json:"Qps,omitnil,omitempty" name:"Qps"`

	// FilterType
	// Note: this field may return null, indicating that no valid values can be obtained.
	FilterType *uint64 `json:"FilterType,omitnil,omitempty" name:"FilterType"`

	// CreateTime
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateTime *uint64 `json:"CreateTime,omitnil,omitempty" name:"CreateTime"`

	// LastModifyTime
	// Note: this field may return null, indicating that no valid values can be obtained.
	LastModifyTime *uint64 `json:"LastModifyTime,omitnil,omitempty" name:"LastModifyTime"`

	// MsgCount
	// Note: this field may return null, indicating that no valid values can be obtained.
	MsgCount *uint64 `json:"MsgCount,omitnil,omitempty" name:"MsgCount"`

	// CreateUin
	// Note: this field may return null, indicating that no valid values can be obtained.
	CreateUin *uint64 `json:"CreateUin,omitnil,omitempty" name:"CreateUin"`

	// Tags
	// Note: this field may return null, indicating that no valid values can be obtained.
	Tags []*Tag `json:"Tags,omitnil,omitempty" name:"Tags"`

	// Whether to enable message trace for a topic. true: yes, false: no
	// Note: this field may return null, indicating that no valid values can be obtained.
	Trace *bool `json:"Trace,omitnil,omitempty" name:"Trace"`
}

type TransactionPolicy 

type TransactionPolicy struct {
	// FirstQueryInterval
	// Note: this field may return null, indicating that no valid values can be obtained.
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitnil,omitempty" name:"FirstQueryInterval"`

	// MaxQueryCount
	// Note: this field may return null, indicating that no valid values can be obtained.
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitnil,omitempty" name:"MaxQueryCount"`
}

type UnbindDeadLetterRequest 

type UnbindDeadLetterRequest struct {
	*tchttp.BaseRequest

	// Source queue name of dead letter policy. Calling this API will clear the dead letter queue policy of this queue.
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

func NewUnbindDeadLetterRequest 

func NewUnbindDeadLetterRequest() (request *UnbindDeadLetterRequest)

func (*UnbindDeadLetterRequest) FromJsonString 

func (r *UnbindDeadLetterRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UnbindDeadLetterRequest) ToJsonString 

func (r *UnbindDeadLetterRequest) ToJsonString() string

type UnbindDeadLetterRequestParams 

type UnbindDeadLetterRequestParams struct {
	// Source queue name of dead letter policy. Calling this API will clear the dead letter queue policy of this queue.
	QueueName *string `json:"QueueName,omitnil,omitempty" name:"QueueName"`
}

Predefined struct for user

type UnbindDeadLetterResponse 

type UnbindDeadLetterResponse struct {
	*tchttp.BaseResponse
	Response *UnbindDeadLetterResponseParams `json:"Response"`
}

func NewUnbindDeadLetterResponse 

func NewUnbindDeadLetterResponse() (response *UnbindDeadLetterResponse)

func (*UnbindDeadLetterResponse) FromJsonString 

func (r *UnbindDeadLetterResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UnbindDeadLetterResponse) ToJsonString 

func (r *UnbindDeadLetterResponse) ToJsonString() string

type UnbindDeadLetterResponseParams 

type UnbindDeadLetterResponseParams struct {
	// The unique request ID, generated by the server, will be returned for every request (if the request fails to reach the server for other reasons, the request will not obtain a RequestId). RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

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.