From 1a3b3bb012490d9dc0af40e2d70afbb490d04c2a Mon Sep 17 00:00:00 2001 From: YangKian <1207783292@qq.com> Date: Wed, 13 Jul 2022 17:19:51 +0800 Subject: [PATCH] add splitShard and mergeShard --- hstream.proto | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/hstream.proto b/hstream.proto index 013d4cd..700b34a 100644 --- a/hstream.proto +++ b/hstream.proto @@ -44,6 +44,8 @@ service HStreamApi { // Shard APIs rpc ListShards(ListShardsRequest) returns (ListShardsResponse) {} + rpc SplitShards(SplitShardsRequest) returns (SplitShardsResponse) {} + rpc MergeShards(MergeShardsRequest) returns (MergeShardsResponse) {} // Subscribe APIs rpc CreateSubscription(Subscription) returns (Subscription) {} @@ -289,6 +291,21 @@ message ListShardsRequest { string streamName = 1; } message ListShardsResponse { repeated Shard shards = 1; } +message SplitShardsRequest { + string streamName = 1; + bool halfSplit = 2; + string splitKey = 3; +} + +message SplitShardsResponse { repeated Shard shards = 1; } + +message MergeShardsRequest { + string streamName = 1; + repeated string shardKeys = 2; +} + +message MergeShardsResponse { Shard shard = 1; } + message TerminateQueriesRequest { repeated string queryId = 1; bool all = 2;