From 663fa6a6e1812b56d29dd3e438e2a09600ff8b7d Mon Sep 17 00:00:00 2001
From: lvboudre <louis-vincent@triton.one>
Date: Tue, 17 Dec 2024 14:24:37 -0500
Subject: [PATCH] fumarole: added ListConsumerGroups,DeleteConsumerGroup and
 (#500)

---
 yellowstone-grpc-proto/proto/fumarole.proto | 37 +++++++++++++++++++++
 1 file changed, 37 insertions(+)

diff --git a/yellowstone-grpc-proto/proto/fumarole.proto b/yellowstone-grpc-proto/proto/fumarole.proto
index 5a28ef6d..67dd9887 100644
--- a/yellowstone-grpc-proto/proto/fumarole.proto
+++ b/yellowstone-grpc-proto/proto/fumarole.proto
@@ -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;
 }
@@ -32,6 +65,10 @@ message CreateStaticConsumerGroupResponse {
   string group_id = 1;
 }
 
+enum ConsumerGroupType {
+  STATIC = 0;
+}
+
 enum InitialOffsetPolicy {
   EARLIEST = 0;
   LATEST = 1;