lichao
2021-04-20 ca319178f45ce6256aed7913565d445571f6db22
proto/source/bhome_msg.proto
@@ -1,11 +1,12 @@
syntax = "proto3";
option optimize_for = LITE_RUNTIME;
option go_package="./bhome_msg";
// import "google/protobuf/descriptor.proto";
import "bhome_msg_api.proto";
import "error_msg.proto";
package bhome.msg;
package bhome_msg;
// message format : head_len(4) + head(BHMsgHead) + body_len(4) + body(variable types)
@@ -19,22 +20,6 @@
   bytes topic = 6; // for request route
}
message MsgRequest {
   MsgType type = 1;
   // oneof body;
}
message MsgReply {
   ErrorMsg err_msg = 1;
   // oneof reply
}
message BHMsgBody {
   oneof reqrep {
      MsgRequest request = 1;
      MsgReply reply = 2;
   }
}
enum MsgType {
   kMsgTypeInvalid = 0;
@@ -76,3 +61,24 @@
   rpc Query (MsgQueryTopic) returns (MsgQueryTopicReply);
   rpc Request (MsgRequestTopic) returns (MsgQueryTopicReply);
}
message MsgRequest {
   // oneof body;
   oneof request {
      MsgRegister register = 1;
      MsgRequestTopic topic_request = 2;
      MsgQueryTopic topic_query = 3;
   }
}
message MsgReply {
   ErrorMsg err_msg = 1;
   // oneof reply
}
message BHMsgBody {
   oneof reqrep {
      MsgRequest request = 1;
      MsgReply reply = 2;
   }
}