diff options
| author | bukton <buk_ton2@hotmail.com> | 2020-04-19 00:21:45 +0700 |
|---|---|---|
| committer | bukton <buk_ton2@hotmail.com> | 2020-04-19 00:21:45 +0700 |
| commit | 290c6b7f01f7b148a65ba10dd6536ad2567d7653 (patch) | |
| tree | e1abb141849419c40691097eea032b944fcbd748 /weed/pb/queue.proto | |
| parent | 6234ea441b6388838a19635c656316047f42917d (diff) | |
| parent | 11f5a6d91346e5f3cbf3b46e0a660e231c5c2998 (diff) | |
| download | seaweedfs-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.proto | 66 |
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; -} |
