| | |
| | | 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) |
| | |
| | | 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; |
| | |
| | | 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; |
| | | } |
| | | } |