refactor: convert index dispatch pipeline into actor model with per index channels

Signed-off-by: William Hankins <[email protected]>

Author: whankinsiv

Cargo.lock

@@ -18,6 +18,7 @@ bincode = "1"
 config = { workspace = true }
 fjall = "2.7.0"
 futures = "0.3"
+minicbor = { workspace = true, features = ["std", "derive"] }
 pallas = { workspace = true}
 serde = { workspace = true, features = ["rc"] }
 tokio = { workspace = true }

modules/custom_indexer/Cargo.toml

@@ -7,7 +7,11 @@ use pallas::ledger::traverse::MultiEraTx;
 pub trait ChainIndex: Send + Sync + 'static {
     fn name(&self) -> String;
 
-    async fn handle_onchain_tx(&mut self, info: &BlockInfo, tx: &MultiEraTx<'_>) -> Result<()> {
+    async fn handle_onchain_tx(
+        &mut self,
+        info: &BlockInfo,
+        tx: &MultiEraTx<'static>,
+    ) -> Result<()> {
         let _ = (info, tx);
         Ok(())
     }