| | |
| | | kMsgTypePublish = 3; |
| | | kMsgTypeSubscribe = 4; |
| | | kMsgTypeUnsubscribe = 5; |
| | | kMsgTypeQueryTopic = 6; |
| | | kMsgTypeQueryTopicReply = 7; |
| | | |
| | | kMsgTypeProcQueryTopic = 6; |
| | | kMsgTypeProcQueryTopicReply = 7; |
| | | kMsgTypeProcRegisterTopics = 8; |
| | | kMsgTypeProcHeartbeat = 9; |
| | | } |
| | | |
| | | message DataPub { |
| | |
| | | bytes data = 1; |
| | | } |
| | | |
| | | message DataQueryTopic { |
| | | message ProcInfo |
| | | { |
| | | bytes name = 1; |
| | | bytes info = 2; |
| | | } |
| | | |
| | | message DataProcRegister |
| | | { |
| | | ProcInfo proc = 1; |
| | | repeated bytes topics = 2; |
| | | } |
| | | |
| | | message DataProcHeartbeat |
| | | { |
| | | ProcInfo proc = 1; |
| | | } |
| | | |
| | | message DataProcQueryTopic { |
| | | bytes topic = 1; |
| | | } |
| | | |
| | | message DataQueryTopicReply { |
| | | message DataProcQueryTopicReply { |
| | | BHAddress address = 1; |
| | | } |