Struct TernNode 

pub struct TernNode {
    pub addr: String,
    /* private fields */
}

The ternlang distributed node. Manages local agent mailboxes and TCP connections to peer nodes.

Fields

addr: String

Implementations

impl TernNode

pub fn new(addr: &str) -> Self

pub fn register_agent(&self, agent_id: usize)

Register a local agent so it can receive remote messages.

pub fn listen(&self)

Start the TCP listener in a background thread. Incoming messages are dispatched to local agent mailboxes.

pub fn connect(&self, peer_addr: &str) -> Result<()>

Connect to a peer node, storing the stream for future sends.

pub fn remote_send( &self, peer_addr: &str, agent_id: usize, trit: i8, ) -> Result<()>

Send a trit to a remote agent’s mailbox.

pub fn remote_await(&self, peer_addr: &str, agent_id: usize) -> Result<i8>

Trigger a remote agent to process its mailbox and return the result trit.

pub fn local_send(&self, agent_id: usize, trit: i8)

Push a trit directly into a local agent’s mailbox (no network).

pub fn local_pop(&self, agent_id: usize) -> i8

Pop a trit from a local agent’s mailbox (returns 0 if empty).

Trait Implementations

impl RemoteTransport for TernNode

Implement the VM’s RemoteTransport trait so TernNode can be injected directly into BetVm::set_remote(Arc::new(node)).

fn remote_send(&self, node_addr: &str, agent_id: usize, trit: i8) -> Result<()>

Send a trit (-1/0/+1) to the specified remote agent’s mailbox (fire-and-forget).

fn remote_await(&self, node_addr: &str, agent_id: usize) -> Result<i8>

Request the remote agent to process its mailbox and return the result trit.