 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
- type Client
- func (c *Client) CreateEnvironment(request *CreateEnvironmentRequest) (response *CreateEnvironmentResponse, err error)
- func (c *Client) CreateSubscription(request *CreateSubscriptionRequest) (response *CreateSubscriptionResponse, err error)
- func (c *Client) CreateTopic(request *CreateTopicRequest) (response *CreateTopicResponse, err error)
- func (c *Client) DeleteEnvironments(request *DeleteEnvironmentsRequest) (response *DeleteEnvironmentsResponse, err error)
- func (c *Client) DeleteSubscriptions(request *DeleteSubscriptionsRequest) (response *DeleteSubscriptionsResponse, err error)
- func (c *Client) DeleteTopics(request *DeleteTopicsRequest) (response *DeleteTopicsResponse, err error)
- func (c *Client) DescribeEnvironmentAttributes(request *DescribeEnvironmentAttributesRequest) (response *DescribeEnvironmentAttributesResponse, err error)
- func (c *Client) DescribeEnvironments(request *DescribeEnvironmentsRequest) (response *DescribeEnvironmentsResponse, err error)
- func (c *Client) DescribeProducers(request *DescribeProducersRequest) (response *DescribeProducersResponse, err error)
- func (c *Client) DescribeSubscriptions(request *DescribeSubscriptionsRequest) (response *DescribeSubscriptionsResponse, err error)
- func (c *Client) DescribeTopics(request *DescribeTopicsRequest) (response *DescribeTopicsResponse, err error)
- func (c *Client) ModifyEnvironmentAttributes(request *ModifyEnvironmentAttributesRequest) (response *ModifyEnvironmentAttributesResponse, err error)
- func (c *Client) ModifyTopic(request *ModifyTopicRequest) (response *ModifyTopicResponse, err error)
- func (c *Client) ResetMsgSubOffsetByTimestamp(request *ResetMsgSubOffsetByTimestampRequest) (response *ResetMsgSubOffsetByTimestampResponse, err error)
 
- type Connection
- type Consumer
- type ConsumersSchedule
- type CreateEnvironmentRequest
- type CreateEnvironmentResponse
- type CreateSubscriptionRequest
- type CreateSubscriptionResponse
- type CreateTopicRequest
- type CreateTopicResponse
- type DeleteEnvironmentsRequest
- type DeleteEnvironmentsResponse
- type DeleteSubscriptionsRequest
- type DeleteSubscriptionsResponse
- type DeleteTopicsRequest
- type DeleteTopicsResponse
- type DescribeEnvironmentAttributesRequest
- type DescribeEnvironmentAttributesResponse
- type DescribeEnvironmentsRequest
- type DescribeEnvironmentsResponse
- type DescribeProducersRequest
- type DescribeProducersResponse
- type DescribeSubscriptionsRequest
- type DescribeSubscriptionsResponse
- type DescribeTopicsRequest
- type DescribeTopicsResponse
- type Environment
- type FilterSubscription
- type ModifyEnvironmentAttributesRequest
- type ModifyEnvironmentAttributesResponse
- type ModifyTopicRequest
- type ModifyTopicResponse
- type PartitionsTopic
- type Producer
- type ResetMsgSubOffsetByTimestampRequest
- type ResetMsgSubOffsetByTimestampResponse
- type Subscription
- type SubscriptionTopic
- type Topic
- type TopicRecord
Constants ¶
      View Source
      
  
const APIVersion = "2020-02-17"
    Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
