hadoop_common/net/
net_utils.rs

1use anyhow::Error;
2use std::net::{SocketAddr, ToSocketAddrs};
3
4pub struct NetUtils;
5
6impl NetUtils {
7    pub fn create_socket_addr_for_host(host: &str, port: i32) -> anyhow::Result<SocketAddr> {
8        // TODO: resolve host
9
10        Ok(format!("{}:{}", host, port)
11            .to_socket_addrs()?
12            .filter(|s| s.is_ipv4())
13            .last()
14            .ok_or(Error::msg(format!(
15                "Does not contain a valid host:port authority: {}:{}",
16                host, port
17            )))?)
18    }
19}