27 lines
467 B
Protocol Buffer
27 lines
467 B
Protocol Buffer
|
syntax = "proto3";
|
||
|
|
|
||
|
|
package service;
|
||
|
|
option go_package="github.com/unistack-org/micro-broker-service;service";
|
||
|
|
|
||
|
|
service Broker {
|
||
|
|
rpc Publish(PublishRequest) returns (Empty) {};
|
||
|
|
rpc Subscribe(SubscribeRequest) returns (stream Message) {};
|
||
|
|
}
|
||
|
|
|
||
|
|
message Empty {}
|
||
|
|
|
||
|
|
message PublishRequest {
|
||
|
|
string topic = 1;
|
||
|
|
Message message = 2;
|
||
|
|
}
|
||
|
|
|
||
|
|
message SubscribeRequest {
|
||
|
|
string topic = 1;
|
||
|
|
string group = 2;
|
||
|
|
}
|
||
|
|
|
||
|
|
message Message {
|
||
|
|
map<string,string> header = 1;
|
||
|
|
bytes body = 2;
|
||
|
|
}
|