syntax = "proto3";
|
option optimize_for = LITE_RUNTIME;
|
option go_package="./bhome_msg";
|
|
// public messages
|
import "error_msg.proto";
|
|
package bhome_msg;
|
|
message BHAddress {
|
bytes mq_id = 1; // mqid, uuid
|
bytes ip = 2; //
|
int32 port = 3;
|
}
|
|
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;
|
repeated BHAddress addrs = 2;
|
}
|
|
message MsgHeartbeat
|
{
|
ProcInfo proc = 1;
|
}
|
|
message MsgQueryTopic {
|
bytes topic = 1;
|
}
|
|
message MsgQueryTopicReply {
|
ErrorMsg errmsg = 1;
|
BHAddress address = 2;
|
}
|
