Struct NetworkNode 

pub struct NetworkNode { /* private fields */ }

Implementations

impl NetworkNode

pub fn name(&self) -> &str

pub fn args(&self) -> Vec<&str>

pub fn spec(&self) -> &NodeSpec

pub fn ws_uri(&self) -> &str

pub fn multiaddr(&self) -> &str

pub async fn rpc(&self) -> Result<RpcClient, Error>

Get the rpc client for the node

pub async fn client<Config>(&self) -> Result<OnlineClient<Config>, Error>

where Config: Config,

👎Deprecated: Use wait_client instead.

Get the online client for the node

pub async fn try_client<Config>(&self) -> Result<OnlineClient<Config>, Error>

where Config: Config,

Try to connect to the node.

Most of the time you only want to use NetworkNode::wait_client that waits for the node to appear before it connects to it. This function directly tries to connect to the node and returns an error if the node is not yet available at that point in time.

Returns a [OnlineClient] on success.

pub async fn wait_client<Config>(&self) -> Result<OnlineClient<Config>, Error>

where Config: Config,

Wait until get the online client for the node

pub async fn wait_client_with_timeout<Config>( &self, timeout_secs: impl Into<u64>, ) -> Result<OnlineClient<Config>, Error>

where Config: Config,

Wait until get the online client for the node with a defined timeout

pub async fn pause(&self) -> Result<(), Error>

Pause the node, this is implemented by pausing the actual process (e.g polkadot) with sending SIGSTOP signal

Note: Using this method with the native provider is currently unsupported.

pub async fn resume(&self) -> Result<(), Error>

Resume the node, this is implemented by resuming the actual process (e.g polkadot) with sending SIGCONT signal

Note: Using this method with the native provider is currently unsupported.

pub async fn restart(&self, after: Option<Duration>) -> Result<(), Error>

Restart the node using the same cmd, args and env (and same isolated dir)

Note: Using this method with the native provider is currently unsupported.

pub async fn reports( &self, metric_name: impl Into<String>, ) -> Result<f64, Error>

Get metric value ‘by name’ from Prometheus (exposed by the node) metric name can be: with prefix (e.g: ‘polkadot_’) with chain attribute (e.g: ‘chain=rococo-local’) without prefix and/or without chain attribute

pub async fn assert( &self, metric_name: impl Into<String>, value: impl Into<f64>, ) -> Result<bool, Error>

Assert on a metric value ‘by name’ from Prometheus (exposed by the node) metric name can be: with prefix (e.g: ‘polkadot_’) with chain attribute (e.g: ‘chain=rococo-local’) without prefix and/or without chain attribute

We first try to assert on the value using the cached metrics and if not meet the criteria we reload the cache and check again

pub async fn assert_with( &self, metric_name: impl Into<String>, predicate: impl Fn(f64) -> bool, ) -> Result<bool, Error>

Assert on a metric value using a given predicate. See NetworkNode::reports description for details on metric name.

pub async fn wait_metric( &self, metric_name: impl Into<String>, predicate: impl Fn(f64) -> bool, ) -> Result<(), Error>

Wait until a metric value pass the predicate

pub async fn wait_metric_with_timeout( &self, metric_name: impl Into<String>, predicate: impl Fn(f64) -> bool, timeout_secs: impl Into<u64>, ) -> Result<(), Error>

Wait until a metric value pass the predicate with a timeout (secs)

pub async fn logs(&self) -> Result<String, Error>

Get the logs of the node TODO: do we need the since param, maybe we could be handy later for loop filtering

pub async fn wait_log_line_count( &self, pattern: impl Into<String>, is_glob: bool, count: usize, ) -> Result<(), Error>

Wait until a the number of matching log lines is reach

pub async fn wait_log_line_count_with_timeout( &self, substring: impl Into<String>, is_glob: bool, options: LogLineCountOptions, ) -> Result<LogLineCount, Error>

Waits until the number of matching log lines satisfies a custom condition, optionally waiting for the entire duration of the timeout.

This method searches log lines for a given substring or glob pattern, and evaluates the number of matching lines using a user-provided predicate function. Optionally, it can wait for the full timeout duration to ensure the condition holds consistently (e.g., for verifying absence of logs).

Arguments

• substring - The substring or pattern to match within log lines.
• is_glob - Whether to treat substring as a glob pattern (true) or a regex (false).
• options - Configuration for timeout, match count predicate, and full-duration waiting.

Returns

• Ok(LogLineCount::TargetReached(n)) if the predicate was satisfied within the timeout,
• Ok(LogLineCount::TargetFails(n)) if the predicate was not satisfied in time,
• Err(e) if an error occurred during log retrieval or matching.

Example

let node = network.get_node("alice")?;
// Wait (up to 10 seconds) until pattern occurs once
let options = LogLineCountOptions {
    predicate: Arc::new(|count| count == 1),
    timeout: Duration::from_secs(10),
    wait_until_timeout_elapses: false,
};
let result = node
    .wait_log_line_count_with_timeout("error", false, options)
    .await?;

pub async fn wait_until_is_up( &self, timeout_secs: impl Into<u64>, ) -> Result<(), Error>

Waits given number of seconds until node reports that it is up and running, which is determined by metric ‘process_start_time_seconds’, which should appear, when node finished booting up.

Arguments

• timeout_secs - The number of seconds to wait.

Returns

• Ok() if the node is up before timeout occured.
• Err(e) if timeout or other error occurred while waiting.

Trait Implementations

impl Clone for NetworkNode

fn clone(&self) -> NetworkNode

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NetworkNode

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Serialize for NetworkNode

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.