From 5ef843db43a21976ac1f03eea954ac9cc72015f8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=80=9D=E6=95=8F?= <huangsimin@yuandian.com>
Date: Fri, 12 Aug 2022 17:44:51 +0800
Subject: [PATCH] =?UTF-8?q?feat(statemachine):=20=E6=8F=90=E4=BA=A4?=
 =?UTF-8?q?=E6=95=B0=E7=BB=84=E9=87=8D=E7=BB=84=E7=9A=84Processor=E7=9B=B8?=
 =?UTF-8?q?=E5=85=B3,=E4=B8=8E=E6=8E=A2=E9=92=88=E4=BA=A4=E4=BA=92?=
 =?UTF-8?q?=E6=97=A0=E5=85=B3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Processor.proto | 24 ++++++++++++++++++++++++
 1 file changed, 24 insertions(+)
 create mode 100644 Processor.proto

diff --git a/Processor.proto b/Processor.proto
new file mode 100644
index 0000000..c9947ab
--- /dev/null
+++ b/Processor.proto
@@ -0,0 +1,24 @@
+syntax = "proto3";
+
+import "google/protobuf/any.proto";
+ 
+option java_multiple_files = false; //不要拆分成多个文件
+option java_package = "com.yuandian.dataflow.proto";
+option go_package = "../grpc-gen;grpcgen";
+ 
+package dataflow;
+ 
+message ProcessorResponse {
+    int32 code = 1; // 返回的状态码
+    string message = 2; // 消息
+}
+
+message PacketsProcessorRequest {
+    int32 type = 1; // 请求类型.  默认 为 1.  暂无意义
+    string version = 2; // 请求版本.  区分版本. 非必要时不使用 
+    repeated google.protobuf.Any packets = 3; // 请求的可变参数. 暂不使用
+}
+ 
+service ProcessorServer {
+    rpc AllPackets (PacketsProcessorRequest) returns (ProcessorResponse);
+}