Struct JamNetworkNode 

pub struct JamNetworkNode { /* private fields */ }

A running JAM node.

Same provider-generic behaviour as any other node (see NodeCore), plus the JAM specifics: the libp2p peer identity used to build bootnode addresses, the node mode and the rpc endpoint.

Unlike NetworkNode it exposes no subxt client and no Prometheus metrics assertions, since JAM nodes serve neither.

Implementations

impl JamNetworkNode

pub fn core(&self) -> &NodeCore

The provider-generic part of this node.

pub fn name(&self) -> &str

pub fn spec(&self) -> &JamNodeSpec

pub fn mode(&self) -> &JamNodeMode

Mode this node runs in (ordinary, validator or proxy).

pub fn peer_id(&self) -> &str

The node libp2p local identity.

pub fn peer_addr(&self) -> &str

{peer_id}@{ip}:{port}, as passed to other nodes with --bootnode.

pub fn rpc_uri(&self) -> &str

ip:rpc_port.

NOTE: only nodes running in JamNodeMode::Ordinary are started with --rpc-port, so this is not bound for validators/proxies.

pub fn ws_uri(&self) -> String

pub async fn is_responsive(&self) -> bool

Check if the node is responsive by attempting to connect to it.

This performs an actual connection attempt with a short timeout (2 seconds). Returns true if the node is reachable and responding, false otherwise.

This is more robust than is_running() as it verifies the node is actually alive.

pub async fn restart_with( &self, assets: Vec<AssetLocation>, program: Option<String>, args: Option<Vec<Arg>>, after: Option<Duration>, ) -> Result<(), Error>

Restart the node using the optional provided:

• Assets: binaries to download
• cmd: program to exec.
• args: Arguments to override the ones provided in config.

The node will be restarted with the same env and isolated directory (e.g same database).

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

Wait until get the [WsClient] for the node

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

Wait until get the [WsClient] for the node with a defined timeout

Trait Implementations

impl Clone for JamNetworkNode

fn clone(&self) -> JamNetworkNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JamNetworkNode

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

Formats the value using the given formatter.

impl Serialize for JamNetworkNode

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.

impl SpawnedNode for JamNetworkNode

fn wait_until_is_up<'life0, 'async_trait>( &'life0 self, timeout_secs: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, JamNetworkNode: 'async_trait,

JAM nodes expose no Prometheus endpoint, so readiness is established by connecting to the port the node binds for its mode.

fn core(&self) -> &NodeCore

The provider handle and runtime state of this node.

fn kind(&self) -> NodeKind

What flavour of node this is.

fn name(&self) -> &str

fn is_running(&self) -> bool

fn last_start_ts(&self) -> u64

fn base_dir(&self) -> &PathBuf

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

fn logs<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn pause<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn resume<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn restart<'life0, 'async_trait>( &'life0 self, after: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,