diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-03-01 22:13:15 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-03-01 22:13:15 -0800 |
| commit | 0ca68a2a6d87786dbebe87fbd4b786b3318c1dcb (patch) | |
| tree | 125779d771d73a905fe030b73033977536dc268e | |
| parent | 4dec5e0e4ae9da6d7749128a81d7010f7a3cd801 (diff) | |
| download | seaweedfs-0ca68a2a6d87786dbebe87fbd4b786b3318c1dcb.tar.xz seaweedfs-0ca68a2a6d87786dbebe87fbd4b786b3318c1dcb.zip | |
WIP
| -rw-r--r-- | weed/pb/queue.proto | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/pb/queue.proto b/weed/pb/queue.proto index e212991d3..39b6ee05a 100644 --- a/weed/pb/queue.proto +++ b/weed/pb/queue.proto @@ -29,7 +29,8 @@ service SeaweedQueue { message WriteMessageRequest { string topic = 1; int64 event_ns = 2; - bytes data = 3; + bytes partition_key = 3; + bytes data = 4; } message WriteMessageResponse { @@ -51,6 +52,7 @@ message ReadMessageResponse { message ConfigureTopicRequest { string topic = 1; int64 ttl_seconds = 2; + int32 partition_count = 3; } message ConfigureTopicResponse { string error = 1; |