func NewClient ¶
func NewClient(credential *common.Credential, region string, clientProfile *profile.ClientProfile) (client *Client, err error)
func NewClientWithSecretId ¶
Deprecated
func (*Client) CreateEnvironment ¶
func (c *Client) CreateEnvironment(request *CreateEnvironmentRequest) (response *CreateEnvironmentResponse, err error)
用于在用户账户下创建消息队列 Tdmq环境(命名空间)
func (*Client) CreateSubscription ¶
func (c *Client) CreateSubscription(request *CreateSubscriptionRequest) (response *CreateSubscriptionResponse, err error)
创建一个主题的订阅关系
func (*Client) CreateTopic ¶
func (c *Client) CreateTopic(request *CreateTopicRequest) (response *CreateTopicResponse, err error)
新增指定分区、类型的消息主题
func (*Client) DeleteEnvironments ¶
func (c *Client) DeleteEnvironments(request *DeleteEnvironmentsRequest) (response *DeleteEnvironmentsResponse, err error)
批量删除租户下的环境
func (*Client) DeleteSubscriptions ¶
func (c *Client) DeleteSubscriptions(request *DeleteSubscriptionsRequest) (response *DeleteSubscriptionsResponse, err error)
删除订阅关系
func (*Client) DeleteTopics ¶
func (c *Client) DeleteTopics(request *DeleteTopicsRequest) (response *DeleteTopicsResponse, err error)
批量删除topics
func (*Client) DescribeEnvironmentAttributes ¶
func (c *Client) DescribeEnvironmentAttributes(request *DescribeEnvironmentAttributesRequest) (response *DescribeEnvironmentAttributesResponse, err error)
获取指定环境的属性
func (*Client) DescribeEnvironments ¶
func (c *Client) DescribeEnvironments(request *DescribeEnvironmentsRequest) (response *DescribeEnvironmentsResponse, err error)
获取租户下环境列表
func (*Client) DescribeProducers ¶
func (c *Client) DescribeProducers(request *DescribeProducersRequest) (response *DescribeProducersResponse, err error)
获取生产者列表,仅显示在线的生产者
func (*Client) DescribeSubscriptions ¶
func (c *Client) DescribeSubscriptions(request *DescribeSubscriptionsRequest) (response *DescribeSubscriptionsResponse, err error)
查询指定环境和主题下的订阅者列表
func (*Client) DescribeTopics ¶
func (c *Client) DescribeTopics(request *DescribeTopicsRequest) (response *DescribeTopicsResponse, err error)
获取环境下主题列表
func (*Client) ModifyEnvironmentAttributes ¶
func (c *Client) ModifyEnvironmentAttributes(request *ModifyEnvironmentAttributesRequest) (response *ModifyEnvironmentAttributesResponse, err error)
修改指定环境的属性值
func (*Client) ModifyTopic ¶
func (c *Client) ModifyTopic(request *ModifyTopicRequest) (response *ModifyTopicResponse, err error)
修改主题备注和分区数
func (*Client) ResetMsgSubOffsetByTimestamp ¶
func (c *Client) ResetMsgSubOffsetByTimestamp(request *ResetMsgSubOffsetByTimestampRequest) (response *ResetMsgSubOffsetByTimestampResponse, err error)
根据时间戳进行消息回溯,精确到毫秒
type Connection ¶
type Connection struct {
	// 生产者地址。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Address *string `json:"Address,omitempty" name:"Address"`
	// 主题分区。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Partitions *int64 `json:"Partitions,omitempty" name:"Partitions"`
	// 生产者版本。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ClientVersion *string `json:"ClientVersion,omitempty" name:"ClientVersion"`
	// 生产者名称。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ProducerName *string `json:"ProducerName,omitempty" name:"ProducerName"`
	// 生产者ID。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ProducerId *string `json:"ProducerId,omitempty" name:"ProducerId"`
	// 消息平均大小(byte)。
	// 注意:此字段可能返回 null,表示取不到有效值。
	AverageMsgSize *string `json:"AverageMsgSize,omitempty" name:"AverageMsgSize"`
	// 生成速率(byte/秒)。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgThroughputIn *string `json:"MsgThroughputIn,omitempty" name:"MsgThroughputIn"`
}
    type Consumer ¶
type Consumer struct {
	// 消费者开始连接的时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConnectedSince *string `json:"ConnectedSince,omitempty" name:"ConnectedSince"`
	// 消费者地址。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumerAddr *string `json:"ConsumerAddr,omitempty" name:"ConsumerAddr"`
	// 消费者名称。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumerName *string `json:"ConsumerName,omitempty" name:"ConsumerName"`
	// 消费者版本。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ClientVersion *string `json:"ClientVersion,omitempty" name:"ClientVersion"`
}
    type ConsumersSchedule ¶
type ConsumersSchedule struct {
	// 当前分区id。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`
	// 消息数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	NumberOfEntries *uint64 `json:"NumberOfEntries,omitempty" name:"NumberOfEntries"`
	// 消息积压数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgBacklog *uint64 `json:"MsgBacklog,omitempty" name:"MsgBacklog"`
	// 消费者每秒分发消息的数量之和。
	MsgRateOut *string `json:"MsgRateOut,omitempty" name:"MsgRateOut"`
	// 消费者每秒消息的byte。
	MsgThroughputOut *string `json:"MsgThroughputOut,omitempty" name:"MsgThroughputOut"`
	// 超时丢弃比例。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRateExpired *string `json:"MsgRateExpired,omitempty" name:"MsgRateExpired"`
}
    type CreateEnvironmentRequest ¶
type CreateEnvironmentRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称,不支持中字以及除了短线和下划线外的特殊字符且不超过16个字符。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 未消费消息过期时间,单位:秒,最小60,最大1296000,(15天)。
	MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`
	// 说明,128个字符以内。
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}
    func NewCreateEnvironmentRequest ¶
func NewCreateEnvironmentRequest() (request *CreateEnvironmentRequest)
func (*CreateEnvironmentRequest) FromJsonString ¶
func (r *CreateEnvironmentRequest) FromJsonString(s string) error
func (*CreateEnvironmentRequest) ToJsonString ¶
func (r *CreateEnvironmentRequest) ToJsonString() string
type CreateEnvironmentResponse ¶
type CreateEnvironmentResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 环境(命名空间)名称。
		EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
		// 未消费消息过期时间,单位:秒。
		MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`
		// 说明,128个字符以内。
		// 注意:此字段可能返回 null,表示取不到有效值。
		Remark *string `json:"Remark,omitempty" name:"Remark"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewCreateEnvironmentResponse ¶
func NewCreateEnvironmentResponse() (response *CreateEnvironmentResponse)
func (*CreateEnvironmentResponse) FromJsonString ¶
func (r *CreateEnvironmentResponse) FromJsonString(s string) error
func (*CreateEnvironmentResponse) ToJsonString ¶
func (r *CreateEnvironmentResponse) ToJsonString() string
type CreateSubscriptionRequest ¶
type CreateSubscriptionRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名称。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 订阅者名称,不支持中字以及除了短线和下划线外的特殊字符且不超过150个字符。
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
	// 是否幂等创建,若否不允许创建同名的订阅关系。
	IsIdempotent *bool `json:"IsIdempotent,omitempty" name:"IsIdempotent"`
	// 备注,128个字符以内。
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}
    func NewCreateSubscriptionRequest ¶
func NewCreateSubscriptionRequest() (request *CreateSubscriptionRequest)
func (*CreateSubscriptionRequest) FromJsonString ¶
func (r *CreateSubscriptionRequest) FromJsonString(s string) error
func (*CreateSubscriptionRequest) ToJsonString ¶
func (r *CreateSubscriptionRequest) ToJsonString() string
type CreateSubscriptionResponse ¶
type CreateSubscriptionResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 创建结果。
		Result *bool `json:"Result,omitempty" name:"Result"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewCreateSubscriptionResponse ¶
func NewCreateSubscriptionResponse() (response *CreateSubscriptionResponse)
func (*CreateSubscriptionResponse) FromJsonString ¶
func (r *CreateSubscriptionResponse) FromJsonString(s string) error
func (*CreateSubscriptionResponse) ToJsonString ¶
func (r *CreateSubscriptionResponse) ToJsonString() string
type CreateTopicRequest ¶
type CreateTopicRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名,不支持中字以及除了短线和下划线外的特殊字符且不超过32个字符。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 0:非分区topic,无分区;非0:具体分区topic的分区数,最大不允许超过128。
	Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`
	// 0: 普通消息;
	// 1 :全局顺序消息;
	// 2 :局部顺序消息;
	// 3 :重试队列;
	// 4 :死信队列;
	// 5 :事务消息。
	TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`
	// 备注,128字符以内。
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}
    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 {
		// 环境(命名空间)名称。
		EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
		// 主题名。
		TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
		// 0:非分区topic,无分区;非0:具体分区topic的分区数。
		Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`
		// 备注,128字符以内。
		// 注意:此字段可能返回 null,表示取不到有效值。
		Remark *string `json:"Remark,omitempty" name:"Remark"`
		// 0: 普通消息;
		// 1 :全局顺序消息;
		// 2 :局部顺序消息;
		// 3 :重试队列;
		// 4 :死信队列;
		// 5 :事务消息。
		// 注意:此字段可能返回 null,表示取不到有效值。
		TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`
		// 唯一请求 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 DeleteEnvironmentsRequest ¶
type DeleteEnvironmentsRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)数组,每次最多删除20个。
	EnvironmentIds []*string `json:"EnvironmentIds,omitempty" name:"EnvironmentIds" list`
}
    func NewDeleteEnvironmentsRequest ¶
func NewDeleteEnvironmentsRequest() (request *DeleteEnvironmentsRequest)
func (*DeleteEnvironmentsRequest) FromJsonString ¶
func (r *DeleteEnvironmentsRequest) FromJsonString(s string) error
func (*DeleteEnvironmentsRequest) ToJsonString ¶
func (r *DeleteEnvironmentsRequest) ToJsonString() string
type DeleteEnvironmentsResponse ¶
type DeleteEnvironmentsResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 成功删除的环境(命名空间)数组。
		EnvironmentIds []*string `json:"EnvironmentIds,omitempty" name:"EnvironmentIds" list`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewDeleteEnvironmentsResponse ¶
