models

Documentation

Index

• type AccessPoint
• type ConsumeInfo
• type ConsumerInfoDetail
• type DeadLetter
• type DeadLetterNumber
• type Message
• type MessageTraceInfo
• type Permission
• type ProduceInfo
• type Queue
• type Subscription
• type Tag
• type Topic
• type TopicConfig
• type TopicRouteInfo
• type TopicWrapper

Types

type AccessPoint

type AccessPoint struct {

	/* sdk接入点 (Optional) */
	SdkAddress string `json:"sdkAddress"`

	/* http接入点 (Optional) */
	HttpAddress string `json:"httpAddress"`
}

type ConsumeInfo

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

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 DeadLetter struct {

	/* id (Optional) */
	MessageId string `json:"messageId"`

	/* 过期时间 (Optional) */
	ExpireTime string `json:"expireTime"`
}

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

type MessageTraceInfo struct {

	/* 生产消息详情 (Optional) */
	ProduceInfo ProduceInfo `json:"produceInfo"`

	/* 消费消息详情 (Optional) */
	ConsumeInfoList []ConsumeInfo `json:"consumeInfoList"`
}

type Permission

type Permission struct {

	/* userId (Optional) */
	UserId string `json:"userId"`

	/* permission, [SUB, PUB, PUBSUB] (Optional) */
	Permission string `json:"permission"`
}

type ProduceInfo

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 Queue

type Queue struct {

	/*  (Optional) */
	QueueId int `json:"queueId"`

	/*  (Optional) */
	QueuePermission string `json:"queuePermission"`
}

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 Tag

type Tag struct {

	/* 标签的键 (Optional) */
	Key string `json:"key"`

	/* 标签的值 (Optional) */
	Value string `json:"value"`
}

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 TopicConfig struct {

	/* 消息最大长度 (Optional) */
	MaxMessageSizeKB int `json:"maxMessageSizeKB"`

	/* tps (Optional) */
	Threshold int `json:"threshold"`

	/* topicPermission (Optional) */
	TopicPermission string `json:"topicPermission"`

	/* topicType (Optional) */
	TopicType string `json:"topicType"`
}

type TopicRouteInfo

type TopicRouteInfo struct {

	/*  (Optional) */
	BrokerAddress string `json:"brokerAddress"`

	/*  (Optional) */
	Queues []Queue `json:"queues"`
}

type TopicWrapper

type TopicWrapper struct {

	/*  (Optional) */
	Topic Topic `json:"topic"`

	/*  (Optional) */
	RouteInfos []TopicRouteInfo `json:"routeInfos"`
}