Struct OcamlNode 

pub struct OcamlNode {
    child: Child,
    executable: OcamlNodeExecutable,
    pub libp2p_port: u16,
    pub graphql_port: u16,
    peer_id: PeerId,
    temp_dir: TempDir,
}

Fields

child: Child

executable: OcamlNodeExecutable

libp2p_port: u16

graphql_port: u16

peer_id: PeerId

temp_dir: TempDir

Implementations

impl OcamlNode

const PRIVKEY_PATH: &'static str = ".libp2p/key"

const LIBP2P_KEYS: [(&'static str, &'static str); 10]

pub fn start(config: OcamlNodeConfig) -> Result<Self>

pub fn dial_addr(&self) -> P2pConnectionOutgoingInitOpts

pub fn peer_id(&self) -> PeerId

pub async fn exec(&mut self, step: OcamlStep) -> Result<bool>

fn kill(&mut self) -> Result<()>

fn privkey_path(dir: &Path) -> PathBuf

fn read_peer_id(dir: &Path) -> Result<String>

fn make_dir_rec(path: &Path) -> Result<()>

fn generate_libp2p_keypair( config: &OcamlNodeConfig, dir: &Path, ) -> Result<String>

fn read_stream<R: Read, W: Write>(from: R, to: W, prefix: &str) -> Result<()>

pub async fn chain_id(&self) -> Result<ChainId>

Queries graphql to get chain_id.

pub async fn synced_best_tip(&self) -> Result<Option<StateHash>>

Queries graphql to check if ocaml node is synced, returning it’s best tip hash if yes.

fn graphql_addr(&self) -> String

pub async fn grapql_query(&self, query: &str) -> Result<Value>

async fn wait_for_p2p(&self, timeout: Duration) -> Result<()>

async fn wait_for_synced(&self, timeout: Duration) -> Result<()>

Trait Implementations

impl Drop for OcamlNode

fn drop(&mut self)

Executes the destructor for this type.