55 lines
843 B
Protocol Buffer
55 lines
843 B
Protocol Buffer
syntax = "proto3";
|
|
|
|
// 微服务通过 ws_channel 与 efka 之间的通道消息定义。
|
|
// 该协议用于替代当前基于 JSON 的请求/响应/推送格式。
|
|
|
|
message ServiceRequest {
|
|
uint32 packet_id = 1;
|
|
|
|
message Register {
|
|
string service_id = 1;
|
|
}
|
|
|
|
message Subscribe {
|
|
string topic = 1;
|
|
}
|
|
|
|
oneof request {
|
|
Register register = 10;
|
|
Subscribe subscribe = 11;
|
|
}
|
|
}
|
|
|
|
message ServiceReply {
|
|
uint32 packet_id = 1;
|
|
|
|
message Error {
|
|
int32 code = 1;
|
|
string message = 2;
|
|
}
|
|
|
|
oneof reply {
|
|
bytes result = 10;
|
|
Error error = 11;
|
|
}
|
|
}
|
|
|
|
message ServiceCast {
|
|
|
|
message MetricData {
|
|
bytes route_key = 1;
|
|
bytes metric = 2;
|
|
}
|
|
|
|
message TopicEvent {
|
|
string topic = 1;
|
|
bytes content = 2;
|
|
}
|
|
|
|
oneof body {
|
|
TopicEvent topic_event = 10;
|
|
MetricData metric_data = 11;
|
|
}
|
|
|
|
}
|