+1 -1

consumer/src/backfill/mod.rs

reviewed

··· 53 53 index_client: Option<parakeet_index::Client>, 54 54 opts: BackfillConfig, 55 55 ) -> eyre::Result<Self> { 56 56 - let semaphore = Arc::new(Semaphore::new(opts.backfill_workers as usize)); 56 56 + let semaphore = Arc::new(Semaphore::new(opts.workers as usize)); 57 57 58 58 Ok(BackfillManager { 59 59 pool,

+2 -2

consumer/src/config.rs

reviewed

··· 34 34 pub relay_source: String, 35 35 pub history_mode: HistoryMode, 36 36 #[serde(default = "default_indexer_workers")] 37 37 - pub indexer_workers: u8, 37 37 + pub workers: u8, 38 38 pub start_commit_seq: Option<u64>, 39 39 /// Whether to resolve handles as part of `#identity` events. 40 40 /// You can use this to move handle resolution out of event handling and into another place. ··· 57 57 #[derive(Clone, Debug, Deserialize)] 58 58 pub struct BackfillConfig { 59 59 #[serde(default = "default_backfill_workers")] 60 60 - pub backfill_workers: u8, 60 60 + pub workers: u8, 61 61 #[serde(default)] 62 62 pub skip_aggregation: bool, 63 63 #[serde(default = "default_download_workers")]

+1 -1

consumer/src/main.rs

reviewed

··· 129 129 ) 130 130 .await?; 131 131 132 132 - tracker.spawn(relay_indexer.run(indexer_cfg.indexer_workers, stop)); 132 132 + tracker.spawn(relay_indexer.run(indexer_cfg.workers, stop)); 133 133 tracker.spawn(index_transport(index_client, idxc_rx)); 134 134 } 135 135

+1 -1

parakeet/src/config.rs

reviewed

··· 15 15 pub struct Config { 16 16 pub index_uri: String, 17 17 pub database_url: String, 18 18 - pub cache_uri: String, 18 18 + pub redis_uri: String, 19 19 #[serde(default)] 20 20 pub server: ConfigServer, 21 21 pub service: ConfigService,

+1 -1

parakeet/src/main.rs

reviewed

··· 49 49 tracing::info!("database migrations complete"); 50 50 } 51 51 52 52 - let redis_client = redis::Client::open(conf.cache_uri)?; 52 52 + let redis_client = redis::Client::open(conf.redis_uri)?; 53 53 let redis_mp = redis_client.get_multiplexed_tokio_connection().await?; 54 54 55 55 let index_client = parakeet_index::Client::connect(conf.index_uri).await?;