Struct Node 

pub struct Node { /* private fields */ }

Implementations

impl Node

pub async fn erlang_system_info( &self, remote_node: &str, item: &str, ) -> Result<OwnedTerm>

pub async fn erlang_statistics( &self, remote_node: &str, item: &str, ) -> Result<OwnedTerm>

pub async fn erlang_memory(&self, remote_node: &str) -> Result<OwnedTerm>

pub async fn erlang_processes(&self, remote_node: &str) -> Result<OwnedTerm>

pub async fn erlang_process_info( &self, remote_node: &str, pid: OwnedTerm, items: Vec<Atom>, ) -> Result<OwnedTerm>

pub async fn erlang_list_to_pid( &self, remote_node: &str, pid_str: &str, ) -> Result<OwnedTerm>

impl Node

pub fn new(name: impl Into<String>, cookie: impl Into<String>) -> Self

pub fn new_hidden(name: impl Into<String>, cookie: impl Into<String>) -> Self

pub async fn connect_to( name: impl Into<String>, cookie: impl Into<String>, remote_node: impl Into<String>, ) -> Result<Self>

pub async fn connect_to_hidden( name: impl Into<String>, cookie: impl Into<String>, remote_node: impl Into<String>, ) -> Result<Self>

pub fn registry(&self) -> Arc<ProcessRegistry>

pub async fn start(&mut self, port: u16) -> Result<()>

pub async fn connect(&self, remote_node: impl Into<String>) -> Result<()>

pub async fn spawn<P: Process>(&self, process: P) -> Result<ExternalPid>

pub async fn register(&self, name: Atom, pid: ExternalPid) -> Result<()>

pub async fn unregister(&self, name: &Atom) -> Result<()>

pub async fn whereis(&self, name: &Atom) -> Option<ExternalPid>

pub async fn registered(&self) -> Vec<Atom>

pub async fn send(&self, to: &ExternalPid, message: OwnedTerm) -> Result<()>

pub async fn send_to_name(&self, to: &Atom, message: OwnedTerm) -> Result<()>

pub async fn link(&self, from: &ExternalPid, to: &ExternalPid) -> Result<()>

pub async fn unlink(&self, from: &ExternalPid, to: &ExternalPid) -> Result<()>

pub fn make_reference(&self) -> ExternalReference

pub async fn monitor( &self, from: &ExternalPid, to: &ExternalPid, ) -> Result<ExternalReference>

pub async fn demonitor( &self, from: &ExternalPid, to: &ExternalPid, reference: &ExternalReference, ) -> Result<()>

pub fn name(&self) -> &Atom

pub fn creation(&self) -> u32

pub async fn process_count(&self) -> usize

pub fn connections(&self) -> Arc<DashMap<String, Arc<Mutex<Connection>>>>

pub fn cookie(&self) -> &str

pub async fn rpc_call( &self, remote_node: &str, module: &str, function: &str, args: Vec<OwnedTerm>, ) -> Result<OwnedTerm>

pub async fn rpc_call_with_timeout( &self, remote_node: &str, module: &str, function: &str, args: Vec<OwnedTerm>, timeout: Duration, ) -> Result<OwnedTerm>

pub async fn rpc_call_raw( &self, remote_node: &str, module: &str, function: &str, args: Vec<OwnedTerm>, ) -> Result<OwnedTerm>

pub async fn rpc_call_raw_with_timeout( &self, remote_node: &str, module: &str, function: &str, args: Vec<OwnedTerm>, timeout: Duration, ) -> Result<OwnedTerm>