proto: add replay_from_slot

CHANGELOG.md

@@ -16,6 +16,7 @@ The minor version will be incremented upon a breaking change and the patch versi
 
 - proto: add tonic feature ([#474](https://github.com/rpcpool/yellowstone-grpc/pull/474))
 - geyser: use default compression as gzip and zstd ([#475](https://github.com/rpcpool/yellowstone-grpc/pull/475))
+- proto: add `replay_from_slot` ([#477](https://github.com/rpcpool/yellowstone-grpc/pull/477))
 
 ### Breaking
 

examples/rust/src/bin/client.rs

@@ -254,6 +254,10 @@ struct ActionSubscribe {
     #[clap(long)]
     blocks_meta: bool,
 
+    /// Replay message from slot
+    #[clap(long)]
+    replay_from_slot: Option<u64>,
+
     /// Send ping in subscribe request
     #[clap(long)]
     ping: Option<i32>,
@@ -447,6 +451,7 @@ impl Action {
                         commitment: commitment.map(|x| x as i32),
                         accounts_data_slice,
                         ping,
+                        replay_from_slot: args.replay_from_slot,
                     },
                     args.resub.unwrap_or(0),
                     args.stats,
@@ -803,6 +808,7 @@ async fn geyser_subscribe(
                     commitment: None,
                     accounts_data_slice: Vec::default(),
                     ping: None,
+                    replay_from_slot: None,
                 })
                 .await
                 .map_err(GeyserGrpcClientError::SubscribeSendError)?;

examples/rust/src/bin/tx-blocktime.rs

@@ -111,6 +111,7 @@ async fn main() -> anyhow::Result<()> {
             commitment: Some(commitment as i32),
             accounts_data_slice: vec![],
             ping: None,
+            replay_from_slot: None,
         })
         .await?;
 

yellowstone-grpc-geyser/config.json

@@ -20,8 +20,9 @@
     "unary_concurrency_limit": 100,
     "unary_disabled": false,
     "x_token": null,
-    "filter_name_size_limit": 32,
-    "filter_names_size_limit": 1024,
+    "replay_stored_slots": 0,
+    "filter_name_size_limit": 128,
+    "filter_names_size_limit": 4096,
     "filter_names_cleanup_interval": "1s",
     "filter_limits": {
       "accounts": {

yellowstone-grpc-geyser/src/config.rs

@@ -119,6 +119,9 @@ pub struct ConfigGrpc {
         with = "humantime_serde"
     )]
     pub filter_names_cleanup_interval: Duration,
+    /// Number of slots stored for replay
+    #[serde(default = "ConfigGrpc::default_replay_stored_slots")]
+    pub replay_stored_slots: u64,
 }
 
 impl ConfigGrpc {
@@ -153,6 +156,10 @@ impl ConfigGrpc {
     const fn default_filter_names_cleanup_interval() -> Duration {
         Duration::from_secs(1)
     }
+
+    const fn default_replay_stored_slots() -> u64 {
+        0
+    }
 }
 
 #[derive(Debug, Clone, Deserialize)]

yellowstone-grpc-proto/proto/geyser.proto

@@ -37,6 +37,7 @@ message SubscribeRequest {
   optional CommitmentLevel commitment = 6;
   repeated SubscribeRequestAccountsDataSlice accounts_data_slice = 7;
   optional SubscribeRequestPing ping = 9;
+  optional uint64 replay_from_slot = 11;
 }
 
 message SubscribeRequestFilterAccounts {

yellowstone-grpc-proto/src/plugin/filter/filter.rs

@@ -1167,6 +1167,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let limit = FilterLimits::default();
         let filter = Filter::new(&config, &limit, &mut create_filter_names());
@@ -1198,6 +1199,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let mut limit = FilterLimits::default();
         limit.accounts.any = false;
@@ -1233,6 +1235,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let mut limit = FilterLimits::default();
         limit.transactions.any = false;
@@ -1267,6 +1270,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let mut limit = FilterLimits::default();
         limit.transactions.any = false;
@@ -1307,6 +1311,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let limit = FilterLimits::default();
         let filter = Filter::new(&config, &limit, &mut create_filter_names()).unwrap();
@@ -1371,6 +1376,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let limit = FilterLimits::default();
         let filter = Filter::new(&config, &limit, &mut create_filter_names()).unwrap();
@@ -1435,6 +1441,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let limit = FilterLimits::default();
         let filter = Filter::new(&config, &limit, &mut create_filter_names()).unwrap();
@@ -1485,6 +1492,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let limit = FilterLimits::default();
         let filter = Filter::new(&config, &limit, &mut create_filter_names()).unwrap();
@@ -1557,6 +1565,7 @@ mod tests {
             commitment: None,
             accounts_data_slice: Vec::new(),
             ping: None,
+            replay_from_slot: None,
         };
         let limit = FilterLimits::default();
         let filter = Filter::new(&config, &limit, &mut create_filter_names()).unwrap();