github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-27 08:08:15 -05:00
Code Issues Packages Projects Releases Wiki Activity

chore: rename EngineApiTreeHandler (#10140)

Browse Source
This commit is contained in:
Matthias Seitz
2024-08-06 17:00:29 +02:00
committed by GitHub
parent 92b2e6137f
commit eb731762ec
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
crates/engine/tree/src/tree/mod.rs
View File

@@ -358,7 +358,7 @@ pub enum TreeAction {
/// This type is responsible for processing engine API requests, maintaining the canonical state and
/// emitting events.
#[derive(Debug)]
pub struct EngineApiTreeHandlerImpl<P, E, T: EngineTypes> {
pub struct EngineApiTreeHandler<P, E, T: EngineTypes> {
provider: P,
executor_provider: E,
consensus: Arc<dyn Consensus>,
@@ -387,7 +387,7 @@ pub struct EngineApiTreeHandlerImpl<P, E, T: EngineTypes> {
metrics: EngineApiMetrics,
}
impl<P, E, T> EngineApiTreeHandlerImpl<P, E, T>
impl<P, E, T> EngineApiTreeHandler<P, E, T>
where
P: BlockReader + StateProviderFactory + Clone + 'static,
E: BlockExecutorProvider,
@@ -1942,7 +1942,7 @@ mod tests {
use tokio::sync::mpsc::unbounded_channel;
struct TestHarness {
tree: EngineApiTreeHandlerImpl<MockEthProvider, MockExecutorProvider, EthEngineTypes>,
tree: EngineApiTreeHandler<MockEthProvider, MockExecutorProvider, EthEngineTypes>,
to_tree_tx: Sender<FromEngine<BeaconEngineMessage<EthEngineTypes>>>,
from_tree_rx: UnboundedReceiver<EngineApiEvent>,
blocks: Vec<ExecutedBlock>,
@@ -1973,7 +1973,7 @@ mod tests {
let (to_payload_service, _payload_command_rx) = unbounded_channel();
let payload_builder = PayloadBuilderHandle::new(to_payload_service);
let tree = EngineApiTreeHandlerImpl::new(
let tree = EngineApiTreeHandler::new(
provider,
executor_provider.clone(),
consensus,

4
crates/ethereum/engine/src/service.rs
View File

@@ -8,7 +8,7 @@ use reth_engine_tree::{
download::BasicBlockDownloader,
engine::{EngineApiRequestHandler, EngineHandler},
persistence::PersistenceHandle,
tree::{EngineApiTreeHandlerImpl, TreeConfig},
tree::{EngineApiTreeHandler, TreeConfig},
};
pub use reth_engine_tree::{
chain::{ChainEvent, ChainOrchestrator},
@@ -81,7 +81,7 @@ where
let canonical_in_memory_state = blockchain_db.canonical_in_memory_state();
let from_tree = EngineApiTreeHandlerImpl::spawn_new(
let from_tree = EngineApiTreeHandler::spawn_new(
blockchain_db,
executor_factory,
consensus,