@@ -37,6 +37,8 @@ service HStreamApi {
37
37
returns (CreateShardReaderResponse ) {}
38
38
rpc LookupShardReader (LookupShardReaderRequest )
39
39
returns (LookupShardReaderResponse ) {}
40
+ rpc ListShardReaders (ListShardReadersRequest )
41
+ returns (ListShardReadersResponse ) {}
40
42
rpc ReadShard (ReadShardRequest ) returns (ReadShardResponse ) {}
41
43
rpc DeleteShardReader (DeleteShardReaderRequest )
42
44
returns (google .protobuf .Empty ) {}
@@ -58,6 +60,7 @@ service HStreamApi {
58
60
rpc DescribeCluster (google .protobuf .Empty ) returns (DescribeClusterResponse ) {
59
61
}
60
62
rpc LookupResource (LookupResourceRequest ) returns (ServerNode ) {}
63
+ rpc GetOverview (GetOverviewRequest ) returns (GetOverviewResponse ) {}
61
64
62
65
// Admin Command
63
66
rpc SendAdminCommand (AdminCommandRequest ) returns (AdminCommandResponse );
@@ -105,9 +108,6 @@ service HStreamApi {
105
108
rpc GetView (GetViewRequest ) returns (View ) {}
106
109
rpc DeleteView (DeleteViewRequest ) returns (google .protobuf .Empty ) {}
107
110
108
- // overvew related apis
109
- // rpc GetOverview(GetOverviewRequest) returns (GetOverviewResponse) {}
110
-
111
111
// FIXME: (store)node related apis
112
112
rpc ListNodes (ListNodesRequest ) returns (ListNodesResponse ) {}
113
113
rpc GetNode (GetNodeRequest ) returns (Node ) {}
@@ -308,8 +308,13 @@ message ReadShardRequest {
308
308
uint32 maxRecords = 2 ;
309
309
}
310
310
311
+ message ListShardReadersRequest {}
312
+ message ListShardReadersResponse { repeated ShardReader shardReaders = 1 ; }
313
+
311
314
message DeleteShardReaderRequest { string readerId = 1 ; }
312
315
316
+ message ShardReader { string id = 1 ; }
317
+
313
318
message ReadShardResponse { repeated ReceivedRecord receivedRecords = 1 ; }
314
319
315
320
message TerminateQueriesRequest {
@@ -390,6 +395,23 @@ message View {
390
395
repeated string schema = 5 ;
391
396
}
392
397
398
+ // Overview related
399
+ message GetOverviewRequest {}
400
+
401
+ message GetOverviewResponse {
402
+ string protocolVersion = 1 ;
403
+ string serverVersion = 2 ;
404
+ repeated ServerNodeStatus serverNodesStatus = 3 ;
405
+ uint64 clusterUpTime = 4 ;
406
+ repeated Stream allStreams = 5 ;
407
+ repeated Subscription allSubscriptions = 6 ;
408
+ repeated Shard allShards = 7 ;
409
+ repeated ShardReader allShardReaders = 8 ;
410
+ repeated Connector allConnectors = 9 ;
411
+ repeated View allViews = 10 ;
412
+ repeated Query allQueries = 11 ;
413
+ }
414
+
393
415
// Nodes related Request and Response
394
416
message GetNodeRequest { int32 id = 1 ; }
395
417
0 commit comments