Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AccessPoint ¶
type ConsumeInfo ¶ added in v1.13.0
type ConsumeInfo struct {
/* 消费组名称 (Optional) */
ConsumerGroupId string `json:"consumerGroupId"`
/* 消费状态[SUCCESS,UNCONSUMED,FAILED_RETRY,ALL_FAILED,UNKNOWN] (Optional) */
MessageConsumeStatus string `json:"messageConsumeStatus"`
/* 消费成功次数 (Optional) */
SuccessTimes int `json:"successTimes"`
/* 消费失败次数 (Optional) */
FailedTimes int `json:"failedTimes"`
/* 消费组下面消费者详情 (Optional) */
ConsumerInfoDetailList []ConsumerInfoDetail `json:"consumerInfoDetailList"`
}
type ConsumerInfoDetail ¶ added in v1.13.0
type ConsumerInfoDetail struct {
/* 消费者IP地址 (Optional) */
ConsumerIp string `json:"consumerIp"`
/* 消费时间戳(millionSecond) (Optional) */
TimeStamp int `json:"timeStamp"`
/* 消费耗时(second) (Optional) */
CostTime int `json:"costTime"`
/* 第几次消费 (Optional) */
ConsumeTimes int `json:"consumeTimes"`
/* 消费状态[SUCCESS,FAILED_WITHOUT_RESULT,FAILED_WITH_RESULT] (Optional) */
ConsumerStatus string `json:"consumerStatus"`
}
type DeadLetter ¶
type DeadLetterNumber ¶
type DeadLetterNumber struct {
/* topic的编号 (Optional) */
TopicId string `json:"topicId"`
/* topic名称 (Optional) */
TopicName string `json:"topicName"`
/* consumerGroupId (Optional) */
ConsumerGroupId string `json:"consumerGroupId"`
/* 死信队列数 (Optional) */
DeadLetterNumber int `json:"deadLetterNumber"`
}
type Message ¶
type Message struct {
/* 消息id (Optional) */
MessageId string `json:"messageId"`
/* 内容 (Optional) */
Body string `json:"body"`
/* tag以逗号隔开 (Optional) */
Tags string `json:"tags"`
/* 用户设置的属性json字符串 (Optional) */
Properties string `json:"properties"`
/* 消息的存储时间 (Optional) */
StoreTime int `json:"storeTime"`
}
type MessageTraceInfo ¶ added in v1.13.0
type MessageTraceInfo struct {
/* 生产消息详情 (Optional) */
ProduceInfo ProduceInfo `json:"produceInfo"`
/* 消费消息详情 (Optional) */
ConsumeInfoList []ConsumeInfo `json:"consumeInfoList"`
}
type Permission ¶
type ProduceInfo ¶ added in v1.13.0
type ProduceInfo struct {
/* 生产者地址 (Optional) */
Address string `json:"address"`
/* 发送时间戳(millionSecond) (Optional) */
TimeStamp int `json:"timeStamp"`
/* 发送耗时(millionSecond) (Optional) */
CostTime int `json:"costTime"`
/* 发送状态[SUCCESS_NORMAL,FAILED,SUCCESS_DELAY] (Optional) */
MessageSendStatus string `json:"messageSendStatus"`
/* 延时消息的延迟时间(second) (Optional) */
DelayTime int `json:"delayTime"`
}
type Subscription ¶
type Subscription struct {
/* consumerGroupId (Optional) */
ConsumerGroupId string `json:"consumerGroupId"`
/* endPoint (Optional) */
EndPoint string `json:"endPoint"`
/* messageInvisibleTimeInSeconds (Optional) */
MessageInvisibleTimeInSeconds int `json:"messageInvisibleTimeInSeconds"`
/* subscriptionType (Optional) */
SubscriptionType string `json:"subscriptionType"`
/* tags (Optional) */
Tags []string `json:"tags"`
/* 是否开启死信队列 (Optional) */
DlqEnable bool `json:"dlqEnable"`
/* 最大重试次数 (Optional) */
MaxRetryTimes int `json:"maxRetryTimes"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 最后更新时间 (Optional) */
LastUpdateTime string `json:"lastUpdateTime"`
/* 在线consumer个数 (Optional) */
ConsumerNumbers int `json:"consumerNumbers"`
}
type Topic ¶
type Topic struct {
/* topic Id (Optional) */
TopicId string `json:"topicId"`
/* topic名称 (Optional) */
TopicName string `json:"topicName"`
/* 描述 (Optional) */
Description string `json:"description"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
LastUpdateTime string `json:"lastUpdateTime"`
/* topicStatus (Optional) */
TopicStatus string `json:"topicStatus"`
/* 自己创建的订阅数 (Optional) */
SubscriptionCount int `json:"subscriptionCount"`
/* 消息生命周期时长小时 (Optional) */
MessageLifeTimeInHours int `json:"messageLifeTimeInHours"`
/* 配置信息 (Optional) */
TopicConfig TopicConfig `json:"topicConfig"`
/* 是否是自己的topic (Optional) */
Own bool `json:"own"`
/* 被授权的权限[PUB,SUB,PUBSUB,READ_ONLY,ADMIN] (Optional) */
AuthorizedPermission string `json:"authorizedPermission"`
/* 标签信息 (Optional) */
Tags []Tag `json:"tags"`
}
type TopicConfig ¶
type TopicRouteInfo ¶ added in v1.13.0
type TopicWrapper ¶ added in v1.13.0
type TopicWrapper struct {
/* (Optional) */
Topic Topic `json:"topic"`
/* (Optional) */
RouteInfos []TopicRouteInfo `json:"routeInfos"`
}
Click to show internal directories.
Click to hide internal directories.