lichao
2021-04-21 ad4f3dcedab29a690c5eedbb08ba1b393917db0b
proto/source/bhome_msg_api.proto
@@ -1,15 +1,16 @@
syntax = "proto3";
option optimize_for = LITE_RUNTIME;
option go_package="./bhome_msg";
// public messages
import "error_msg.proto";
package bhome.msg;
package bhome_msg;
message BHAddress {
   bytes mq_id = 1; // mqid, uuid
   // bytes ip = 2;   //
   // int32 port = 3;
   bytes ip = 2;   //
   int32 port = 3;
}
message ProcInfo
@@ -20,16 +21,14 @@
   bytes private_info = 4; 
}
message MsgTopicList {
   repeated bytes topic_list = 1;
}
message MsgPublish {
   bytes topic = 1;
   bytes data = 2; 
}
message MsgSubscribe {
   repeated bytes topics = 1;
}
message MsgUnsubscribe {
   repeated bytes topics = 1;
}
message MsgCommonReply {
@@ -49,11 +48,7 @@
message MsgRegister
{
   ProcInfo proc = 1;
}
message MsgRegisterRPC
{
   repeated bytes topics = 1;
   repeated BHAddress addrs = 2;
}
message MsgHeartbeat