func NewDeleteEnvironmentsResponse() (response *DeleteEnvironmentsResponse)
func (*DeleteEnvironmentsResponse) FromJsonString ¶
func (r *DeleteEnvironmentsResponse) FromJsonString(s string) error
func (*DeleteEnvironmentsResponse) ToJsonString ¶
func (r *DeleteEnvironmentsResponse) ToJsonString() string
type DeleteSubscriptionsRequest ¶
type DeleteSubscriptionsRequest struct {
	*tchttp.BaseRequest
	// 订阅关系集合,每次最多删除20个。
	SubscriptionTopicSets []*SubscriptionTopic `json:"SubscriptionTopicSets,omitempty" name:"SubscriptionTopicSets" list`
}
    func NewDeleteSubscriptionsRequest ¶
func NewDeleteSubscriptionsRequest() (request *DeleteSubscriptionsRequest)
func (*DeleteSubscriptionsRequest) FromJsonString ¶
func (r *DeleteSubscriptionsRequest) FromJsonString(s string) error
func (*DeleteSubscriptionsRequest) ToJsonString ¶
func (r *DeleteSubscriptionsRequest) ToJsonString() string
type DeleteSubscriptionsResponse ¶
type DeleteSubscriptionsResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 成功删除的订阅关系数组。
		SubscriptionTopicSets []*SubscriptionTopic `json:"SubscriptionTopicSets,omitempty" name:"SubscriptionTopicSets" list`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewDeleteSubscriptionsResponse ¶
func NewDeleteSubscriptionsResponse() (response *DeleteSubscriptionsResponse)
func (*DeleteSubscriptionsResponse) FromJsonString ¶
func (r *DeleteSubscriptionsResponse) FromJsonString(s string) error
func (*DeleteSubscriptionsResponse) ToJsonString ¶
func (r *DeleteSubscriptionsResponse) ToJsonString() string
type DeleteTopicsRequest ¶
type DeleteTopicsRequest struct {
	*tchttp.BaseRequest
	// 主题集合,每次最多删除20个。
	TopicSets []*TopicRecord `json:"TopicSets,omitempty" name:"TopicSets" list`
}
    func NewDeleteTopicsRequest ¶
func NewDeleteTopicsRequest() (request *DeleteTopicsRequest)
func (*DeleteTopicsRequest) FromJsonString ¶
func (r *DeleteTopicsRequest) FromJsonString(s string) error
func (*DeleteTopicsRequest) ToJsonString ¶
func (r *DeleteTopicsRequest) ToJsonString() string
type DeleteTopicsResponse ¶
type DeleteTopicsResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 被删除的主题数组。
		TopicSets []*TopicRecord `json:"TopicSets,omitempty" name:"TopicSets" list`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewDeleteTopicsResponse ¶
func NewDeleteTopicsResponse() (response *DeleteTopicsResponse)
func (*DeleteTopicsResponse) FromJsonString ¶
func (r *DeleteTopicsResponse) FromJsonString(s string) error
func (*DeleteTopicsResponse) ToJsonString ¶
func (r *DeleteTopicsResponse) ToJsonString() string
type DescribeEnvironmentAttributesRequest ¶
type DescribeEnvironmentAttributesRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
}
    func NewDescribeEnvironmentAttributesRequest ¶
func NewDescribeEnvironmentAttributesRequest() (request *DescribeEnvironmentAttributesRequest)
func (*DescribeEnvironmentAttributesRequest) FromJsonString ¶
func (r *DescribeEnvironmentAttributesRequest) FromJsonString(s string) error
func (*DescribeEnvironmentAttributesRequest) ToJsonString ¶
func (r *DescribeEnvironmentAttributesRequest) ToJsonString() string
type DescribeEnvironmentAttributesResponse ¶
type DescribeEnvironmentAttributesResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 未消费消息过期时间,单位:秒,最大1296000(15天)。
		MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`
		// 消费速率限制,单位:byte/秒,0:不限速。
		RateInByte *uint64 `json:"RateInByte,omitempty" name:"RateInByte"`
		// 消费速率限制,单位:个数/秒,0:不限速。
		RateInSize *uint64 `json:"RateInSize,omitempty" name:"RateInSize"`
		// 已消费消息保存策略,单位:小时,0:消费完马上删除。
		RetentionHours *uint64 `json:"RetentionHours,omitempty" name:"RetentionHours"`
		// 已消费消息保存策略,单位:G,0:消费完马上删除。
		RetentionSize *uint64 `json:"RetentionSize,omitempty" name:"RetentionSize"`
		// 环境(命名空间)名称。
		EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
		// 副本数。
		Replicas *uint64 `json:"Replicas,omitempty" name:"Replicas"`
		// 备注。
		Remark *string `json:"Remark,omitempty" name:"Remark"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewDescribeEnvironmentAttributesResponse ¶
