aaron-ai commented on code in PR #31:
URL: https://github.com/apache/rocketmq-apis/pull/31#discussion_r871939119
##########
apache/rocketmq/v2/admin.proto:
##########
@@ -38,6 +43,109 @@ message ChangeLogLevelRequest {
message ChangeLogLevelResponse { string remark = 1; }
+message DescribeTopicStatusRequest {
+ optional string instance_id = 1;
+ Resource topic = 2;
+}
+
+message DescribeTopicStatusResponse {
+ Status status = 1;
+ MessageType topic_message_type = 2;
+ optional string description = 3;
+ optional google.protobuf.Timestamp create_timestamp = 4;
+ map<string, string> tags = 5;
+}
+
+message DescribeSubscriptionRequest {
+ optional string instance_id = 1;
+ oneof search_resource {
+ Resource topic = 2;
+ Resource group = 3;
+ }
+}
+
+message DescribeSubscriptionResponse {
+ message SubscriptionInfo {
+ Resource group = 1;
+ Resource topic = 2;
+ FilterExpression expression = 3;
+ bool online = 4;
+ google.protobuf.Timestamp last_update_timestamp = 5;
+ }
+ Status status = 1;
+ repeated SubscriptionInfo subscription_info = 2;
+}
+
+message DescribeGroupAccumulationRequest {
+ optional string instance_id = 1;
+ Resource group = 2;
+ repeated Resource topics = 3;
+}
+
+message DescribeGroupAccumulationResponse {
+ Status status = 1;
+ int64 inflight_messages = 2;
+ int64 ready_messages = 3;
+ int64 accumulation = 4;
+ google.protobuf.Duration deliver_delay_time = 5;
+}
+
+message DescribeConsumerStatusRequest {
+ optional string instance_id = 1;
+ Resource group = 2;
+}
+
+message DescribeConsumerStatusResponse {
+ message ClientInfo {
+ string client_id = 1;
+ string version = 2;
+ string language = 3;
Review Comment:
Maybe we should extract an enumeration to describe language here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
