actix-telepathy 0.7.0

Cluster extension for the actix actor framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use std::net::SocketAddr;

use port_scanner::request_open_port;

pub(crate) mod cluster_listener;

pub(crate) fn get_n_local_socket_addrs(n: usize) -> Vec<SocketAddr> {
    let mut addrs = Vec::new();
    for _ in 0..n {
        addrs.push(
            format!("127.0.0.1:{}", request_open_port().unwrap_or(8000))
                .parse()
                .unwrap(),
        );
    }
    addrs
}