func NewDescribeEnvironmentAttributesResponse() (response *DescribeEnvironmentAttributesResponse)
func (*DescribeEnvironmentAttributesResponse) FromJsonString ¶
func (r *DescribeEnvironmentAttributesResponse) FromJsonString(s string) error
func (*DescribeEnvironmentAttributesResponse) ToJsonString ¶
func (r *DescribeEnvironmentAttributesResponse) ToJsonString() string
type DescribeEnvironmentsRequest ¶
type DescribeEnvironmentsRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称,模糊搜索。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 起始下标,不填默认为0。
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`
	// 返回数量,不填则默认为10,最大值为20。
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`
}
    func NewDescribeEnvironmentsRequest ¶
func NewDescribeEnvironmentsRequest() (request *DescribeEnvironmentsRequest)
func (*DescribeEnvironmentsRequest) FromJsonString ¶
func (r *DescribeEnvironmentsRequest) FromJsonString(s string) error
func (*DescribeEnvironmentsRequest) ToJsonString ¶
func (r *DescribeEnvironmentsRequest) ToJsonString() string
type DescribeEnvironmentsResponse ¶
type DescribeEnvironmentsResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 环境(命名空间)记录数。
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`
		// 环境(命名空间)集合数组。
		EnvironmentSet []*Environment `json:"EnvironmentSet,omitempty" name:"EnvironmentSet" list`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewDescribeEnvironmentsResponse ¶
func NewDescribeEnvironmentsResponse() (response *DescribeEnvironmentsResponse)
func (*DescribeEnvironmentsResponse) FromJsonString ¶
func (r *DescribeEnvironmentsResponse) FromJsonString(s string) error
func (*DescribeEnvironmentsResponse) ToJsonString ¶
func (r *DescribeEnvironmentsResponse) ToJsonString() string
type DescribeProducersRequest ¶
type DescribeProducersRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 起始下标,不填默认为0。
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`
	// 返回数量,不填则默认为10,最大值为20。
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`
	// 生产者名称,模糊匹配。
	ProducerName *string `json:"ProducerName,omitempty" name:"ProducerName"`
}
    func NewDescribeProducersRequest ¶
func NewDescribeProducersRequest() (request *DescribeProducersRequest)
func (*DescribeProducersRequest) FromJsonString ¶
func (r *DescribeProducersRequest) FromJsonString(s string) error
func (*DescribeProducersRequest) ToJsonString ¶
func (r *DescribeProducersRequest) ToJsonString() string
type DescribeProducersResponse ¶
type DescribeProducersResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 生产者集合数组。
		ProducerSets []*Producer `json:"ProducerSets,omitempty" name:"ProducerSets" list`
		// 记录总数。
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewDescribeProducersResponse ¶
func NewDescribeProducersResponse() (response *DescribeProducersResponse)
func (*DescribeProducersResponse) FromJsonString ¶
func (r *DescribeProducersResponse) FromJsonString(s string) error
func (*DescribeProducersResponse) ToJsonString ¶
func (r *DescribeProducersResponse) ToJsonString() string
type DescribeSubscriptionsRequest ¶
type DescribeSubscriptionsRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名称。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 起始下标,不填默认为0。
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`
	// 返回数量,不填则默认为10,最大值为20。
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`
	// 订阅者名称,模糊匹配。
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
	// 数据过滤条件。
	Filters []*FilterSubscription `json:"Filters,omitempty" name:"Filters" list`
}
    func NewDescribeSubscriptionsRequest ¶
func NewDescribeSubscriptionsRequest() (request *DescribeSubscriptionsRequest)
func (*DescribeSubscriptionsRequest) FromJsonString ¶
func (r *DescribeSubscriptionsRequest) FromJsonString(s string) error
func (*DescribeSubscriptionsRequest) ToJsonString ¶
func (r *DescribeSubscriptionsRequest) ToJsonString() string
type DescribeSubscriptionsResponse ¶
type DescribeSubscriptionsResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 订阅者集合数组。
		SubscriptionSets []*Subscription `json:"SubscriptionSets,omitempty" name:"SubscriptionSets" list`
		// 数量。
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewDescribeSubscriptionsResponse ¶
func NewDescribeSubscriptionsResponse() (response *DescribeSubscriptionsResponse)
func (*DescribeSubscriptionsResponse) FromJsonString ¶
func (r *DescribeSubscriptionsResponse) FromJsonString(s string) error
func (*DescribeSubscriptionsResponse) ToJsonString ¶
func (r *DescribeSubscriptionsResponse) ToJsonString() string
type DescribeTopicsRequest ¶
type DescribeTopicsRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名模糊匹配。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 起始下标,不填默认为0。
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`
	// 返回数量,不填则默认为10,最大值为20。
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`
	// topic类型描述:
	// 0:普通消息;
	// 1:全局顺序消息;
	// 2:局部顺序消息;
	// 3:重试队列;
	// 4:死信队列;
	// 5:事务消息。
	TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`
}
    func NewDescribeTopicsRequest ¶
