fix proto endpoint bad naming

rpcpool · May 10, 2024 · 4959006 · 4959006
1 parent b91a0b8
commit 4959006
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/yellowstone-grpc-proto/proto/yellowstone-log.proto b/yellowstone-grpc-proto/proto/yellowstone-log.proto
@@ -8,7 +8,7 @@ option go_package = "github.com/rpcpool/solana-geyser-grpc/golang/proto";
 package yellowstone.log;
 
 service YellowstoneLog {
-  rpc consume(ConsumeRequest) returns (stream geyser.SubscribeUpdate) {}
+  rpc Consume(ConsumeRequest) returns (stream geyser.SubscribeUpdate) {}
 }
 
 

diff --git a/yellowstone-grpc-tools/src/scylladb/consumer/grpc.rs b/yellowstone-grpc-tools/src/scylladb/consumer/grpc.rs
@@ -416,12 +416,12 @@ pub type LogStream = Pin<Box<dyn Stream<Item = Result<SubscribeUpdate, tonic::St
 #[tonic::async_trait]
 impl YellowstoneLog for ScyllaYsLog {
     #[doc = r" Server streaming response type for the consume method."]
-    type consumeStream = LogStream;
+    type ConsumeStream = LogStream;
 
     async fn consume(
         &self,
         request: tonic::Request<ConsumeRequest>,
-    ) -> Result<tonic::Response<Self::consumeStream>, tonic::Status> {
+    ) -> Result<tonic::Response<Self::ConsumeStream>, tonic::Status> {
         let cr = request.into_inner();
 
         let consumer_id = cr.consumer_id.clone().unwrap_or(Uuid::new_v4().to_string());
@@ -475,7 +475,7 @@ impl YellowstoneLog for ScyllaYsLog {
 
         let ret = ReceiverStream::new(rx);
 
-        let res = Response::new(Box::pin(ret) as Self::consumeStream);
+        let res = Response::new(Box::pin(ret) as Self::ConsumeStream);
         Ok(res)
     }
 }