update somm_proto

PeggyJV · Feb 3, 2024 · df8a077 · df8a077
1 parent ad35638
commit df8a077
Showing 1 changed file with 23 additions and 0 deletions.
diff --git a/somm_proto/src/prost/pubsub.v1.rs b/somm_proto/src/prost/pubsub.v1.rs
@@ -459,6 +459,13 @@ pub struct QuerySubscribersResponse {
     pub subscribers: ::prost::alloc::vec::Vec<Subscriber>,
 }
 #[derive(Clone, PartialEq, ::prost::Message)]
+pub struct QueryValidatorSubscribersRequest {}
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct QueryValidatorSubscribersResponse {
+    #[prost(message, repeated, tag = "1")]
+    pub subscribers: ::prost::alloc::vec::Vec<Subscriber>,
+}
+#[derive(Clone, PartialEq, ::prost::Message)]
 pub struct QueryPublisherIntentRequest {
     #[prost(string, tag = "1")]
     pub publisher_domain: ::prost::alloc::string::String,
@@ -666,6 +673,22 @@ pub mod query_client {
             let path = http::uri::PathAndQuery::from_static("/pubsub.v1.Query/QuerySubscribers");
             self.inner.unary(request.into_request(), path, codec).await
         }
+        pub async fn query_validator_subscribers(
+            &mut self,
+            request: impl tonic::IntoRequest<super::QueryValidatorSubscribersRequest>,
+        ) -> Result<tonic::Response<super::QueryValidatorSubscribersResponse>, tonic::Status>
+        {
+            self.inner.ready().await.map_err(|e| {
+                tonic::Status::new(
+                    tonic::Code::Unknown,
+                    format!("Service was not ready: {}", e.into()),
+                )
+            })?;
+            let codec = tonic::codec::ProstCodec::default();
+            let path =
+                http::uri::PathAndQuery::from_static("/pubsub.v1.Query/QueryValidatorSubscribers");
+            self.inner.unary(request.into_request(), path, codec).await
+        }
         pub async fn query_publisher_intent(
             &mut self,
             request: impl tonic::IntoRequest<super::QueryPublisherIntentRequest>,