chore: switch to run_v2 for ingest which handles ingesting accounts a…

…nd transactions
metaplex-foundation · Aug 9, 2024 · 81f5d71 · 81f5d71
1 parent 2cc3411
commit 81f5d71
Show file tree

Hide file tree

Showing 7 changed files with 383 additions and 80 deletions.
diff --git a/digital_asset_types/src/dapi/change_logs.rs b/digital_asset_types/src/dapi/change_logs.rs
@@ -200,7 +200,7 @@ fn build_asset_proof(
     tree_id: Vec<u8>,
     leaf_node_idx: i64,
     leaf_hash: Vec<u8>,
-    req_indexes: &Vec<i64>,
+    req_indexes: &[i64],
     required_nodes: &[SimpleChangeLog],
 ) -> AssetProof {
     let mut final_node_list = vec![SimpleChangeLog::default(); req_indexes.len()];
@@ -211,7 +211,7 @@ fn build_asset_proof(
     }
     for (i, (n, nin)) in final_node_list
         .iter_mut()
-        .zip(req_indexes.clone())
+        .zip(req_indexes.to_owned())
         .enumerate()
     {
         if *n == SimpleChangeLog::default() {

diff --git a/grpc-ingest/config-ingester.yml b/grpc-ingest/config-ingester.yml
@@ -13,9 +13,6 @@ redis:
       xack_batch_max_size: 100
       xack_batch_max_idle_ms: 10
       xack_max_in_process: 100
-    - type: metadata_json
-      stream: METADATA_JSONS
-      data_key: data
   prefetch_queue_size: 1_000 # max number of messages available in the read queue for processing
   xpending_max: 250 # used for reading pending messages
   xpending_only: false # exit once all pending messages consumed (should be applied if you want downscale number of ingesters)