| | |
| | | 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 |
| | |
| | | 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 { |
| | |
| | | message MsgRegister |
| | | { |
| | | ProcInfo proc = 1; |
| | | } |
| | | |
| | | message MsgRegisterRPC |
| | | { |
| | | repeated bytes topics = 1; |
| | | repeated BHAddress addrs = 2; |
| | | } |
| | | |
| | | message MsgHeartbeat |