weed queue starts

1 files changed, 64 insertions, 0 deletions

diff --git a/weed/pb/queue.proto b/weed/pb/queue.proto
new file mode 100644
index 000000000..e212991d3
--- /dev/null
+++ b/weed/pb/queue.proto
@@ -0,0 +1,64 @@
+syntax = "proto3";
+
+package queue_pb;
+
+option java_package = "seaweedfs.client";
+option java_outer_classname = "QueueProto";
+
+//////////////////////////////////////////////////
+
+service SeaweedQueue {
+
+    rpc StreamWrite (stream WriteMessageRequest) returns (stream WriteMessageResponse) {
+    }
+
+    rpc StreamRead (ReadMessageRequest) returns (stream ReadMessageResponse) {
+    }
+
+    rpc ConfigureTopic (ConfigureTopicRequest) returns (ConfigureTopicResponse) {
+    }
+
+    rpc DeleteTopic (DeleteTopicRequest) returns (DeleteTopicResponse) {
+    }
+
+}
+
+//////////////////////////////////////////////////
+
+
+message WriteMessageRequest {
+    string topic = 1;
+    int64 event_ns = 2;
+    bytes data = 3;
+}
+
+message WriteMessageResponse {
+    string error = 1;
+    int64 ack_ns = 2;
+}
+
+message ReadMessageRequest {
+    string topic = 1;
+    int64 start_ns = 2;
+}
+
+message ReadMessageResponse {
+    string error = 1;
+    int64 event_ns = 2;
+    bytes data = 3;
+}
+
+message ConfigureTopicRequest {
+    string topic = 1;
+    int64 ttl_seconds = 2;
+}
+message ConfigureTopicResponse {
+    string error = 1;
+}
+
+message DeleteTopicRequest {
+    string topic = 1;
+}
+message DeleteTopicResponse {
+    string error = 1;
+}