Skip to content
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

fumarole: added ListConsumerGroups,DeleteConsumerGroup and #500

Merged
merged 1 commit into from
Dec 17, 2024
Merged

fumarole: added ListConsumerGroups,DeleteConsumerGroup and #500

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
37 changes: 37 additions & 0 deletions yellowstone-grpc-proto/proto/fumarole.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,44 @@ import public "geyser.proto";
package fumarole;

service Fumarole {
rpc GetConsumerGroupInfo(GetConsumerGroupInfoRequest) returns (ConsumerGroupInfo) {}
rpc ListConsumerGroups(ListConsumerGroupsRequest) returns (ListConsumerGroupsResponse) {}
rpc DeleteConsumerGroup(DeleteConsumerGroupRequest) returns (DeleteConsumerGroupResponse) {}
rpc CreateStaticConsumerGroup(CreateStaticConsumerGroupRequest) returns (CreateStaticConsumerGroupResponse) {}
rpc Subscribe(stream SubscribeRequest) returns (stream geyser.SubscribeUpdate) {}
rpc GetSlotLagInfo(GetSlotLagInfoRequest) returns (GetSlotLagInfoResponse) {}
}

message GetConsumerGroupInfoRequest {
string consumer_group_label = 1;
}


message DeleteConsumerGroupRequest {
string consumer_group_label = 1;
}

message DeleteConsumerGroupResponse {
bool success = 1;
}

message ListConsumerGroupsRequest {}

message ListConsumerGroupsResponse {
repeated ConsumerGroupInfo consumer_groups = 1;
}


message ConsumerGroupInfo {
string id = 1;
string consumer_group_label = 2;
ConsumerGroupType consumer_group_type = 3;
uint32 member_count = 4;
geyser.CommitmentLevel commitment_level = 5;
EventSubscriptionPolicy event_subscription_policy = 6;
bool is_stale = 7;
}

message GetSlotLagInfoRequest {
string consumer_group_label = 1;
}
Expand All @@ -32,6 +65,10 @@ message CreateStaticConsumerGroupResponse {
string group_id = 1;
}

enum ConsumerGroupType {
STATIC = 0;
}

enum InitialOffsetPolicy {
EARLIEST = 0;
LATEST = 1;
Expand Down
Loading