func NewDescribeTopicsRequest() (request *DescribeTopicsRequest)
func (*DescribeTopicsRequest) FromJsonString ¶
func (r *DescribeTopicsRequest) FromJsonString(s string) error
func (*DescribeTopicsRequest) ToJsonString ¶
func (r *DescribeTopicsRequest) ToJsonString() string
type DescribeTopicsResponse ¶
type DescribeTopicsResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 主题集合数组。
		TopicSets []*Topic `json:"TopicSets,omitempty" name:"TopicSets" list`
		// 主题数量。
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewDescribeTopicsResponse ¶
func NewDescribeTopicsResponse() (response *DescribeTopicsResponse)
func (*DescribeTopicsResponse) FromJsonString ¶
func (r *DescribeTopicsResponse) FromJsonString(s string) error
func (*DescribeTopicsResponse) ToJsonString ¶
func (r *DescribeTopicsResponse) ToJsonString() string
type Environment ¶
type Environment struct {
	// 环境(命名空间)名称
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 说明
	Remark *string `json:"Remark,omitempty" name:"Remark"`
	// 未消费消息过期时间,单位:秒,最大1296000(15天)
	MsgTTL *int64 `json:"MsgTTL,omitempty" name:"MsgTTL"`
	// 创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`
	// 最近修改时间
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`
}
    type FilterSubscription ¶
type FilterSubscription struct {
	// 是否仅展示包含真实消费者的订阅。
	ConsumerHasCount *bool `json:"ConsumerHasCount,omitempty" name:"ConsumerHasCount"`
	// 是否仅展示消息堆积的订阅。
	ConsumerHasBacklog *bool `json:"ConsumerHasBacklog,omitempty" name:"ConsumerHasBacklog"`
	// 是否仅展示存在消息超期丢弃的订阅。
	ConsumerHasExpired *bool `json:"ConsumerHasExpired,omitempty" name:"ConsumerHasExpired"`
}
    type ModifyEnvironmentAttributesRequest ¶
type ModifyEnvironmentAttributesRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 未消费消息过期时间,单位:秒,最大1296000。
	MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`
	// 备注,字符串最长不超过128。
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}
    func NewModifyEnvironmentAttributesRequest ¶
func NewModifyEnvironmentAttributesRequest() (request *ModifyEnvironmentAttributesRequest)
func (*ModifyEnvironmentAttributesRequest) FromJsonString ¶
func (r *ModifyEnvironmentAttributesRequest) FromJsonString(s string) error
func (*ModifyEnvironmentAttributesRequest) ToJsonString ¶
func (r *ModifyEnvironmentAttributesRequest) ToJsonString() string
type ModifyEnvironmentAttributesResponse ¶
type ModifyEnvironmentAttributesResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 环境(命名空间)名称。
		EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
		// 未消费消息过期时间,单位:秒。
		MsgTTL *uint64 `json:"MsgTTL,omitempty" name:"MsgTTL"`
		// 备注,字符串最长不超过128。
		// 注意:此字段可能返回 null,表示取不到有效值。
		Remark *string `json:"Remark,omitempty" name:"Remark"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewModifyEnvironmentAttributesResponse ¶
func NewModifyEnvironmentAttributesResponse() (response *ModifyEnvironmentAttributesResponse)
func (*ModifyEnvironmentAttributesResponse) FromJsonString ¶
func (r *ModifyEnvironmentAttributesResponse) FromJsonString(s string) error
func (*ModifyEnvironmentAttributesResponse) ToJsonString ¶
func (r *ModifyEnvironmentAttributesResponse) ToJsonString() string
type ModifyTopicRequest ¶
type ModifyTopicRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 分区数,必须大于或者等于原分区数,若想维持原分区数请输入原数目,修改分区数仅对非全局顺序消息起效果,不允许超过128个分区。
	Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`
	// 备注,128字符以内。
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}
    func NewModifyTopicRequest ¶
