Struct NodeManager 

pub(crate) struct NodeManager {
    datadir: Option<String>,
    metrics_port: u16,
    chain: Chain,
    use_sudo: bool,
    binary_path: Option<PathBuf>,
    enable_profiling: bool,
    output_dir: PathBuf,
    additional_reth_args: Vec<String>,
    comparison_dir: Option<PathBuf>,
    tracing_endpoint: Option<String>,
    otlp_max_queue_size: usize,
}

Manages reth node lifecycle and operations

Fields

datadir: Option<String>

metrics_port: u16

chain: Chain

use_sudo: bool

binary_path: Option<PathBuf>

enable_profiling: bool

output_dir: PathBuf

additional_reth_args: Vec<String>

comparison_dir: Option<PathBuf>

tracing_endpoint: Option<String>

otlp_max_queue_size: usize

Implementations

impl NodeManager

pub(crate) fn new(args: &Args) -> Self

Create a new NodeManager with configuration from CLI args

pub(crate) fn set_comparison_dir(&mut self, dir: PathBuf)

Set the comparison directory path for logging

fn get_log_file_path(&self, ref_type: &str) -> Result<PathBuf>

Get the log file path for a given reference type

fn get_perf_sample_rate(&self) -> Option<String>

Get the perf event max sample rate from the system, capped at 10000

async fn get_samply_path(&self) -> Result<String>

Get the absolute path to samply using ‘which’ command

fn build_reth_args( &self, binary_path_str: &str, additional_args: &[String], ref_type: &str, ) -> (Vec<String>, String)

Build reth arguments as a vector of strings

async fn create_profiling_command( &self, ref_type: &str, reth_args: &[String], ) -> Result<Command>

Create a command for profiling mode

fn create_direct_command(&self, reth_args: &[String]) -> Command

Create a command for direct reth execution

pub(crate) async fn start_node( &mut self, binary_path: &Path, _git_ref: &str, ref_type: &str, additional_args: &[String], ) -> Result<Child>

Start a reth node using the specified binary path and return the process handle

pub(crate) async fn wait_for_node_ready_and_get_tip(&self) -> Result<u64>

Wait for the node to be ready and return its current tip

pub(crate) async fn stop_node(&self, child: &mut Child) -> Result<()>

Stop the reth node gracefully

pub(crate) async fn unwind_to_block(&self, block_number: u64) -> Result<()>

Unwind the node to a specific block

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 176 bytes