refactor: rename DbOrchestartor for DbOrchestrator

Author: MarcosNicolau

aggregation_mode/db/src/orchestrator.rs

@@ -27,7 +27,7 @@ struct DbNode {
 
 /// Database orchestrator for running reads/writes across multiple PostgreSQL nodes with retry/backoff.
 ///
-/// `DbOrchestartor` holds a list of database nodes (connection pools) and will:
+/// `DbOrchestrator` holds a list of database nodes (connection pools) and will:
 /// - try nodes in a preferred order (healthy nodes first, then recently-failed nodes),
 /// - mark nodes as failed on connection-type errors,
 /// - retry transient failures with exponential backoff based on `retry_config`,
@@ -41,18 +41,18 @@ struct DbNode {
 /// Clones share health state (the atomics) and the underlying pools, so all clones observe and influence
 /// the same “preferred node” ordering decisions.
 #[derive(Debug, Clone)]
-pub struct DbOrchestartor {
+pub struct DbOrchestrator {
     nodes: Vec<Arc<DbNode>>,
     retry_config: RetryConfig,
 }
 
 #[derive(Debug)]
-pub enum DbOrchestartorError {
+pub enum DbOrchestratorError {
     InvalidNumberOfConnectionUrls,
     Sqlx(sqlx::Error),
 }
 
-impl std::fmt::Display for DbOrchestartorError {
+impl std::fmt::Display for DbOrchestratorError {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         match self {
             Self::InvalidNumberOfConnectionUrls => {
@@ -63,13 +63,13 @@ impl std::fmt::Display for DbOrchestartorError {
     }
 }
 
-impl DbOrchestartor {
+impl DbOrchestrator {
     pub fn try_new(
         connection_urls: &[String],
         retry_config: RetryConfig,
-    ) -> Result<Self, DbOrchestartorError> {
+    ) -> Result<Self, DbOrchestratorError> {
         if connection_urls.is_empty() {
-            return Err(DbOrchestartorError::InvalidNumberOfConnectionUrls);
+            return Err(DbOrchestratorError::InvalidNumberOfConnectionUrls);
         }
 
         let nodes = connection_urls
@@ -84,7 +84,7 @@ impl DbOrchestartor {
                 }))
             })
             .collect::<Result<Vec<_>, sqlx::Error>>()
-            .map_err(DbOrchestartorError::Sqlx)?;
+            .map_err(DbOrchestratorError::Sqlx)?;
 
         Ok(Self {
             nodes,

aggregation_mode/gateway/src/db.rs

@@ -1,5 +1,5 @@
 use crate::types::Receipt;
-use db::{orchestrator::DbOrchestartor, retry::RetryConfig};
+use db::{orchestrator::DbOrchestrator, retry::RetryConfig};
 use sqlx::types::{BigDecimal, Uuid};
 
 // Retry/backoff behavior summary (see
@@ -34,7 +34,7 @@ const RETRY_MAX_DELAY_SECONDS: u64 = 10;
 
 #[derive(Clone, Debug)]
 pub struct Db {
-    orchestrator: DbOrchestartor,
+    orchestrator: DbOrchestrator,
 }
 
 #[derive(Debug, Clone)]
@@ -44,7 +44,7 @@ pub enum DbError {
 
 impl Db {
     pub async fn try_new(connection_urls: &[String]) -> Result<Self, DbError> {
-        let orchestrator = DbOrchestartor::try_new(
+        let orchestrator = DbOrchestrator::try_new(
             connection_urls,
             RetryConfig {
                 min_delay_millis: RETRY_MIN_DELAY_MILLIS,

aggregation_mode/payments_poller/src/db.rs

@@ -1,4 +1,4 @@
-use db::{orchestrator::DbOrchestartor, retry::RetryConfig};
+use db::{orchestrator::DbOrchestrator, retry::RetryConfig};
 use sqlx::types::BigDecimal;
 
 // Retry/backoff behavior summary for DB queries (see
@@ -29,7 +29,7 @@ const RETRY_MAX_DELAY_SECONDS: u64 = 30;
 
 #[derive(Clone, Debug)]
 pub struct Db {
-    orchestartor: DbOrchestartor,
+    orchestrator: DbOrchestrator,
 }
 
 #[derive(Debug, Clone)]
@@ -39,7 +39,7 @@ pub enum DbError {
 
 impl Db {
     pub async fn try_new(connection_urls: &[String]) -> Result<Self, DbError> {
-        let orchestartor = DbOrchestartor::try_new(
+        let orchestrator = DbOrchestrator::try_new(
             connection_urls,
             RetryConfig {
                 min_delay_millis: RETRY_MIN_DELAY_MILLIS,
@@ -50,7 +50,7 @@ impl Db {
         )
         .map_err(|e| DbError::ConnectError(e.to_string()))?;
 
-        Ok(Self { orchestartor })
+        Ok(Self { orchestrator })
     }
 
     pub async fn insert_payment_event(
@@ -61,7 +61,7 @@ impl Db {
         valid_until: &BigDecimal,
         tx_hash: &str,
     ) -> Result<(), sqlx::Error> {
-        self.orchestartor
+        self.orchestrator
             .write(async |pool| {
                 sqlx::query(
                     "INSERT INTO payment_events (address, started_at, amount, valid_until, tx_hash)

aggregation_mode/proof_aggregator/src/backend/db.rs

@@ -1,4 +1,4 @@
-use db::{orchestrator::DbOrchestartor, retry::RetryConfig, types::Task};
+use db::{orchestrator::DbOrchestrator, retry::RetryConfig, types::Task};
 use sqlx::types::Uuid;
 
 // Retry/backoff behavior summary (see
@@ -29,7 +29,7 @@ const RETRY_MAX_DELAY_SECONDS: u64 = 30;
 
 #[derive(Debug, Clone)]
 pub struct Db {
-    orchestrator: DbOrchestartor,
+    orchestrator: DbOrchestrator,
 }
 
 #[derive(Debug, Clone)]
@@ -40,7 +40,7 @@ pub enum DbError {
 
 impl Db {
     pub async fn try_new(connection_urls: &[String]) -> Result<Self, DbError> {
-        let orchestrator = DbOrchestartor::try_new(
+        let orchestrator = DbOrchestrator::try_new(
             connection_urls,
             RetryConfig {
                 min_delay_millis: RETRY_MIN_DELAY_MILLIS,