From ca319178f45ce6256aed7913565d445571f6db22 Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期二, 20 四月 2021 11:04:07 +0800 Subject: [PATCH] add go api, wrap C api, not finished. --- proto/source/bhome_msg.proto | 40 +++++++++++++++++++++++----------------- 1 files changed, 23 insertions(+), 17 deletions(-) diff --git a/proto/source/bhome_msg.proto b/proto/source/bhome_msg.proto index 11ff5a2..aabe372 100644 --- a/proto/source/bhome_msg.proto +++ b/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; + } +} -- Gitblit v1.8.0