diff --git a/Cargo.lock b/Cargo.lock
index c0038eb63..b63b7d97d 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -8682,6 +8682,7 @@ dependencies = [
  "serde_derive",
  "serde_json",
  "tempfile",
+ "tokio",
  "toml 0.8.19",
 ]
 
diff --git a/Cargo.toml b/Cargo.toml
index d038146cc..b30097163 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -5,10 +5,7 @@ resolver = "2"
 members = [
     "protocol-units/bridge/config",
     "protocol-units/bridge/setup",
-    "protocol-units/execution/dof",
-    "protocol-units/execution/opt-executor",
-    "protocol-units/execution/fin-view",
-    "protocol-units/execution/util",
+    "protocol-units/execution/maptos/*",
     "protocol-units/da/m1/*",
     "protocol-units/sequencing/memseq/*",
     "protocol-units/mempool/*",
@@ -73,10 +70,10 @@ m1-da-light-node-util = { path = "protocol-units/da/m1/util" }
 m1-da-light-node-setup = { path = "protocol-units/da/m1/setup" }
 m1-da-light-node-verifier = { path = "protocol-units/da/m1/light-node-verifier" }
 ## execution
-maptos-dof-execution = { path = "protocol-units/execution/dof" }
-maptos-opt-executor = { path = "protocol-units/execution/opt-executor" }
-maptos-fin-view = { path = "protocol-units/execution/fin-view" }
-maptos-execution-util = { path = "protocol-units/execution/util" }
+maptos-dof-execution = { path = "protocol-units/execution/maptos/dof" }
+maptos-opt-executor = { path = "protocol-units/execution/maptos/opt-executor" }
+maptos-fin-view = { path = "protocol-units/execution/maptos/fin-view" }
+maptos-execution-util = { path = "protocol-units/execution/maptos/util" }
 ## infra
 movement-rest = { path = "protocol-units/movement-rest" }
 ## mempool
diff --git a/protocol-units/execution/dof/Cargo.toml b/protocol-units/execution/maptos/dof/Cargo.toml
similarity index 100%
rename from protocol-units/execution/dof/Cargo.toml
rename to protocol-units/execution/maptos/dof/Cargo.toml
diff --git a/protocol-units/execution/dof/src/lib.rs b/protocol-units/execution/maptos/dof/src/lib.rs
similarity index 100%
rename from protocol-units/execution/dof/src/lib.rs
rename to protocol-units/execution/maptos/dof/src/lib.rs
diff --git a/protocol-units/execution/dof/src/services.rs b/protocol-units/execution/maptos/dof/src/services.rs
similarity index 100%
rename from protocol-units/execution/dof/src/services.rs
rename to protocol-units/execution/maptos/dof/src/services.rs
diff --git a/protocol-units/execution/dof/src/v1.rs b/protocol-units/execution/maptos/dof/src/v1.rs
similarity index 100%
rename from protocol-units/execution/dof/src/v1.rs
rename to protocol-units/execution/maptos/dof/src/v1.rs
diff --git a/protocol-units/execution/fin-view/Cargo.toml b/protocol-units/execution/maptos/fin-view/Cargo.toml
similarity index 100%
rename from protocol-units/execution/fin-view/Cargo.toml
rename to protocol-units/execution/maptos/fin-view/Cargo.toml
diff --git a/protocol-units/execution/fin-view/src/fin_view.rs b/protocol-units/execution/maptos/fin-view/src/fin_view.rs
similarity index 100%
rename from protocol-units/execution/fin-view/src/fin_view.rs
rename to protocol-units/execution/maptos/fin-view/src/fin_view.rs
diff --git a/protocol-units/execution/fin-view/src/lib.rs b/protocol-units/execution/maptos/fin-view/src/lib.rs
similarity index 100%
rename from protocol-units/execution/fin-view/src/lib.rs
rename to protocol-units/execution/maptos/fin-view/src/lib.rs
diff --git a/protocol-units/execution/fin-view/src/service.rs b/protocol-units/execution/maptos/fin-view/src/service.rs
similarity index 100%
rename from protocol-units/execution/fin-view/src/service.rs
rename to protocol-units/execution/maptos/fin-view/src/service.rs
diff --git a/protocol-units/execution/opt-executor/Cargo.toml b/protocol-units/execution/maptos/opt-executor/Cargo.toml
similarity index 100%
rename from protocol-units/execution/opt-executor/Cargo.toml
rename to protocol-units/execution/maptos/opt-executor/Cargo.toml
diff --git a/protocol-units/execution/opt-executor/src/background/error.rs b/protocol-units/execution/maptos/opt-executor/src/background/error.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/background/error.rs
rename to protocol-units/execution/maptos/opt-executor/src/background/error.rs
diff --git a/protocol-units/execution/opt-executor/src/background/mod.rs b/protocol-units/execution/maptos/opt-executor/src/background/mod.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/background/mod.rs
rename to protocol-units/execution/maptos/opt-executor/src/background/mod.rs
diff --git a/protocol-units/execution/opt-executor/src/background/read_only.rs b/protocol-units/execution/maptos/opt-executor/src/background/read_only.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/background/read_only.rs
rename to protocol-units/execution/maptos/opt-executor/src/background/read_only.rs
diff --git a/protocol-units/execution/opt-executor/src/background/task.rs b/protocol-units/execution/maptos/opt-executor/src/background/task.rs
similarity index 97%
rename from protocol-units/execution/opt-executor/src/background/task.rs
rename to protocol-units/execution/maptos/opt-executor/src/background/task.rs
index 3fbeddcfd..c9f08145b 100644
--- a/protocol-units/execution/opt-executor/src/background/task.rs
+++ b/protocol-units/execution/maptos/opt-executor/src/background/task.rs
@@ -34,8 +34,8 @@ impl BackgroundTask {
 		mempool_config: &MempoolConfig,
 		transactions_in_flight: Arc<AtomicU64>,
 		transactions_in_flight_limit: u64,
-	) -> Self {
-		Self {
+	) -> Result<Self, anyhow::Error> {
+		Ok(Self {
 			inner: BackgroundInner::Full(TransactionPipe::new(
 				mempool_client_receiver,
 				transaction_sender,
@@ -44,8 +44,8 @@ impl BackgroundTask {
 				mempool_config,
 				transactions_in_flight,
 				transactions_in_flight_limit,
-			)),
-		}
+			)?),
+		})
 	}
 
 	pub(crate) fn read_only(
diff --git a/protocol-units/execution/opt-executor/src/background/transaction_pipe.rs b/protocol-units/execution/maptos/opt-executor/src/background/transaction_pipe.rs
similarity index 96%
rename from protocol-units/execution/opt-executor/src/background/transaction_pipe.rs
rename to protocol-units/execution/maptos/opt-executor/src/background/transaction_pipe.rs
index 61f5244f8..169b1d6fc 100644
--- a/protocol-units/execution/opt-executor/src/background/transaction_pipe.rs
+++ b/protocol-units/execution/maptos/opt-executor/src/background/transaction_pipe.rs
@@ -9,10 +9,12 @@ use aptos_mempool::core_mempool::CoreMempool;
 use aptos_mempool::SubmissionStatus;
 use aptos_mempool::{core_mempool::TimelineState, MempoolClientRequest};
 use aptos_storage_interface::{state_view::LatestDbStateCheckpointView as _, DbReader};
+use aptos_types::account_address::AccountAddress;
 use aptos_types::mempool_status::{MempoolStatus, MempoolStatusCode};
 use aptos_types::transaction::SignedTransaction;
 use aptos_types::vm_status::DiscardedVMStatus;
 use aptos_vm_validator::vm_validator::{self, TransactionValidation, VMValidator};
+use std::collections::HashSet;
 
 use crate::gc_account_sequence_number::UsedSequenceNumberPool;
 use futures::channel::mpsc as futures_mpsc;
@@ -42,6 +44,8 @@ pub struct TransactionPipe {
 	last_gc: Instant,
 	// The pool of used sequence numbers
 	used_sequence_number_pool: UsedSequenceNumberPool,
+	/// The accounts whitelisted for ingress
+	whitelisted_accounts: Option<HashSet<AccountAddress>>,
 }
 
 enum SequenceNumberValidity {
@@ -58,8 +62,8 @@ impl TransactionPipe {
 		mempool_config: &MempoolConfig,
 		transactions_in_flight: Arc<AtomicU64>,
 		transactions_in_flight_limit: u64,
-	) -> Self {
-		TransactionPipe {
+	) -> Result<Self, anyhow::Error> {
+		Ok(TransactionPipe {
 			mempool_client_receiver,
 			transaction_sender,
 			db_reader,
@@ -71,6 +75,14 @@ impl TransactionPipe {
 				mempool_config.sequence_number_ttl_ms,
 				mempool_config.gc_slot_duration_ms,
 			),
+			whitelisted_accounts: mempool_config.whitelisted_accounts()?,
+		})
+	}
+
+	pub fn is_whitelisted(&self, address: &AccountAddress) -> Result<bool, Error> {
+		match &self.whitelisted_accounts {
+			Some(whitelisted_accounts) => Ok(whitelisted_accounts.contains(address)),
+			None => Ok(true),
 		}
 	}
 
@@ -182,6 +194,11 @@ impl TransactionPipe {
 		&mut self,
 		transaction: SignedTransaction,
 	) -> Result<SubmissionStatus, Error> {
+		// Check whether the account is whitelisted
+		if !self.is_whitelisted(&transaction.sender())? {
+			return Ok((MempoolStatus::new(MempoolStatusCode::TooManyTransactions), None));
+		}
+
 		// For now, we are going to consider a transaction in flight until it exits the mempool and is sent to the DA as is indicated by WriteBatch.
 		let in_flight = self.transactions_in_flight.load(std::sync::atomic::Ordering::Relaxed);
 		info!(
diff --git a/protocol-units/execution/opt-executor/src/bootstrap.rs b/protocol-units/execution/maptos/opt-executor/src/bootstrap.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/bootstrap.rs
rename to protocol-units/execution/maptos/opt-executor/src/bootstrap.rs
diff --git a/protocol-units/execution/opt-executor/src/context.rs b/protocol-units/execution/maptos/opt-executor/src/context.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/context.rs
rename to protocol-units/execution/maptos/opt-executor/src/context.rs
diff --git a/protocol-units/execution/opt-executor/src/executor/execution.rs b/protocol-units/execution/maptos/opt-executor/src/executor/execution.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/executor/execution.rs
rename to protocol-units/execution/maptos/opt-executor/src/executor/execution.rs
diff --git a/protocol-units/execution/opt-executor/src/executor/initialization.rs b/protocol-units/execution/maptos/opt-executor/src/executor/initialization.rs
similarity index 99%
rename from protocol-units/execution/opt-executor/src/executor/initialization.rs
rename to protocol-units/execution/maptos/opt-executor/src/executor/initialization.rs
index a71e0a5cd..0f90631e6 100644
--- a/protocol-units/execution/opt-executor/src/executor/initialization.rs
+++ b/protocol-units/execution/maptos/opt-executor/src/executor/initialization.rs
@@ -147,7 +147,7 @@ impl Executor {
 				&self.config.mempool,
 				Arc::clone(&self.transactions_in_flight),
 				maptos_config.load_shedding.max_transactions_in_flight,
-			)
+			)?
 		};
 
 		let cx = Context::new(self.db().clone(), mempool_client_sender, maptos_config, node_config);
diff --git a/protocol-units/execution/opt-executor/src/executor/mod.rs b/protocol-units/execution/maptos/opt-executor/src/executor/mod.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/executor/mod.rs
rename to protocol-units/execution/maptos/opt-executor/src/executor/mod.rs
diff --git a/protocol-units/execution/opt-executor/src/gc_account_sequence_number.rs b/protocol-units/execution/maptos/opt-executor/src/gc_account_sequence_number.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/gc_account_sequence_number.rs
rename to protocol-units/execution/maptos/opt-executor/src/gc_account_sequence_number.rs
diff --git a/protocol-units/execution/opt-executor/src/indexer.rs b/protocol-units/execution/maptos/opt-executor/src/indexer.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/indexer.rs
rename to protocol-units/execution/maptos/opt-executor/src/indexer.rs
diff --git a/protocol-units/execution/opt-executor/src/lib.rs b/protocol-units/execution/maptos/opt-executor/src/lib.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/lib.rs
rename to protocol-units/execution/maptos/opt-executor/src/lib.rs
diff --git a/protocol-units/execution/opt-executor/src/service.rs b/protocol-units/execution/maptos/opt-executor/src/service.rs
similarity index 100%
rename from protocol-units/execution/opt-executor/src/service.rs
rename to protocol-units/execution/maptos/opt-executor/src/service.rs
diff --git a/protocol-units/execution/util/Cargo.toml b/protocol-units/execution/maptos/util/Cargo.toml
similarity index 96%
rename from protocol-units/execution/util/Cargo.toml
rename to protocol-units/execution/maptos/util/Cargo.toml
index e041b8735..bff9503a4 100644
--- a/protocol-units/execution/util/Cargo.toml
+++ b/protocol-units/execution/maptos/util/Cargo.toml
@@ -25,5 +25,6 @@ serde_derive = { workspace = true }
 toml = { workspace = true }
 godfig = { workspace = true }
 hex = { workspace = true }
+tokio = { workspace =  true }
 
 aptos-sdk = { workspace = true }
diff --git a/protocol-units/execution/util/src/config/chain.rs b/protocol-units/execution/maptos/util/src/config/chain.rs
similarity index 100%
rename from protocol-units/execution/util/src/config/chain.rs
rename to protocol-units/execution/maptos/util/src/config/chain.rs
diff --git a/protocol-units/execution/util/src/config/client.rs b/protocol-units/execution/maptos/util/src/config/client.rs
similarity index 100%
rename from protocol-units/execution/util/src/config/client.rs
rename to protocol-units/execution/maptos/util/src/config/client.rs
diff --git a/protocol-units/execution/util/src/config/common.rs b/protocol-units/execution/maptos/util/src/config/common.rs
similarity index 96%
rename from protocol-units/execution/util/src/config/common.rs
rename to protocol-units/execution/maptos/util/src/config/common.rs
index 81608376e..9cec66a60 100644
--- a/protocol-units/execution/util/src/config/common.rs
+++ b/protocol-units/execution/maptos/util/src/config/common.rs
@@ -2,7 +2,8 @@ use std::str::FromStr;
 
 use aptos_crypto::{ed25519::Ed25519PrivateKey, Genesis, ValidCryptoMaterialStringExt};
 use aptos_types::chain_id::ChainId;
-use godfig::env_default;
+use godfig::{env_default, env_or_none};
+use std::collections::HashSet;
 
 // The default Maptos API listen hostname
 env_default!(
@@ -167,3 +168,5 @@ env_default!(default_max_transactions_in_flight, "MAPTOS_MAX_TRANSACTIONS_IN_FLI
 env_default!(default_sequence_number_ttl_ms, "MAPTOS_SEQUENCE_NUMBER_TTL_MS", u64, 1000 * 60 * 3);
 
 env_default!(default_gc_slot_duration_ms, "MAPTOS_GC_SLOT_DURATION_MS", u64, 1000 * 2);
+
+env_default!(default_ingress_account_whitelist, "MAPTOS_INGRESS_ACCOUNT_WHITELIST", String);
diff --git a/protocol-units/execution/util/src/config/faucet.rs b/protocol-units/execution/maptos/util/src/config/faucet.rs
similarity index 100%
rename from protocol-units/execution/util/src/config/faucet.rs
rename to protocol-units/execution/maptos/util/src/config/faucet.rs
diff --git a/protocol-units/execution/util/src/config/fin.rs b/protocol-units/execution/maptos/util/src/config/fin.rs
similarity index 100%
rename from protocol-units/execution/util/src/config/fin.rs
rename to protocol-units/execution/maptos/util/src/config/fin.rs
diff --git a/protocol-units/execution/util/src/config/indexer.rs b/protocol-units/execution/maptos/util/src/config/indexer.rs
similarity index 100%
rename from protocol-units/execution/util/src/config/indexer.rs
rename to protocol-units/execution/maptos/util/src/config/indexer.rs
diff --git a/protocol-units/execution/util/src/config/indexer_processor.rs b/protocol-units/execution/maptos/util/src/config/indexer_processor.rs
similarity index 100%
rename from protocol-units/execution/util/src/config/indexer_processor.rs
rename to protocol-units/execution/maptos/util/src/config/indexer_processor.rs
diff --git a/protocol-units/execution/util/src/config/load_shedding.rs b/protocol-units/execution/maptos/util/src/config/load_shedding.rs
similarity index 100%
rename from protocol-units/execution/util/src/config/load_shedding.rs
rename to protocol-units/execution/maptos/util/src/config/load_shedding.rs
diff --git a/protocol-units/execution/maptos/util/src/config/mempool.rs b/protocol-units/execution/maptos/util/src/config/mempool.rs
new file mode 100644
index 000000000..11ed307dd
--- /dev/null
+++ b/protocol-units/execution/maptos/util/src/config/mempool.rs
@@ -0,0 +1,53 @@
+use super::common::{
+	default_gc_slot_duration_ms, default_ingress_account_whitelist, default_sequence_number_ttl_ms,
+};
+use aptos_types::account_address::AccountAddress;
+use serde::{Deserialize, Serialize};
+use std::collections::HashSet;
+
+#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+pub struct Config {
+	/// The number of milliseconds a sequence number is valid for.
+	#[serde(default = "default_sequence_number_ttl_ms")]
+	pub sequence_number_ttl_ms: u64,
+
+	/// The duration of a garbage collection slot in milliseconds.
+	#[serde(default = "default_gc_slot_duration_ms")]
+	pub gc_slot_duration_ms: u64,
+
+	/// The whitelist (path) for the mempool
+	#[serde(default = "default_ingress_account_whitelist")]
+	pub ingress_account_whitelist: Option<String>,
+}
+
+impl Default for Config {
+	fn default() -> Self {
+		Self {
+			sequence_number_ttl_ms: default_sequence_number_ttl_ms(),
+			gc_slot_duration_ms: default_gc_slot_duration_ms(),
+			ingress_account_whitelist: default_ingress_account_whitelist(),
+		}
+	}
+}
+
+impl Config {
+	pub fn whitelisted_accounts(&self) -> Result<Option<HashSet<AccountAddress>>, anyhow::Error> {
+		match &self.ingress_account_whitelist {
+			Some(whitelist_path) => {
+				let mut whitelisted = HashSet::new();
+
+				// read the file from memory
+				let file_string = String::from_utf8(std::fs::read(whitelist_path)?)?;
+
+				// for each line
+				for line in file_string.lines() {
+					let account = AccountAddress::from_hex(line.trim())?;
+					whitelisted.insert(account);
+				}
+
+				Ok(Some(whitelisted))
+			}
+			None => Ok(None),
+		}
+	}
+}
diff --git a/protocol-units/execution/util/src/config/mod.rs b/protocol-units/execution/maptos/util/src/config/mod.rs
similarity index 100%
rename from protocol-units/execution/util/src/config/mod.rs
rename to protocol-units/execution/maptos/util/src/config/mod.rs
diff --git a/protocol-units/execution/util/src/lib.rs b/protocol-units/execution/maptos/util/src/lib.rs
similarity index 100%
rename from protocol-units/execution/util/src/lib.rs
rename to protocol-units/execution/maptos/util/src/lib.rs
diff --git a/protocol-units/execution/util/src/config/mempool.rs b/protocol-units/execution/util/src/config/mempool.rs
deleted file mode 100644
index b2f057e4c..000000000
--- a/protocol-units/execution/util/src/config/mempool.rs
+++ /dev/null
@@ -1,25 +0,0 @@
-use super::common::{default_gc_slot_duration_ms, default_sequence_number_ttl_ms};
-use aptos_crypto::ed25519::Ed25519PrivateKey;
-use aptos_types::chain_id::ChainId;
-use serde::{Deserialize, Serialize};
-use std::path::PathBuf;
-
-#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
-pub struct Config {
-	/// The number of milliseconds a sequence number is valid for.
-	#[serde(default = "default_sequence_number_ttl_ms")]
-	pub sequence_number_ttl_ms: u64,
-
-	/// The duration of a garbage collection slot in milliseconds.
-	#[serde(default = "default_gc_slot_duration_ms")]
-	pub gc_slot_duration_ms: u64,
-}
-
-impl Default for Config {
-	fn default() -> Self {
-		Self {
-			sequence_number_ttl_ms: default_sequence_number_ttl_ms(),
-			gc_slot_duration_ms: default_gc_slot_duration_ms(),
-		}
-	}
-}