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;
}