scaffolding messaging

1 files changed, 0 insertions, 66 deletions

diff --git a/weed/pb/queue.proto b/weed/pb/queue.proto
deleted file mode 100644
index 39b6ee05a..000000000
--- a/weed/pb/queue.proto
+++ /dev/null
@@ -1,66 +0,0 @@
-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 partition_key = 3;
-    bytes data = 4;
-}
-
-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;
-    int32 partition_count = 3;
-}
-message ConfigureTopicResponse {
-    string error = 1;
-}
-
-message DeleteTopicRequest {
-    string topic = 1;
-}
-message DeleteTopicResponse {
-    string error = 1;
-}