Skip to content

add getOverview #32

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 1 commit into
base: main
Choose a base branch
from
Draft

add getOverview #32

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
28 changes: 25 additions & 3 deletions hstream.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,8 @@ service HStreamApi {
returns (CreateShardReaderResponse) {}
rpc LookupShardReader(LookupShardReaderRequest)
returns (LookupShardReaderResponse) {}
rpc ListShardReaders(ListShardReadersRequest)
returns (ListShardReadersResponse) {}
rpc ReadShard(ReadShardRequest) returns (ReadShardResponse) {}
rpc DeleteShardReader(DeleteShardReaderRequest)
returns (google.protobuf.Empty) {}
Expand All @@ -58,6 +60,7 @@ service HStreamApi {
rpc DescribeCluster(google.protobuf.Empty) returns (DescribeClusterResponse) {
}
rpc LookupResource(LookupResourceRequest) returns (ServerNode) {}
rpc GetOverview(GetOverviewRequest) returns (GetOverviewResponse) {}

// Admin Command
rpc SendAdminCommand(AdminCommandRequest) returns (AdminCommandResponse);
Expand Down Expand Up @@ -105,9 +108,6 @@ service HStreamApi {
rpc GetView(GetViewRequest) returns (View) {}
rpc DeleteView(DeleteViewRequest) returns (google.protobuf.Empty) {}

// overvew related apis
// rpc GetOverview(GetOverviewRequest) returns (GetOverviewResponse) {}

// FIXME: (store)node related apis
rpc ListNodes(ListNodesRequest) returns (ListNodesResponse) {}
rpc GetNode(GetNodeRequest) returns (Node) {}
Expand Down Expand Up @@ -308,8 +308,13 @@ message ReadShardRequest {
uint32 maxRecords = 2;
}

message ListShardReadersRequest {}
message ListShardReadersResponse { repeated ShardReader shardReaders = 1; }

message DeleteShardReaderRequest { string readerId = 1; }

message ShardReader { string id = 1; }

message ReadShardResponse { repeated ReceivedRecord receivedRecords = 1; }

message TerminateQueriesRequest {
Expand Down Expand Up @@ -390,6 +395,23 @@ message View {
repeated string schema = 5;
}

// Overview related
message GetOverviewRequest {}

message GetOverviewResponse {
string protocolVersion = 1;
string serverVersion = 2;
repeated ServerNodeStatus serverNodesStatus = 3;
uint64 clusterUpTime = 4;
repeated Stream allStreams = 5;
repeated Subscription allSubscriptions = 6;
repeated Shard allShards = 7;
repeated ShardReader allShardReaders = 8;
repeated Connector allConnectors = 9;
repeated View allViews = 10;
repeated Query allQueries = 11;
}

// Nodes related Request and Response
message GetNodeRequest { int32 id = 1; }

Expand Down