aboutsummaryrefslogtreecommitdiff
path: root/weed/pb/queue.proto
diff options
context:
space:
mode:
authorbukton <buk_ton2@hotmail.com>2020-04-19 00:21:45 +0700
committerbukton <buk_ton2@hotmail.com>2020-04-19 00:21:45 +0700
commit290c6b7f01f7b148a65ba10dd6536ad2567d7653 (patch)
treee1abb141849419c40691097eea032b944fcbd748 /weed/pb/queue.proto
parent6234ea441b6388838a19635c656316047f42917d (diff)
parent11f5a6d91346e5f3cbf3b46e0a660e231c5c2998 (diff)
downloadseaweedfs-290c6b7f01f7b148a65ba10dd6536ad2567d7653.tar.xz
seaweedfs-290c6b7f01f7b148a65ba10dd6536ad2567d7653.zip
Merge remote-tracking branch 'origin/master' into filer_mongodb
# Conflicts: # go.mod # go.sum # weed/server/filer_server.go
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;
-}