| | |
| | | package bhome_msg; |
| | | |
| | | message BHAddress { |
| | | bytes mq_id = 1; // mqid, uuid |
| | | bytes ip = 2; // |
| | | int32 port = 3; |
| | | uint64 mq_id = 1; |
| | | int64 abs_addr = 2; |
| | | bytes ip = 3; |
| | | int32 port = 4; |
| | | } |
| | | |
| | | message ProcInfo |
| | |
| | | message MsgRegister |
| | | { |
| | | ProcInfo proc = 1; |
| | | repeated BHAddress addrs = 2; |
| | | } |
| | | |
| | | message MsgUnregister |
| | | { |
| | | ProcInfo proc = 1; |
| | | } |
| | | |
| | | message MsgHeartbeat |
| | |
| | | |
| | | message MsgQueryTopicReply { |
| | | ErrorMsg errmsg = 1; |
| | | BHAddress address = 2; |
| | | |
| | | message BHNodeAddress { |
| | | bytes proc_id = 1; |
| | | BHAddress addr = 2; |
| | | } |
| | | repeated BHNodeAddress node_address = 2; |
| | | } |
| | | |
| | | message MsgQueryProc { |
| | | bytes proc_id = 1; |
| | | } |
| | | |
| | | message MsgQueryProcReply { |
| | | ErrorMsg errmsg = 1; |
| | | repeated ProcInfo proc = 2; |
| | | } |