Documentation
¶
Index ¶
- Constants
- type ClearQueueRequest
- type ClearQueueRequestParams
- type ClearQueueResponse
- type ClearQueueResponseParams
- type ClearSubscriptionFilterTagsRequest
- type ClearSubscriptionFilterTagsRequestParams
- type ClearSubscriptionFilterTagsResponse
- type ClearSubscriptionFilterTagsResponseParams
- type Client
- func (c *Client) ClearQueue(request *ClearQueueRequest) (response *ClearQueueResponse, err error)
- func (c *Client) ClearQueueWithContext(ctx context.Context, request *ClearQueueRequest) (response *ClearQueueResponse, err error)
- func (c *Client) ClearSubscriptionFilterTags(request *ClearSubscriptionFilterTagsRequest) (response *ClearSubscriptionFilterTagsResponse, err error)
- func (c *Client) ClearSubscriptionFilterTagsWithContext(ctx context.Context, request *ClearSubscriptionFilterTagsRequest) (response *ClearSubscriptionFilterTagsResponse, err error)
- func (c *Client) CreateQueue(request *CreateQueueRequest) (response *CreateQueueResponse, err error)
- func (c *Client) CreateQueueWithContext(ctx context.Context, request *CreateQueueRequest) (response *CreateQueueResponse, err error)
- func (c *Client) CreateSubscribe(request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)
- func (c *Client) CreateSubscribeWithContext(ctx context.Context, request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)
- func (c *Client) CreateTopic(request *CreateTopicRequest) (response *CreateTopicResponse, err error)
- func (c *Client) CreateTopicWithContext(ctx context.Context, request *CreateTopicRequest) (response *CreateTopicResponse, err error)
- func (c *Client) DeleteQueue(request *DeleteQueueRequest) (response *DeleteQueueResponse, err error)
- func (c *Client) DeleteQueueWithContext(ctx context.Context, request *DeleteQueueRequest) (response *DeleteQueueResponse, err error)
- func (c *Client) DeleteSubscribe(request *DeleteSubscribeRequest) (response *DeleteSubscribeResponse, err error)
- func (c *Client) DeleteSubscribeWithContext(ctx context.Context, request *DeleteSubscribeRequest) (response *DeleteSubscribeResponse, err error)
- func (c *Client) DeleteTopic(request *DeleteTopicRequest) (response *DeleteTopicResponse, err error)
- func (c *Client) DeleteTopicWithContext(ctx context.Context, request *DeleteTopicRequest) (response *DeleteTopicResponse, err error)
- func (c *Client) DescribeDeadLetterSourceQueues(request *DescribeDeadLetterSourceQueuesRequest) (response *DescribeDeadLetterSourceQueuesResponse, err error)
- func (c *Client) DescribeDeadLetterSourceQueuesWithContext(ctx context.Context, request *DescribeDeadLetterSourceQueuesRequest) (response *DescribeDeadLetterSourceQueuesResponse, err error)
- func (c *Client) DescribeQueueDetail(request *DescribeQueueDetailRequest) (response *DescribeQueueDetailResponse, err error)
- func (c *Client) DescribeQueueDetailWithContext(ctx context.Context, request *DescribeQueueDetailRequest) (response *DescribeQueueDetailResponse, err error)
- func (c *Client) DescribeSubscriptionDetail(request *DescribeSubscriptionDetailRequest) (response *DescribeSubscriptionDetailResponse, err error)
- func (c *Client) DescribeSubscriptionDetailWithContext(ctx context.Context, request *DescribeSubscriptionDetailRequest) (response *DescribeSubscriptionDetailResponse, err error)
- func (c *Client) DescribeTopicDetail(request *DescribeTopicDetailRequest) (response *DescribeTopicDetailResponse, err error)
- func (c *Client) DescribeTopicDetailWithContext(ctx context.Context, request *DescribeTopicDetailRequest) (response *DescribeTopicDetailResponse, err error)
- func (c *Client) ModifyQueueAttribute(request *ModifyQueueAttributeRequest) (response *ModifyQueueAttributeResponse, err error)
- func (c *Client) ModifyQueueAttributeWithContext(ctx context.Context, request *ModifyQueueAttributeRequest) (response *ModifyQueueAttributeResponse, err error)
- func (c *Client) ModifySubscriptionAttribute(request *ModifySubscriptionAttributeRequest) (response *ModifySubscriptionAttributeResponse, err error)
- func (c *Client) ModifySubscriptionAttributeWithContext(ctx context.Context, request *ModifySubscriptionAttributeRequest) (response *ModifySubscriptionAttributeResponse, err error)
- func (c *Client) ModifyTopicAttribute(request *ModifyTopicAttributeRequest) (response *ModifyTopicAttributeResponse, err error)
- func (c *Client) ModifyTopicAttributeWithContext(ctx context.Context, request *ModifyTopicAttributeRequest) (response *ModifyTopicAttributeResponse, err error)
- func (c *Client) RewindQueue(request *RewindQueueRequest) (response *RewindQueueResponse, err error)
- func (c *Client) RewindQueueWithContext(ctx context.Context, request *RewindQueueRequest) (response *RewindQueueResponse, err error)
- func (c *Client) UnbindDeadLetter(request *UnbindDeadLetterRequest) (response *UnbindDeadLetterResponse, err error)
- func (c *Client) UnbindDeadLetterWithContext(ctx context.Context, request *UnbindDeadLetterRequest) (response *UnbindDeadLetterResponse, err error)
- type CreateQueueRequest
- type CreateQueueRequestParams
- type CreateQueueResponse
- type CreateQueueResponseParams
- type CreateSubscribeRequest
- type CreateSubscribeRequestParams
- type CreateSubscribeResponse
- type CreateSubscribeResponseParams
- type CreateTopicRequest
- type CreateTopicRequestParams
- type CreateTopicResponse
- type CreateTopicResponseParams
- type DeadLetterPolicy
- type DeadLetterSource
- type DeleteQueueRequest
- type DeleteQueueRequestParams
- type DeleteQueueResponse
- type DeleteQueueResponseParams
- type DeleteSubscribeRequest
- type DeleteSubscribeRequestParams
- type DeleteSubscribeResponse
- type DeleteSubscribeResponseParams
- type DeleteTopicRequest
- type DeleteTopicRequestParams
- type DeleteTopicResponse
- type DeleteTopicResponseParams
- type DescribeDeadLetterSourceQueuesRequest
- type DescribeDeadLetterSourceQueuesRequestParams
- type DescribeDeadLetterSourceQueuesResponse
- type DescribeDeadLetterSourceQueuesResponseParams
- type DescribeQueueDetailRequest
- type DescribeQueueDetailRequestParams
- type DescribeQueueDetailResponse
- type DescribeQueueDetailResponseParams
- type DescribeSubscriptionDetailRequest
- type DescribeSubscriptionDetailRequestParams
- type DescribeSubscriptionDetailResponse
- type DescribeSubscriptionDetailResponseParams
- type DescribeTopicDetailRequest
- type DescribeTopicDetailRequestParams
- type DescribeTopicDetailResponse
- type DescribeTopicDetailResponseParams
- type Filter
- type ModifyQueueAttributeRequest
- type ModifyQueueAttributeRequestParams
- type ModifyQueueAttributeResponse
- type ModifyQueueAttributeResponseParams
- type ModifySubscriptionAttributeRequest
- type ModifySubscriptionAttributeRequestParams
- type ModifySubscriptionAttributeResponse
- type ModifySubscriptionAttributeResponseParams
- type ModifyTopicAttributeRequest
- type ModifyTopicAttributeRequestParams
- type ModifyTopicAttributeResponse
- type ModifyTopicAttributeResponseParams
- type QueueSet
- type RewindQueueRequest
- type RewindQueueRequestParams
- type RewindQueueResponse
- type RewindQueueResponseParams
- type Subscription
- type Tag
- type TopicSet
- type TransactionPolicy
- type UnbindDeadLetterRequest
- type UnbindDeadLetterRequestParams
- type UnbindDeadLetterResponse
- type UnbindDeadLetterResponseParams
Constants ¶
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" )
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 ¶
func NewClient ¶
func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)
func NewClientWithSecretId ¶
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 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