func NewModifyTopicRequest() (request *ModifyTopicRequest)
func (*ModifyTopicRequest) FromJsonString ¶
func (r *ModifyTopicRequest) FromJsonString(s string) error
func (*ModifyTopicRequest) ToJsonString ¶
func (r *ModifyTopicRequest) ToJsonString() string
type ModifyTopicResponse ¶
type ModifyTopicResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 分区数
		Partitions *uint64 `json:"Partitions,omitempty" name:"Partitions"`
		// 备注,128字符以内。
		Remark *string `json:"Remark,omitempty" name:"Remark"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewModifyTopicResponse ¶
func NewModifyTopicResponse() (response *ModifyTopicResponse)
func (*ModifyTopicResponse) FromJsonString ¶
func (r *ModifyTopicResponse) FromJsonString(s string) error
func (*ModifyTopicResponse) ToJsonString ¶
func (r *ModifyTopicResponse) ToJsonString() string
type PartitionsTopic ¶
type PartitionsTopic struct {
	// 最后一次间隔内发布消息的平均byte大小。
	// 注意:此字段可能返回 null,表示取不到有效值。
	AverageMsgSize *string `json:"AverageMsgSize,omitempty" name:"AverageMsgSize"`
	// 消费者数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumerCount *string `json:"ConsumerCount,omitempty" name:"ConsumerCount"`
	// 被记录下来的消息总数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	LastConfirmedEntry *string `json:"LastConfirmedEntry,omitempty" name:"LastConfirmedEntry"`
	// 最后一个ledger创建的时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	LastLedgerCreatedTimestamp *string `json:"LastLedgerCreatedTimestamp,omitempty" name:"LastLedgerCreatedTimestamp"`
	// 本地和复制的发布者每秒发布消息的速率。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRateIn *string `json:"MsgRateIn,omitempty" name:"MsgRateIn"`
	// 本地和复制的消费者每秒分发消息的数量之和。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRateOut *string `json:"MsgRateOut,omitempty" name:"MsgRateOut"`
	// 本地和复制的发布者每秒发布消息的byte。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgThroughputIn *string `json:"MsgThroughputIn,omitempty" name:"MsgThroughputIn"`
	// 本地和复制的消费者每秒分发消息的byte。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgThroughputOut *string `json:"MsgThroughputOut,omitempty" name:"MsgThroughputOut"`
	// 被记录下来的消息总数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	NumberOfEntries *string `json:"NumberOfEntries,omitempty" name:"NumberOfEntries"`
	// 子分区id。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Partitions *int64 `json:"Partitions,omitempty" name:"Partitions"`
	// 生产者数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ProducerCount *string `json:"ProducerCount,omitempty" name:"ProducerCount"`
	// 以byte计算的所有消息存储总量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TotalSize *string `json:"TotalSize,omitempty" name:"TotalSize"`
	// topic类型描述。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`
}
    type Producer ¶
type Producer struct {
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名称。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 连接数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	CountConnect *int64 `json:"CountConnect,omitempty" name:"CountConnect"`
	// 连接集合。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConnectionSets []*Connection `json:"ConnectionSets,omitempty" name:"ConnectionSets" list`
}
    type ResetMsgSubOffsetByTimestampRequest ¶
type ResetMsgSubOffsetByTimestampRequest struct {
	*tchttp.BaseRequest
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名称。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 订阅者名称。
	Subscription *string `json:"Subscription,omitempty" name:"Subscription"`
	// 时间戳,精确到毫秒。
	ToTimestamp *uint64 `json:"ToTimestamp,omitempty" name:"ToTimestamp"`
}
    func NewResetMsgSubOffsetByTimestampRequest ¶
