- Switch from the flatbuffers to the protobuf

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 15 insertions, 0 deletions

diff --git a/pkg/pubsub/message.proto b/pkg/pubsub/message.proto
new file mode 100644
index 00000000..772e7611
--- /dev/null
+++ b/pkg/pubsub/message.proto
@@ -0,0 +1,15 @@
+syntax = "proto3";
+
+package pubsub.v1;
+option go_package = "./message";
+
+message Message {
+    string command = 1;
+    string broker = 2;
+    repeated string topics = 3;
+    bytes payload = 4;
+}
+
+message Messages {
+    repeated Message messages = 1;
+}