aboutsummaryrefslogtreecommitdiff
path: root/weed/pb/queue.proto
diff options
context:
space:
mode:
Diffstat (limited to 'weed/pb/queue.proto')
-rw-r--r--weed/pb/queue.proto66
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;
-}