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;