v20190304

package
v3.0.233+incompatible Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const APIVersion = "2019-03-04"

Variables

This section is empty.

Functions

This section is empty.

Types

type ClearQueueRequest

type ClearQueueRequest struct {
	*tchttp.BaseRequest

	// 队列名字,在单个地域同一帐号下唯一。队列名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

func NewClearQueueRequest

func NewClearQueueRequest() (request *ClearQueueRequest)

func (*ClearQueueRequest) FromJsonString

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

func (*ClearQueueRequest) ToJsonString

func (r *ClearQueueRequest) ToJsonString() string

type ClearQueueResponse

type ClearQueueResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewClearQueueResponse

func NewClearQueueResponse() (response *ClearQueueResponse)

func (*ClearQueueResponse) FromJsonString

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

func (*ClearQueueResponse) ToJsonString

func (r *ClearQueueResponse) ToJsonString() string

type ClearSubscriptionFilterTagsRequest

type ClearSubscriptionFilterTagsRequest struct {
	*tchttp.BaseRequest

	// 主题名字,在单个地域同一帐号下唯一。主题名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 订阅名字,在单个地域同一帐号的同一主题下唯一。订阅名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
}

func NewClearSubscriptionFilterTagsRequest

func NewClearSubscriptionFilterTagsRequest() (request *ClearSubscriptionFilterTagsRequest)

func (*ClearSubscriptionFilterTagsRequest) FromJsonString

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

func (*ClearSubscriptionFilterTagsRequest) ToJsonString

func (r *ClearSubscriptionFilterTagsRequest) ToJsonString() string

type ClearSubscriptionFilterTagsResponse

type ClearSubscriptionFilterTagsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewClearSubscriptionFilterTagsResponse

func NewClearSubscriptionFilterTagsResponse() (response *ClearSubscriptionFilterTagsResponse)

func (*ClearSubscriptionFilterTagsResponse) FromJsonString

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

func (*ClearSubscriptionFilterTagsResponse) ToJsonString

func (r *ClearSubscriptionFilterTagsResponse) ToJsonString() string

type Client

type Client struct {
	common.Client
}

func NewClient

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

func NewClientWithSecretId

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

Deprecated

func (*Client) ClearQueue

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

清除queue中的所有消息

func (*Client) ClearSubscriptionFilterTags

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

清空订阅者消息标签

func (*Client) CreateQueue

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

创建队列接口

func (*Client) CreateSubscribe

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

创建订阅接口

func (*Client) CreateTopic

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

创建主题

func (*Client) DeleteQueue

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

DeleteQueue

func (*Client) DeleteSubscribe

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

删除订阅

func (*Client) DeleteTopic

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

删除主题

func (*Client) DescribeDeadLetterSourceQueues

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

枚举死信队列源队列

func (*Client) DescribeQueueDetail

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

枚举队列

func (*Client) DescribeSubscriptionDetail

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

查询订阅详情

func (*Client) DescribeTopicDetail

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

查询主题详情

func (*Client) ModifyQueueAttribute

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

修改队列属性

func (*Client) ModifySubscriptionAttribute

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

修改订阅属性

func (*Client) ModifyTopicAttribute

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

修改主题属性

func (*Client) RewindQueue

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

回溯队列

func (*Client) UnbindDeadLetter

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

解绑死信队列

type CreateQueueRequest

type CreateQueueRequest struct {
	*tchttp.BaseRequest

	// 队列名字,在单个地域同一帐号下唯一。队列名称是一个不超过 64 个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// 最大堆积消息数。取值范围在公测期间为 1,000,000 - 10,000,000,正式上线后范围可达到 1000,000-1000,000,000。默认取值在公测期间为 10,000,000,正式上线后为 100,000,000。
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitempty" name:"MaxMsgHeapNum"`

	// 消息接收长轮询等待时间。取值范围 0-30 秒,默认值 0。
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitempty" name:"PollingWaitSeconds"`

	// 消息可见性超时。取值范围 1-43200 秒(即12小时内),默认值 30。
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitempty" name:"VisibilityTimeout"`

	// 消息最大长度。取值范围 1024-65536 Byte(即1-64K),默认值 65536。
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// 消息保留周期。取值范围 60-1296000 秒(1min-15天),默认值 345600 (4 天)。
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// 队列是否开启回溯消息能力,该参数取值范围0-msgRetentionSeconds,即最大的回溯时间为消息在队列中的保留周期,0表示不开启。
	RewindSeconds *uint64 `json:"RewindSeconds,omitempty" name:"RewindSeconds"`

	// 1 表示事务队列,0 表示普通队列
	Transaction *uint64 `json:"Transaction,omitempty" name:"Transaction"`

	// 第一次回查间隔
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitempty" name:"FirstQueryInterval"`

	// 最大回查次数
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitempty" name:"MaxQueryCount"`

	// 死信队列名称
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitempty" name:"DeadLetterQueueName"`

	// 死信策略。0为消息被多次消费未删除,1为Time-To-Live过期
	Policy *uint64 `json:"Policy,omitempty" name:"Policy"`

	// 最大接收次数 1-1000
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitempty" name:"MaxReceiveCount"`

	// policy为1时必选。最大未消费过期时间。范围300-43200,单位秒,需要小于消息最大保留时间msgRetentionSeconds
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitempty" name:"MaxTimeToLive"`

	// 是否开启消息轨迹追踪,当不设置字段时,默认为不开启,该字段为true表示开启,为false表示不开启
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

func NewCreateQueueRequest

func NewCreateQueueRequest() (request *CreateQueueRequest)

func (*CreateQueueRequest) FromJsonString

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

func (*CreateQueueRequest) ToJsonString

func (r *CreateQueueRequest) ToJsonString() string

type CreateQueueResponse

type CreateQueueResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 创建成功的queueId
		QueueId *string `json:"QueueId,omitempty" name:"QueueId"`

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateQueueResponse

func NewCreateQueueResponse() (response *CreateQueueResponse)

func (*CreateQueueResponse) FromJsonString

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

func (*CreateQueueResponse) ToJsonString

func (r *CreateQueueResponse) ToJsonString() string

type CreateSubscribeRequest

type CreateSubscribeRequest struct {
	*tchttp.BaseRequest

	// 主题名字,在单个地域同一帐号下唯一。主题名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 订阅名字,在单个地域同一帐号的同一主题下唯一。订阅名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// 订阅的协议,目前支持两种协议:http、queue。使用http协议,用户需自己搭建接受消息的web server。使用queue,消息会自动推送到CMQ queue,用户可以并发地拉取消息。
	Protocol *string `json:"Protocol,omitempty" name:"Protocol"`

	// 接收通知的Endpoint,根据协议Protocol区分:对于http,Endpoint必须以“`http://`”开头,host可以是域名或IP;对于Queue,则填QueueName。 请注意,目前推送服务不能推送到私有网络中,因此Endpoint填写为私有网络域名或地址将接收不到推送的消息,目前支持推送到公网和基础网络。
	Endpoint *string `json:"Endpoint,omitempty" name:"Endpoint"`

	// 向Endpoint推送消息出现错误时,CMQ推送服务器的重试策略。取值有:1)BACKOFF_RETRY,退避重试。每隔一定时间重试一次,重试够一定次数后,就把该消息丢弃,继续推送下一条消息;2)EXPONENTIAL_DECAY_RETRY,指数衰退重试。每次重试的间隔是指数递增的,例如开始1s,后面是2s,4s,8s...由于Topic消息的周期是一天,所以最多重试一天就把消息丢弃。默认值是EXPONENTIAL_DECAY_RETRY。
	NotifyStrategy *string `json:"NotifyStrategy,omitempty" name:"NotifyStrategy"`

	// 消息正文。消息标签(用于消息过滤)。标签数量不能超过5个,每个标签不超过16个字符。与(Batch)PublishMessage的MsgTag参数配合使用,规则:1)如果FilterTag没有设置,则无论MsgTag是否有设置,订阅接收所有发布到Topic的消息;2)如果FilterTag数组有值,则只有数组中至少有一个值在MsgTag数组中也存在时(即FilterTag和MsgTag有交集),订阅才接收该发布到Topic的消息;3)如果FilterTag数组有值,但MsgTag没设置,则不接收任何发布到Topic的消息,可以认为是2)的一种特例,此时FilterTag和MsgTag没有交集。规则整体的设计思想是以订阅者的意愿为主。
	FilterTag []*string `json:"FilterTag,omitempty" name:"FilterTag" list`

	// BindingKey数量不超过5个, 每个BindingKey长度不超过64字节,该字段表示订阅接收消息的过滤策略,每个BindingKey最多含有15个“.”, 即最多16个词组。
	BindingKey []*string `json:"BindingKey,omitempty" name:"BindingKey" list`

	// 推送内容的格式。取值:1)JSON;2)SIMPLIFIED,即raw格式。如果Protocol是queue,则取值必须为SIMPLIFIED。如果Protocol是http,两个值均可以,默认值是JSON。
	NotifyContentFormat *string `json:"NotifyContentFormat,omitempty" name:"NotifyContentFormat"`
}

func NewCreateSubscribeRequest

func NewCreateSubscribeRequest() (request *CreateSubscribeRequest)

func (*CreateSubscribeRequest) FromJsonString

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

func (*CreateSubscribeRequest) ToJsonString

func (r *CreateSubscribeRequest) ToJsonString() string

type CreateSubscribeResponse

type CreateSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// SubscriptionId
		SubscriptionId *string `json:"SubscriptionId,omitempty" name:"SubscriptionId"`

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateSubscribeResponse

func NewCreateSubscribeResponse() (response *CreateSubscribeResponse)

func (*CreateSubscribeResponse) FromJsonString

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

func (*CreateSubscribeResponse) ToJsonString

func (r *CreateSubscribeResponse) ToJsonString() string

type CreateTopicRequest

type CreateTopicRequest struct {
	*tchttp.BaseRequest

	// 主题名字,在单个地域同一帐号下唯一。主题名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 消息最大长度。取值范围 1024-65536 Byte(即1-64K),默认值 65536。
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// 用于指定主题的消息匹配策略。1:表示标签匹配策略;2:表示路由匹配策略,默认值为标签匹配策略。
	FilterType *uint64 `json:"FilterType,omitempty" name:"FilterType"`

	// 消息保存时间。取值范围60 - 86400 s(即1分钟 - 1天),默认值86400。
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// 是否开启消息轨迹标识,true表示开启,false表示不开启,不填表示不开启。
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

func NewCreateTopicRequest

func NewCreateTopicRequest() (request *CreateTopicRequest)

func (*CreateTopicRequest) FromJsonString

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

func (*CreateTopicRequest) ToJsonString

func (r *CreateTopicRequest) ToJsonString() string

type CreateTopicResponse

type CreateTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// TopicName
		TopicId *string `json:"TopicId,omitempty" name:"TopicId"`

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateTopicResponse

func NewCreateTopicResponse() (response *CreateTopicResponse)

func (*CreateTopicResponse) FromJsonString

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

func (*CreateTopicResponse) ToJsonString

func (r *CreateTopicResponse) ToJsonString() string

type DeadLetterPolicy

type DeadLetterPolicy struct {

	// 死信队列名字。
	// 注意:此字段可能返回 null,表示取不到有效值。
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitempty" name:"DeadLetterQueueName"`

	// 死信队列。
	// 注意:此字段可能返回 null,表示取不到有效值。
	DeadLetterQueue *string `json:"DeadLetterQueue,omitempty" name:"DeadLetterQueue"`

	// 死信队列策略。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Policy *uint64 `json:"Policy,omitempty" name:"Policy"`

	// 最大未消费过期时间。Policy为1时必选。范围300-43200,单位秒,需要小于消息最大保留时间MsgRetentionSeconds。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitempty" name:"MaxTimeToLive"`

	// 最大接收次数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitempty" name:"MaxReceiveCount"`
}

type DeadLetterSource

type DeadLetterSource struct {

	// 消息队列ID。
	// 注意:此字段可能返回 null,表示取不到有效值。
	QueueId *string `json:"QueueId,omitempty" name:"QueueId"`

	// 消息队列名字。
	// 注意:此字段可能返回 null,表示取不到有效值。
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

type DeleteQueueRequest

type DeleteQueueRequest struct {
	*tchttp.BaseRequest

	// 队列名字,在单个地域同一帐号下唯一。队列名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

func NewDeleteQueueRequest

func NewDeleteQueueRequest() (request *DeleteQueueRequest)

func (*DeleteQueueRequest) FromJsonString

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

func (*DeleteQueueRequest) ToJsonString

func (r *DeleteQueueRequest) ToJsonString() string

type DeleteQueueResponse

type DeleteQueueResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteQueueResponse

func NewDeleteQueueResponse() (response *DeleteQueueResponse)

func (*DeleteQueueResponse) FromJsonString

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

func (*DeleteQueueResponse) ToJsonString

func (r *DeleteQueueResponse) ToJsonString() string

type DeleteSubscribeRequest

type DeleteSubscribeRequest struct {
	*tchttp.BaseRequest

	// 主题名字,在单个地域同一帐号下唯一。主题名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 订阅名字,在单个地域同一帐号的同一主题下唯一。订阅名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
}

func NewDeleteSubscribeRequest

func NewDeleteSubscribeRequest() (request *DeleteSubscribeRequest)

func (*DeleteSubscribeRequest) FromJsonString

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

func (*DeleteSubscribeRequest) ToJsonString

func (r *DeleteSubscribeRequest) ToJsonString() string

type DeleteSubscribeResponse

type DeleteSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteSubscribeResponse

func NewDeleteSubscribeResponse() (response *DeleteSubscribeResponse)

func (*DeleteSubscribeResponse) FromJsonString

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

func (*DeleteSubscribeResponse) ToJsonString

func (r *DeleteSubscribeResponse) ToJsonString() string

type DeleteTopicRequest

type DeleteTopicRequest struct {
	*tchttp.BaseRequest

	// 主题名字,在单个地域同一帐号下唯一。主题名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
}

func NewDeleteTopicRequest

func NewDeleteTopicRequest() (request *DeleteTopicRequest)

func (*DeleteTopicRequest) FromJsonString

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

func (*DeleteTopicRequest) ToJsonString

func (r *DeleteTopicRequest) ToJsonString() string

type DeleteTopicResponse

type DeleteTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteTopicResponse

func NewDeleteTopicResponse() (response *DeleteTopicResponse)

func (*DeleteTopicResponse) FromJsonString

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

func (*DeleteTopicResponse) ToJsonString

func (r *DeleteTopicResponse) ToJsonString() string

type DescribeDeadLetterSourceQueuesRequest

type DescribeDeadLetterSourceQueuesRequest struct {
	*tchttp.BaseRequest

	// 死信队列名称
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitempty" name:"DeadLetterQueueName"`

	// 分页时本页获取主题列表的起始位置。如果填写了该值,必须也要填写 limit 。该值缺省时,后台取默认值 0。
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// 分页时本页获取主题的个数,如果不传递该参数,则该参数默认为20,最大值为50。
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// 过滤死信队列源队列名称,目前仅支持SourceQueueName过滤
	Filters []*Filter `json:"Filters,omitempty" name:"Filters" list`
}

func NewDescribeDeadLetterSourceQueuesRequest

func NewDescribeDeadLetterSourceQueuesRequest() (request *DescribeDeadLetterSourceQueuesRequest)

func (*DescribeDeadLetterSourceQueuesRequest) FromJsonString

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

func (*DescribeDeadLetterSourceQueuesRequest) ToJsonString

type DescribeDeadLetterSourceQueuesResponse

type DescribeDeadLetterSourceQueuesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 满足本次条件的队列个数
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// 死信队列源队列
		QueueSet []*DeadLetterSource `json:"QueueSet,omitempty" name:"QueueSet" list`

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeDeadLetterSourceQueuesResponse

func NewDescribeDeadLetterSourceQueuesResponse() (response *DescribeDeadLetterSourceQueuesResponse)

func (*DescribeDeadLetterSourceQueuesResponse) FromJsonString

func (*DescribeDeadLetterSourceQueuesResponse) ToJsonString

type DescribeQueueDetailRequest

type DescribeQueueDetailRequest struct {
	*tchttp.BaseRequest

	// 分页时本页获取队列列表的起始位置。如果填写了该值,必须也要填写 limit 。该值缺省时,后台取默认值 0
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// 分页时本页获取队列的个数,如果不传递该参数,则该参数默认为20,最大值为50。
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// 筛选参数,目前支持QueueName筛选,且仅支持一个关键字
	Filters []*Filter `json:"Filters,omitempty" name:"Filters" list`

	// 标签搜索
	TagKey *string `json:"TagKey,omitempty" name:"TagKey"`

	// 精确匹配QueueName
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

func NewDescribeQueueDetailRequest

func NewDescribeQueueDetailRequest() (request *DescribeQueueDetailRequest)

func (*DescribeQueueDetailRequest) FromJsonString

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

func (*DescribeQueueDetailRequest) ToJsonString

func (r *DescribeQueueDetailRequest) ToJsonString() string

type DescribeQueueDetailResponse

type DescribeQueueDetailResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 总队列数。
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// 队列详情列表。
		QueueSet []*QueueSet `json:"QueueSet,omitempty" name:"QueueSet" list`

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeQueueDetailResponse

func NewDescribeQueueDetailResponse() (response *DescribeQueueDetailResponse)

func (*DescribeQueueDetailResponse) FromJsonString

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

func (*DescribeQueueDetailResponse) ToJsonString

func (r *DescribeQueueDetailResponse) ToJsonString() string

type DescribeSubscriptionDetailRequest

type DescribeSubscriptionDetailRequest struct {
	*tchttp.BaseRequest

	// 主题名字,在单个地域同一帐号下唯一。主题名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 分页时本页获取主题列表的起始位置。如果填写了该值,必须也要填写 limit 。该值缺省时,后台取默认值 0
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// 分页时本页获取主题的个数,如果不传递该参数,则该参数默认为20,最大值为50。
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// 筛选参数,目前只支持SubscriptionName,且仅支持一个关键字。
	Filters []*Filter `json:"Filters,omitempty" name:"Filters" list`
}

func NewDescribeSubscriptionDetailRequest

func NewDescribeSubscriptionDetailRequest() (request *DescribeSubscriptionDetailRequest)

func (*DescribeSubscriptionDetailRequest) FromJsonString

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

func (*DescribeSubscriptionDetailRequest) ToJsonString

func (r *DescribeSubscriptionDetailRequest) ToJsonString() string

type DescribeSubscriptionDetailResponse

type DescribeSubscriptionDetailResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 总数
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Subscription属性集合
		// 注意:此字段可能返回 null,表示取不到有效值。
		SubscriptionSet []*Subscription `json:"SubscriptionSet,omitempty" name:"SubscriptionSet" list`

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeSubscriptionDetailResponse

func NewDescribeSubscriptionDetailResponse() (response *DescribeSubscriptionDetailResponse)

func (*DescribeSubscriptionDetailResponse) FromJsonString

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

func (*DescribeSubscriptionDetailResponse) ToJsonString

func (r *DescribeSubscriptionDetailResponse) ToJsonString() string

type DescribeTopicDetailRequest

type DescribeTopicDetailRequest struct {
	*tchttp.BaseRequest

	// 分页时本页获取队列列表的起始位置。如果填写了该值,必须也要填写 limit 。该值缺省时,后台取默认值 0。
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// 分页时本页获取队列的个数,如果不传递该参数,则该参数默认为20,最大值为50。
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// 目前只支持过滤TopicName , 且只能填一个过滤值。
	Filters []*Filter `json:"Filters,omitempty" name:"Filters" list`

	// 标签匹配。
	TagKey *string `json:"TagKey,omitempty" name:"TagKey"`

	// 精确匹配TopicName。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
}

func NewDescribeTopicDetailRequest

func NewDescribeTopicDetailRequest() (request *DescribeTopicDetailRequest)

func (*DescribeTopicDetailRequest) FromJsonString

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

func (*DescribeTopicDetailRequest) ToJsonString

func (r *DescribeTopicDetailRequest) ToJsonString() string

type DescribeTopicDetailResponse

type DescribeTopicDetailResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 主题列表总数。
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// 主题详情列表。
		TopicSet []*TopicSet `json:"TopicSet,omitempty" name:"TopicSet" list`

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeTopicDetailResponse

func NewDescribeTopicDetailResponse() (response *DescribeTopicDetailResponse)

func (*DescribeTopicDetailResponse) FromJsonString

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

func (*DescribeTopicDetailResponse) ToJsonString

func (r *DescribeTopicDetailResponse) ToJsonString() string

type Filter

type Filter struct {

	// 过滤参数的名字
	Name *string `json:"Name,omitempty" name:"Name"`

	// 数值
	Values []*string `json:"Values,omitempty" name:"Values" list`
}

type ModifyQueueAttributeRequest

type ModifyQueueAttributeRequest struct {
	*tchttp.BaseRequest

	// 队列名字,在单个地域同一帐号下唯一。队列名称是一个不超过 64 个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// 最大堆积消息数。取值范围在公测期间为 1,000,000 - 10,000,000,正式上线后范围可达到 1000,000-1000,000,000。默认取值在公测期间为 10,000,000,正式上线后为 100,000,000。
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitempty" name:"MaxMsgHeapNum"`

	// 消息接收长轮询等待时间。取值范围 0-30 秒,默认值 0。
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitempty" name:"PollingWaitSeconds"`

	// 消息可见性超时。取值范围 1-43200 秒(即12小时内),默认值 30。
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitempty" name:"VisibilityTimeout"`

	// 消息最大长度。取值范围 1024-65536 Byte(即1-64K),默认值 65536。
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// 消息保留周期。取值范围 60-1296000 秒(1min-15天),默认值 345600 (4 天)。
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// 消息最长回溯时间,取值范围0-msgRetentionSeconds,消息的最大回溯之间为消息在队列中的保存周期,0表示不开启消息回溯。
	RewindSeconds *uint64 `json:"RewindSeconds,omitempty" name:"RewindSeconds"`

	// 第一次查询时间
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitempty" name:"FirstQueryInterval"`

	// 最大查询次数
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitempty" name:"MaxQueryCount"`

	// 死信队列名称
	DeadLetterQueueName *string `json:"DeadLetterQueueName,omitempty" name:"DeadLetterQueueName"`

	// MaxTimeToLivepolicy为1时必选。最大未消费过期时间。范围300-43200,单位秒,需要小于消息最大保留时间MsgRetentionSeconds
	MaxTimeToLive *uint64 `json:"MaxTimeToLive,omitempty" name:"MaxTimeToLive"`

	// 最大接收次数
	MaxReceiveCount *uint64 `json:"MaxReceiveCount,omitempty" name:"MaxReceiveCount"`

	// 死信队列策略
	Policy *uint64 `json:"Policy,omitempty" name:"Policy"`

	// 是否开启消息轨迹标识,true表示开启,false表示不开启,不填表示不开启。
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

func NewModifyQueueAttributeRequest

func NewModifyQueueAttributeRequest() (request *ModifyQueueAttributeRequest)

func (*ModifyQueueAttributeRequest) FromJsonString

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

func (*ModifyQueueAttributeRequest) ToJsonString

func (r *ModifyQueueAttributeRequest) ToJsonString() string

type ModifyQueueAttributeResponse

type ModifyQueueAttributeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyQueueAttributeResponse

func NewModifyQueueAttributeResponse() (response *ModifyQueueAttributeResponse)

func (*ModifyQueueAttributeResponse) FromJsonString

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

func (*ModifyQueueAttributeResponse) ToJsonString

func (r *ModifyQueueAttributeResponse) ToJsonString() string

type ModifySubscriptionAttributeRequest

type ModifySubscriptionAttributeRequest struct {
	*tchttp.BaseRequest

	// 主题名字,在单个地域同一帐号下唯一。主题名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 订阅名字,在单个地域同一帐号的同一主题下唯一。订阅名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// 向 Endpoint 推送消息出现错误时,CMQ 推送服务器的重试策略。取值如下:
	// (1)BACKOFF_RETRY,退避重试。每隔一定时间重试一次,重试够一定次数后,就把该消息丢弃,继续推送下一条消息。
	// (2)EXPONENTIAL_DECAY_RETRY,指数衰退重试。每次重试的间隔是指数递增的,例如开始1s,后面是2s,4s,8s···由于 Topic 消息的周期是一天,所以最多重试一天就把消息丢弃。默认值是 EXPONENTIAL_DECAY_RETRY。
	NotifyStrategy *string `json:"NotifyStrategy,omitempty" name:"NotifyStrategy"`

	// 推送内容的格式。取值:(1)JSON;(2)SIMPLIFIED,即 raw 格式。如果 Protocol 是 queue,则取值必须为 SIMPLIFIED。如果 Protocol 是 HTTP,两个值均可以,默认值是 JSON。
	NotifyContentFormat *string `json:"NotifyContentFormat,omitempty" name:"NotifyContentFormat"`

	// 消息正文。消息标签(用于消息过滤)。标签数量不能超过5个,每个标签不超过16个字符。与(Batch)PublishMessage的MsgTag参数配合使用,规则:1)如果FilterTag没有设置,则无论MsgTag是否有设置,订阅接收所有发布到Topic的消息;2)如果FilterTag数组有值,则只有数组中至少有一个值在MsgTag数组中也存在时(即FilterTag和MsgTag有交集),订阅才接收该发布到Topic的消息;3)如果FilterTag数组有值,但MsgTag没设置,则不接收任何发布到Topic的消息,可以认为是2)的一种特例,此时FilterTag和MsgTag没有交集。规则整体的设计思想是以订阅者的意愿为主。
	FilterTags []*string `json:"FilterTags,omitempty" name:"FilterTags" list`

	// BindingKey数量不超过5个, 每个BindingKey长度不超过64字节,该字段表示订阅接收消息的过滤策略,每个BindingKey最多含有15个“.”, 即最多16个词组。
	BindingKey []*string `json:"BindingKey,omitempty" name:"BindingKey" list`
}

func NewModifySubscriptionAttributeRequest

func NewModifySubscriptionAttributeRequest() (request *ModifySubscriptionAttributeRequest)

func (*ModifySubscriptionAttributeRequest) FromJsonString

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

func (*ModifySubscriptionAttributeRequest) ToJsonString

func (r *ModifySubscriptionAttributeRequest) ToJsonString() string

type ModifySubscriptionAttributeResponse

type ModifySubscriptionAttributeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifySubscriptionAttributeResponse

func NewModifySubscriptionAttributeResponse() (response *ModifySubscriptionAttributeResponse)

func (*ModifySubscriptionAttributeResponse) FromJsonString

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

func (*ModifySubscriptionAttributeResponse) ToJsonString

func (r *ModifySubscriptionAttributeResponse) ToJsonString() string

type ModifyTopicAttributeRequest

type ModifyTopicAttributeRequest struct {
	*tchttp.BaseRequest

	// 主题名字,在单个地域同一帐号下唯一。主题名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 消息最大长度。取值范围1024 - 65536 Byte(即1 - 64K),默认值65536。
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// 消息保存时间。取值范围60 - 86400 s(即1分钟 - 1天),默认值86400。
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// 是否开启消息轨迹标识,true表示开启,false表示不开启,不填表示不开启。
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

func NewModifyTopicAttributeRequest

func NewModifyTopicAttributeRequest() (request *ModifyTopicAttributeRequest)

func (*ModifyTopicAttributeRequest) FromJsonString

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

func (*ModifyTopicAttributeRequest) ToJsonString

func (r *ModifyTopicAttributeRequest) ToJsonString() string

type ModifyTopicAttributeResponse

type ModifyTopicAttributeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewModifyTopicAttributeResponse

func NewModifyTopicAttributeResponse() (response *ModifyTopicAttributeResponse)

func (*ModifyTopicAttributeResponse) FromJsonString

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

func (*ModifyTopicAttributeResponse) ToJsonString

func (r *ModifyTopicAttributeResponse) ToJsonString() string

type QueueSet

type QueueSet struct {

	// 消息队列ID。
	QueueId *string `json:"QueueId,omitempty" name:"QueueId"`

	// 消息队列名字。
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// 每秒钟生产消息条数的限制,消费消息的大小是该值的1.1倍。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Qps *uint64 `json:"Qps,omitempty" name:"Qps"`

	// 带宽限制。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Bps *uint64 `json:"Bps,omitempty" name:"Bps"`

	// 飞行消息最大保留时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MaxDelaySeconds *uint64 `json:"MaxDelaySeconds,omitempty" name:"MaxDelaySeconds"`

	// 最大堆积消息数。取值范围在公测期间为 1,000,000 - 10,000,000,正式上线后范围可达到 1000,000-1000,000,000。默认取值在公测期间为 10,000,000,正式上线后为 100,000,000。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MaxMsgHeapNum *uint64 `json:"MaxMsgHeapNum,omitempty" name:"MaxMsgHeapNum"`

	// 消息接收长轮询等待时间。取值范围0 - 30秒,默认值0。
	// 注意:此字段可能返回 null,表示取不到有效值。
	PollingWaitSeconds *uint64 `json:"PollingWaitSeconds,omitempty" name:"PollingWaitSeconds"`

	// 消息保留周期。取值范围60-1296000秒(1min-15天),默认值345600秒(4 天)。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// 消息可见性超时。取值范围1 - 43200秒(即12小时内),默认值30。
	// 注意:此字段可能返回 null,表示取不到有效值。
	VisibilityTimeout *uint64 `json:"VisibilityTimeout,omitempty" name:"VisibilityTimeout"`

	// 消息最大长度。取值范围1024 - 1048576 Byte(即1K - 1024K),默认值65536。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// 回溯队列的消息回溯时间最大值,取值范围0 - 43200秒,0表示不开启消息回溯。
	// 注意:此字段可能返回 null,表示取不到有效值。
	RewindSeconds *uint64 `json:"RewindSeconds,omitempty" name:"RewindSeconds"`

	// 队列的创建时间。返回 Unix 时间戳,精确到秒。
	// 注意:此字段可能返回 null,表示取不到有效值。
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// 最后一次修改队列属性的时间。返回 Unix 时间戳,精确到秒。
	// 注意:此字段可能返回 null,表示取不到有效值。
	LastModifyTime *uint64 `json:"LastModifyTime,omitempty" name:"LastModifyTime"`

	// 在队列中处于 Active 状态(不处于被消费状态)的消息总数,为近似值。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ActiveMsgNum *uint64 `json:"ActiveMsgNum,omitempty" name:"ActiveMsgNum"`

	// 在队列中处于 Inactive 状态(正处于被消费状态)的消息总数,为近似值。
	// 注意:此字段可能返回 null,表示取不到有效值。
	InactiveMsgNum *uint64 `json:"InactiveMsgNum,omitempty" name:"InactiveMsgNum"`

	// 延迟消息数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	DelayMsgNum *uint64 `json:"DelayMsgNum,omitempty" name:"DelayMsgNum"`

	// 已调用 DelMsg 接口删除,但还在回溯保留时间内的消息数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	RewindMsgNum *uint64 `json:"RewindMsgNum,omitempty" name:"RewindMsgNum"`

	// 消息最小未消费时间,单位为秒。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MinMsgTime *uint64 `json:"MinMsgTime,omitempty" name:"MinMsgTime"`

	// 事务消息队列。true表示是事务消息,false表示不是事务消息。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Transaction *bool `json:"Transaction,omitempty" name:"Transaction"`

	// 死信队列。
	// 注意:此字段可能返回 null,表示取不到有效值。
	DeadLetterSource []*DeadLetterSource `json:"DeadLetterSource,omitempty" name:"DeadLetterSource" list`

	// 死信队列策略。
	// 注意:此字段可能返回 null,表示取不到有效值。
	DeadLetterPolicy *DeadLetterPolicy `json:"DeadLetterPolicy,omitempty" name:"DeadLetterPolicy"`

	// 事务消息策略。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TransactionPolicy *TransactionPolicy `json:"TransactionPolicy,omitempty" name:"TransactionPolicy"`

	// 创建者Uin。
	// 注意:此字段可能返回 null,表示取不到有效值。
	CreateUin *uint64 `json:"CreateUin,omitempty" name:"CreateUin"`

	// 关联的标签。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Tags []*Tag `json:"Tags,omitempty" name:"Tags" list`

	// 消息轨迹。true表示开启,false表示不开启。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

type RewindQueueRequest

type RewindQueueRequest struct {
	*tchttp.BaseRequest

	// 队列名字,在单个地域同一帐号下唯一。队列名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`

	// 设定该时间,则(Batch)receiveMessage接口,会按照生产消息的先后顺序消费该时间戳以后的消息。
	StartConsumeTime *uint64 `json:"StartConsumeTime,omitempty" name:"StartConsumeTime"`
}

func NewRewindQueueRequest

func NewRewindQueueRequest() (request *RewindQueueRequest)

func (*RewindQueueRequest) FromJsonString

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

func (*RewindQueueRequest) ToJsonString

func (r *RewindQueueRequest) ToJsonString() string

type RewindQueueResponse

type RewindQueueResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewRewindQueueResponse

func NewRewindQueueResponse() (response *RewindQueueResponse)

func (*RewindQueueResponse) FromJsonString

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

func (*RewindQueueResponse) ToJsonString

func (r *RewindQueueResponse) ToJsonString() string

type Subscription

type Subscription struct {

	// 订阅名字,在单个地域同一帐号的同一主题下唯一。订阅名称是一个不超过64个字符的字符串,必须以字母为首字符,剩余部分可以包含字母、数字和横划线(-)。
	// 注意:此字段可能返回 null,表示取不到有效值。
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`

	// 订阅 ID。订阅 ID 在拉取监控数据时会用到。
	// 注意:此字段可能返回 null,表示取不到有效值。
	SubscriptionId *string `json:"SubscriptionId,omitempty" name:"SubscriptionId"`

	// 订阅拥有者的 APPID。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TopicOwner *uint64 `json:"TopicOwner,omitempty" name:"TopicOwner"`

	// 该订阅待投递的消息数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgCount *uint64 `json:"MsgCount,omitempty" name:"MsgCount"`

	// 最后一次修改订阅属性的时间。返回 Unix 时间戳,精确到秒。
	// 注意:此字段可能返回 null,表示取不到有效值。
	LastModifyTime *uint64 `json:"LastModifyTime,omitempty" name:"LastModifyTime"`

	// 订阅的创建时间。返回 Unix 时间戳,精确到秒。
	// 注意:此字段可能返回 null,表示取不到有效值。
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// 表示订阅接收消息的过滤策略。
	// 注意:此字段可能返回 null,表示取不到有效值。
	BindingKey []*string `json:"BindingKey,omitempty" name:"BindingKey" list`

	// 接收通知的 endpoint,根据协议 protocol 区分:对于 HTTP,endpoint 必须以http://开头,host 可以是域名或 IP;对于 queue,则填 queueName。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Endpoint *string `json:"Endpoint,omitempty" name:"Endpoint"`

	// 描述用户创建订阅时选择的过滤策略:
	// filterType = 1表示用户使用 filterTag 标签过滤
	// filterType = 2表示用户使用 bindingKey 过滤。
	// 注意:此字段可能返回 null,表示取不到有效值。
	FilterTags []*string `json:"FilterTags,omitempty" name:"FilterTags" list`

	// 订阅的协议,目前支持两种协议:HTTP、queue。使用 HTTP 协议,用户需自己搭建接受消息的 Web Server。使用 queue,消息会自动推送到 CMQ queue,用户可以并发地拉取消息。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Protocol *string `json:"Protocol,omitempty" name:"Protocol"`

	// 向 endpoint 推送消息出现错误时,CMQ 推送服务器的重试策略。取值有:
	// (1)BACKOFF_RETRY,退避重试。每隔一定时间重试一次,重试够一定次数后,就把该消息丢弃,继续推送下一条消息;
	// (2)EXPONENTIAL_DECAY_RETRY,指数衰退重试。每次重试的间隔是指数递增的,例如开始 1s,后面是 2s,4s,8s...由于 Topic 消息的周期是一天,所以最多重试一天就把消息丢弃。默认值是 EXPONENTIAL_DECAY_RETRY。
	// 注意:此字段可能返回 null,表示取不到有效值。
	NotifyStrategy *string `json:"NotifyStrategy,omitempty" name:"NotifyStrategy"`

	// 推送内容的格式。取值:(1)JSON;(2)SIMPLIFIED,即 raw 格式。如果 protocol 是 queue,则取值必须为 SIMPLIFIED。如果 protocol 是 HTTP,两个值均可以,默认值是 JSON。
	// 注意:此字段可能返回 null,表示取不到有效值。
	NotifyContentFormat *string `json:"NotifyContentFormat,omitempty" name:"NotifyContentFormat"`
}

type Tag

type Tag struct {

	// 标签Key
	// 注意:此字段可能返回 null,表示取不到有效值。
	TagKey *string `json:"TagKey,omitempty" name:"TagKey"`

	// 标签值
	// 注意:此字段可能返回 null,表示取不到有效值。
	TagValue *string `json:"TagValue,omitempty" name:"TagValue"`
}

type TopicSet

type TopicSet struct {

	// 主题的 ID。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TopicId *string `json:"TopicId,omitempty" name:"TopicId"`

	// 主题名称。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// 消息在主题中最长存活时间,从发送到该主题开始经过此参数指定的时间后,不论消息是否被成功推送给用户都将被删除,单位为秒。固定为一天(86400秒),该属性不能修改。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRetentionSeconds *uint64 `json:"MsgRetentionSeconds,omitempty" name:"MsgRetentionSeconds"`

	// 消息最大长度。取值范围1024 - 1048576Byte(即1 - 1024K),默认值为65536。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MaxMsgSize *uint64 `json:"MaxMsgSize,omitempty" name:"MaxMsgSize"`

	// 每秒钟发布消息的条数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Qps *uint64 `json:"Qps,omitempty" name:"Qps"`

	// 描述用户创建订阅时选择的过滤策略:
	// FilterType = 1表示用户使用 FilterTag 标签过滤;
	// FilterType = 2表示用户使用 BindingKey 过滤。
	// 注意:此字段可能返回 null,表示取不到有效值。
	FilterType *uint64 `json:"FilterType,omitempty" name:"FilterType"`

	// 主题的创建时间。返回 Unix 时间戳,精确到秒。
	// 注意:此字段可能返回 null,表示取不到有效值。
	CreateTime *uint64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// 最后一次修改主题属性的时间。返回 Unix 时间戳,精确到秒。
	// 注意:此字段可能返回 null,表示取不到有效值。
	LastModifyTime *uint64 `json:"LastModifyTime,omitempty" name:"LastModifyTime"`

	// 当前该主题中消息数目(消息堆积数)。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgCount *uint64 `json:"MsgCount,omitempty" name:"MsgCount"`

	// 创建者 Uin,CAM 鉴权 resource 由该字段组合而成。
	// 注意:此字段可能返回 null,表示取不到有效值。
	CreateUin *uint64 `json:"CreateUin,omitempty" name:"CreateUin"`

	// 关联的标签。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Tags []*Tag `json:"Tags,omitempty" name:"Tags" list`

	// 消息轨迹。true表示开启,false表示不开启。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Trace *bool `json:"Trace,omitempty" name:"Trace"`
}

type TransactionPolicy

type TransactionPolicy struct {

	// 第一次回查时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	FirstQueryInterval *uint64 `json:"FirstQueryInterval,omitempty" name:"FirstQueryInterval"`

	// 最大查询次数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MaxQueryCount *uint64 `json:"MaxQueryCount,omitempty" name:"MaxQueryCount"`
}

type UnbindDeadLetterRequest

type UnbindDeadLetterRequest struct {
	*tchttp.BaseRequest

	// 死信策略源队列名称,调用本接口会清空该队列的死信队列策略。
	QueueName *string `json:"QueueName,omitempty" name:"QueueName"`
}

func NewUnbindDeadLetterRequest

func NewUnbindDeadLetterRequest() (request *UnbindDeadLetterRequest)

func (*UnbindDeadLetterRequest) FromJsonString

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

func (*UnbindDeadLetterRequest) ToJsonString

func (r *UnbindDeadLetterRequest) ToJsonString() string

type UnbindDeadLetterResponse

type UnbindDeadLetterResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewUnbindDeadLetterResponse

func NewUnbindDeadLetterResponse() (response *UnbindDeadLetterResponse)

func (*UnbindDeadLetterResponse) FromJsonString

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

func (*UnbindDeadLetterResponse) ToJsonString

func (r *UnbindDeadLetterResponse) ToJsonString() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL