v0.3.13-pre.008-fix.002

crates/ksp-worker-raw-transaction-ingest-lib/src/runtime_resources.rs

@@ -1,5 +1,5 @@
 // file: crates/ksp-worker-raw-transaction-ingest-lib/src/runtime_resources.rs
-// version: 22
+// version: 23
 
 use sha2::Digest; // rust-rules: trait-import
 
@@ -621,7 +621,7 @@ impl crate::RawTransactionIngestYellowstoneSource {
     }
 
     /// Runs the productive Yellowstone source task until cooperative stop or one safe terminal source failure.
-    pub(crate) async fn run(
+    async fn run(
         self,
         settings: crate::RawTransactionIngestSettings,
         mut stop_receiver: tokio::sync::watch::Receiver<bool>,
@@ -858,7 +858,7 @@ impl crate::RawTransactionIngestHeliusTransactionSource {
     }
 
     /// Runs one productive Helius `transactionSubscribe` source until cooperative stop or one safe terminal source failure.
-    pub(crate) async fn run(
+    async fn run(
         self,
         settings: crate::RawTransactionIngestSettings,
         mut stop_receiver: tokio::sync::watch::Receiver<bool>,
@@ -1577,7 +1577,7 @@ impl crate::RawTransactionIngestStandardLogsSource {
     }
 
     /// Runs one productive standard `logsSubscribe` source until cooperative stop or one safe terminal source failure.
-    pub(crate) async fn run(
+    async fn run(
         self,
         settings: crate::RawTransactionIngestSettings,
         mut stop_receiver: tokio::sync::watch::Receiver<bool>,
@@ -3414,6 +3414,7 @@ struct RawTransactionIngestHydrationCoordinator {
 }
 
 impl RawTransactionIngestHydrationCoordinator {
+    #[cfg(test)]
     fn new(settings: &crate::RawTransactionIngestSettings) -> Self {
         return Self::with_global_registry(settings, std::sync::Arc::new(RawTransactionIngestGlobalHydrationRegistry::new(settings)));
     }