func NewResetMsgSubOffsetByTimestampRequest() (request *ResetMsgSubOffsetByTimestampRequest)
func (*ResetMsgSubOffsetByTimestampRequest) FromJsonString ¶
func (r *ResetMsgSubOffsetByTimestampRequest) FromJsonString(s string) error
func (*ResetMsgSubOffsetByTimestampRequest) ToJsonString ¶
func (r *ResetMsgSubOffsetByTimestampRequest) ToJsonString() string
type ResetMsgSubOffsetByTimestampResponse ¶
type ResetMsgSubOffsetByTimestampResponse struct {
	*tchttp.BaseResponse
	Response *struct {
		// 结果。
		// 注意:此字段可能返回 null,表示取不到有效值。
		Result *bool `json:"Result,omitempty" name:"Result"`
		// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}
    func NewResetMsgSubOffsetByTimestampResponse ¶
func NewResetMsgSubOffsetByTimestampResponse() (response *ResetMsgSubOffsetByTimestampResponse)
func (*ResetMsgSubOffsetByTimestampResponse) FromJsonString ¶
func (r *ResetMsgSubOffsetByTimestampResponse) FromJsonString(s string) error
func (*ResetMsgSubOffsetByTimestampResponse) ToJsonString ¶
func (r *ResetMsgSubOffsetByTimestampResponse) ToJsonString() string
type Subscription ¶
type Subscription struct {
	// 主题名称。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 环境(命名空间)名称。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 消费者开始连接的时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConnectedSince *string `json:"ConnectedSince,omitempty" name:"ConnectedSince"`
	// 消费者地址。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumerAddr *string `json:"ConsumerAddr,omitempty" name:"ConsumerAddr"`
	// 消费者数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumerCount *string `json:"ConsumerCount,omitempty" name:"ConsumerCount"`
	// 消费者名称。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumerName *string `json:"ConsumerName,omitempty" name:"ConsumerName"`
	// 堆积的消息数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgBacklog *string `json:"MsgBacklog,omitempty" name:"MsgBacklog"`
	// 于TTL,此订阅下没有被发送而是被丢弃的比例。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRateExpired *string `json:"MsgRateExpired,omitempty" name:"MsgRateExpired"`
	// 消费者每秒分发消息的数量之和。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRateOut *string `json:"MsgRateOut,omitempty" name:"MsgRateOut"`
	// 消费者每秒消息的byte。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgThroughputOut *string `json:"MsgThroughputOut,omitempty" name:"MsgThroughputOut"`
	// 订阅名称。
	// 注意:此字段可能返回 null,表示取不到有效值。
	SubscriptionName *string `json:"SubscriptionName,omitempty" name:"SubscriptionName"`
	// 消费者集合。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumerSets []*Consumer `json:"ConsumerSets,omitempty" name:"ConsumerSets" list`
	// 是否在线。
	// 注意:此字段可能返回 null,表示取不到有效值。
	IsOnline *bool `json:"IsOnline,omitempty" name:"IsOnline"`
	// 消费进度集合。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumersScheduleSets []*ConsumersSchedule `json:"ConsumersScheduleSets,omitempty" name:"ConsumersScheduleSets" list`
	// 备注。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`
	// 创建时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`
	// 最近修改时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`
}
    type SubscriptionTopic ¶
type Topic ¶
type Topic struct {
	// 最后一次间隔内发布消息的平均byte大小。
	// 注意:此字段可能返回 null,表示取不到有效值。
	AverageMsgSize *string `json:"AverageMsgSize,omitempty" name:"AverageMsgSize"`
	// 消费者数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConsumerCount *string `json:"ConsumerCount,omitempty" name:"ConsumerCount"`
	// 被记录下来的消息总数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	LastConfirmedEntry *string `json:"LastConfirmedEntry,omitempty" name:"LastConfirmedEntry"`
	// 最后一个ledger创建的时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	LastLedgerCreatedTimestamp *string `json:"LastLedgerCreatedTimestamp,omitempty" name:"LastLedgerCreatedTimestamp"`
	// 本地和复制的发布者每秒发布消息的速率。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRateIn *string `json:"MsgRateIn,omitempty" name:"MsgRateIn"`
	// 本地和复制的消费者每秒分发消息的数量之和。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgRateOut *string `json:"MsgRateOut,omitempty" name:"MsgRateOut"`
	// 本地和复制的发布者每秒发布消息的byte。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgThroughputIn *string `json:"MsgThroughputIn,omitempty" name:"MsgThroughputIn"`
	// 本地和复制的消费者每秒分发消息的byte。
	// 注意:此字段可能返回 null,表示取不到有效值。
	MsgThroughputOut *string `json:"MsgThroughputOut,omitempty" name:"MsgThroughputOut"`
	// 被记录下来的消息总数。
	// 注意:此字段可能返回 null,表示取不到有效值。
	NumberOfEntries *string `json:"NumberOfEntries,omitempty" name:"NumberOfEntries"`
	// 分区数<=0:topic下无子分区。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Partitions *int64 `json:"Partitions,omitempty" name:"Partitions"`
	// 生产者数量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	ProducerCount *string `json:"ProducerCount,omitempty" name:"ProducerCount"`
	// 以byte计算的所有消息存储总量。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TotalSize *string `json:"TotalSize,omitempty" name:"TotalSize"`
	// 分区topic里面的子分区。
	// 注意:此字段可能返回 null,表示取不到有效值。
	SubTopicSets []*PartitionsTopic `json:"SubTopicSets,omitempty" name:"SubTopicSets" list`
	// topic类型描述:
	// 0:普通消息;
	// 1:全局顺序消息;
	// 2:局部顺序消息;
	// 3:重试队列;
	// 4:死信队列;
	// 5:事务消息。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TopicType *uint64 `json:"TopicType,omitempty" name:"TopicType"`
	// 环境(命名空间)名称。
	// 注意:此字段可能返回 null,表示取不到有效值。
	EnvironmentId *string `json:"EnvironmentId,omitempty" name:"EnvironmentId"`
	// 主题名称。
	// 注意:此字段可能返回 null,表示取不到有效值。
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
	// 说明,128个字符以内。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`
	// 创建时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`
	// 最近修改时间。
	// 注意:此字段可能返回 null,表示取不到有效值。
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`
}
    type TopicRecord ¶
 Click to show internal directories. 
   Click to hide internal directories.