syntax = "proto3";
|
option optimize_for = LITE_RUNTIME;
|
option go_package="./bhome_msg";
|
|
// public messages
|
import "error_msg.proto";
|
|
package bhome_msg;
|
|
message BHAddress {
|
uint64 mq_id = 1;
|
int64 abs_addr = 2;
|
bytes ip = 3;
|
int32 port = 4;
|
}
|
|
message ProcInfo
|
{
|
bytes proc_id = 1; // serial number, maybe managed
|
bytes name = 2;
|
bytes public_info = 3; // maybe json.
|
bytes private_info = 4;
|
}
|
|
message MsgTopicList {
|
repeated bytes topic_list = 1;
|
}
|
|
|
message MsgPublish {
|
bytes topic = 1;
|
bytes data = 2;
|
}
|
|
message MsgCommonReply {
|
ErrorMsg errmsg = 1;
|
}
|
|
message MsgRequestTopic {
|
bytes topic = 1;
|
bytes data = 2;
|
}
|
|
message MsgRequestTopicReply {
|
ErrorMsg errmsg = 1;
|
bytes data = 2;
|
}
|
|
message MsgRegister
|
{
|
ProcInfo proc = 1;
|
}
|
|
message MsgUnregister
|
{
|
ProcInfo proc = 1;
|
}
|
|
message MsgHeartbeat
|
{
|
ProcInfo proc = 1;
|
}
|
|
message MsgQueryTopic {
|
bytes topic = 1;
|
}
|
|
message MsgQueryTopicReply {
|
ErrorMsg errmsg = 1;
|
|
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;
|
message Info {
|
ProcInfo proc = 1;
|
bool online = 2;
|
MsgTopicList topics = 3;
|
MsgTopicList subLocalTopics = 4;
|
MsgTopicList subNetTopics = 5;
|
}
|
repeated Info proc_list = 2;
|
}
|
