| | |
| | | uint64 ssn_id = 5; // node mq id |
| | | bytes proc_id = 6; |
| | | bytes topic = 7; // for request route |
| | | BHAddress dest = 8; // other host |
| | | } |
| | | |
| | | |
| | |
| | | // kMsgTypeUnsubscribeReply = 25; |
| | | kMsgTypeUnregister = 26; |
| | | // kMsgTypeUnregisterReply = 27; |
| | | kMsgTypeQueryProc = 28; |
| | | kMsgTypeQueryProcReply = 29; |
| | | |
| | | } |
| | | |
| | | message MsgSubscribe { |
| | | MsgTopicList topics = 1; |
| | | bool network = 2; |
| | | } |
| | | message MsgUnsubscribe { |
| | | MsgTopicList topics = 1; |
| | | bool network = 2; |
| | | } |
| | | message MsgRegisterRPC { |
| | | MsgTopicList topics = 1; |
| | | } |
| | | |
| | | message MsgProcInit{ } // proc_id is in header. |
| | | 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 { |