From bef8f3e815052251a9b2ce45862be3586cb08b8c Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Mon, 20 Apr 2026 20:02:42 +0800
Subject: [PATCH] fix

---
 proto/service.proto | 54 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 54 insertions(+)
 create mode 100644 proto/service.proto

diff --git a/proto/service.proto b/proto/service.proto
new file mode 100644
index 0000000..791089c
--- /dev/null
+++ b/proto/service.proto
@@ -0,0 +1,54 @@
+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;
+  }
+
+}
\ No newline at end of file