Struct Addr

Source

pub struct Addr { /* private fields */ }

Expand description

Unique actor addresses based on IP, PORT and names. Some fields are later extension points

Implementations§

Source §

impl Addr

Source

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

A new local actor address - bound to be unique. Actors with same name will have different ids based on system ports even if multiple instances of the arrows systems are running on the same node

Examples found in repository ?

examples/send.rs (line 14)

4fn main() {
5    let m1 = Msg::from_text("Message to new_actor");
6    let m2 = Msg::from_text("Message to new_actor");
7    let m3 = Msg::from_text("Message to new_actor");
8
9    send!("demo_actor", (m1, m2, m3));
10
11    let mut m4 = Msg::from_text("Message to another_actor");
12
13    //Impersonate sender as "new_actor"
14    m4.set_from(&Addr::new("demo_actor"));
15
16    send!("another_actor", m4);
17}

Source

pub fn remote(name: &str, hostport: &str) -> Self

An actor running on a different local or remote system

Examples found in repository ?

examples/scratch.rs (line 13)

5pub fn main() {
6    let m1 = Msg::from_text("Message to actor1");
7    let m2 = Msg::from_text("Message to actor1");
8    let m3 = Msg::from_text("Message to actor2");
9    let m4 = Msg::from_text("Message to actor1");
10    let m5 = Msg::from_text("Message to actor1");
11    send!("actor1", (m1, m2), "actor2", (m3), "actor1", (m4, m5));
12
13    let remote_addr1 = Addr::remote("actor1", "10.10.10.10:7171");
14    let remote_addr2 = Addr::remote("actor2", "11.11.11.11:8181");
15
16    let m1 = Msg::from_text("Message to remote actor1");
17    let m2 = Msg::from_text("Message to remote actor1");
18    let m3 = Msg::from_text("Message to remote actor2");
19    let m4 = Msg::from_text("Message to remote actor2");
20
21    send!(remote_addr1, (m1, m2), remote_addr2, (m3, m4));
22}

Source

pub fn with_port(&mut self, port: u16)

Alter the port - to talk to different system

Source

pub fn with_ip(&mut self, ip: &str)

Alter the IP - as requried

Source

pub fn get_name(&self) -> &String

Human readable name of an actor

Source

pub fn get_id(&self) -> u64

Internally used by the system for unique address identification

Source

pub fn get_host_ip(&self) -> IpAddr

Address host ip

Source

pub fn is_ip_local(ip: IpAddr) -> bool

Needed for support remoting - used to decide if listener should be booted if not already up if message comes in

Source

pub fn is_local_ip(&self) -> bool

Mostly for routing decisions

Source

pub fn is_local_port(&self) -> bool

Routing

Source

pub fn is_local(&self) -> bool

Is the local - based on port or ip or both together

Source

pub fn get_host(&self) -> Option<&String>

Handle to host

Source

pub fn get_port(&self) -> Option<u16>

Handle to port

Source

pub fn as_bytes(&self) -> Vec<u8> ⓘ

For serialization

Source

pub fn listen_addr() -> Self

The address of the listener

Examples found in repository ?

examples/shutdown.rs (line 6)

5fn main() {
6    let _rs = send!(Addr::listen_addr(), Msg::shutdown());
7}

More examples

Hide additional examples

examples/echo.rs (line 10)

5fn main() {
6    //Fire an echo message to the listener - it should reverse the string and send it back if
7    //alive
8    let m = Msg::echo("This is an echo message back from the listener");
9    //let m = Msg::echo("renetsil eht morf kcab egassem ohce na si sihT");
10    send!(Addr::listen_addr(), m);
11}