diff options
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; -} |
