lichao
2021-05-19 981ca0fa022524fd04af988bc798f2d697d31548
proto/source/bhome_msg.proto
@@ -16,8 +16,9 @@
   repeated BHAddress route = 2; // for reply and proxy.
   int64 timestamp = 3;
   int32 type = 4;
   bytes proc_id = 5;
   bytes topic = 6; // for request route
   uint64 ssn_id = 5; // node mq id
   bytes proc_id = 6;
   bytes topic = 7; // for request route
}
@@ -27,6 +28,8 @@
   kMsgTypeCommonReply = 2;
   kMsgTypeProcInit = 8;
   kMsgTypeProcInitReply = 9;
   kMsgTypeRegister= 10;
   // kMsgTypeRegisterReply= 11;
   kMsgTypeHeartbeat = 12;
@@ -44,6 +47,8 @@
   // kMsgTypeSubscribeReply = 23;
   kMsgTypeUnsubscribe = 24;
   // kMsgTypeUnsubscribeReply = 25;
   kMsgTypeUnregister = 26;
   // kMsgTypeUnregisterReply = 27;
}
@@ -57,6 +62,16 @@
   MsgTopicList topics = 1;
}
message MsgProcInit{
   int32 extra_mq_num = 1;
} // proc_id is in header.
message MsgProcInitReply {
   ErrorMsg errmsg = 1;
   int32 proc_index = 2;
   repeated BHAddress extra_mqs = 3;
}
service TopicRPC {
   rpc Query (MsgQueryTopic) returns (MsgQueryTopicReply);
   rpc Request (MsgRequestTopic) returns (MsgQueryTopicReply);