gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

WIP

Browse Source
This commit is contained in:
Chris Lu
2020-03-01 22:13:15 -08:00
parent 4dec5e0e4a
commit 0ca68a2a6d
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
weed/pb/queue.proto
View File

@@ -29,7 +29,8 @@ service SeaweedQueue {
message WriteMessageRequest { message WriteMessageRequest {
string topic = 1; string topic = 1;
int64 event_ns = 2; int64 event_ns = 2;
bytes data = 3; bytes partition_key = 3;
bytes data = 4;
} }
message WriteMessageResponse { message WriteMessageResponse {
@@ -51,6 +52,7 @@ message ReadMessageResponse {
message ConfigureTopicRequest { message ConfigureTopicRequest {
string topic = 1; string topic = 1;
int64 ttl_seconds = 2; int64 ttl_seconds = 2;
int32 partition_count = 3;
} }
message ConfigureTopicResponse { message ConfigureTopicResponse {
string error = 1; string error = 1;