pub struct NetworkAddress(/* private fields */);Expand description
§Overview
Diem NetworkAddress is a compact, efficient, self-describing and
future-proof network address represented as a stack of protocols.
Essentially libp2p’s multiaddr but using [bcs] to describe the binary
format.
Most validators will advertise a network address like:
/dns/example.com/tcp/6180/ln-noise-ik/<x25519-pubkey>/ln-handshake/1
Unpacking, the above effectively means:
- Resolve the DNS name “example.com” to an ip address, 
addr. - Open a TCP connection to 
(addr, 6180). - Perform a Noise IK handshake and assume the peer’s static pubkey is
<x25519-pubkey>. After this step, we will have a secure, authenticated connection with the peer. - Perform a DiemNet version negotiation handshake (version 1).
 
§Self-describing, Upgradable
One key concept behind NetworkAddress is that it is fully self-describing,
which allows us to easily “pre-negotiate” protocols while also allowing for
future upgrades. For example, it is generally unsafe to negotiate a secure
transport in-band. Instead, with NetworkAddress we can advertise (via
discovery) the specific secure transport protocol and public key that we
support (and even advertise multiple incompatible versions). When a peer
wishes to establish a connection with us, they already know which secure
transport protocol to use; in this sense, the secure transport protocol is
“pre-negotiated” by the dialier selecting which advertised protocol to use.
Each network address is encoded with the length of the encoded
NetworkAddress and then the serialized protocol slices to allow for
transparent upgradeability. For example, if the current software cannot
decode a NetworkAddress within a Vec<NetworkAddress> it can still decode
the underlying Vec<u8> and retrieve the remaining Vec<NetworkAddress>.
§Transport
In addition, NetworkAddress is integrated with the DiemNet concept of a
Transport, which takes a NetworkAddress when dialing and peels off
Protocols to establish a connection and perform initial handshakes.
Similarly, the Transport takes NetworkAddress to listen on, which
tells it what protocols to expect on the socket.
§Example
An example of a serialized NetworkAddress:
// human-readable format:
//
//   "/ip4/10.0.0.16/tcp/80"
//
// serialized NetworkAddress:
//
//      [ 09 02 00 0a 00 00 10 05 80 00 ]
//          \  \  \  \           \  \
//           \  \  \  \           \  '-- u16 tcp port
//            \  \  \  \           '-- uvarint protocol id for /tcp
//             \  \  \  '-- u32 ipv4 address
//              \  \  '-- uvarint protocol id for /ip4
//               \  '-- uvarint number of protocols
//                '-- length of encoded network address
use bcs;
use diem_types::network_address::NetworkAddress;
use std::{convert::TryFrom, str::FromStr};
let addr = NetworkAddress::from_str("/ip4/10.0.0.16/tcp/80").unwrap();
let actual_ser_addr = bcs::to_bytes(&addr).unwrap();
let expected_ser_addr: Vec<u8> = [9, 2, 0, 10, 0, 0, 16, 5, 80, 0].to_vec();
assert_eq!(expected_ser_addr, actual_ser_addr);Implementations§
Source§impl NetworkAddress
 
impl NetworkAddress
pub fn as_slice(&self) -> &[Protocol]
pub fn push(self, proto: Protocol) -> Self
pub fn extend_from_slice(self, protos: &[Protocol]) -> Self
Sourcepub fn encrypt(
    self,
    shared_val_netaddr_key: &Key,
    key_version: KeyVersion,
    account: &AccountAddress,
    seq_num: u64,
    addr_idx: u32,
) -> Result<EncNetworkAddress, ParseError>
 
pub fn encrypt( self, shared_val_netaddr_key: &Key, key_version: KeyVersion, account: &AccountAddress, seq_num: u64, addr_idx: u32, ) -> Result<EncNetworkAddress, ParseError>
Sourcepub fn append_prod_protos(
    self,
    network_pubkey: PublicKey,
    handshake_version: u8,
) -> Self
 
pub fn append_prod_protos( self, network_pubkey: PublicKey, handshake_version: u8, ) -> Self
Given a base NetworkAddress, append production protocols and
return the modified NetworkAddress.
§Example
use diem_crypto::{traits::ValidCryptoMaterialStringExt, x25519};
use diem_types::network_address::NetworkAddress;
use std::str::FromStr;
let pubkey_str = "080e287879c918794170e258bfaddd75acac5b3e350419044655e4983a487120";
let pubkey = x25519::PublicKey::from_encoded_string(pubkey_str).unwrap();
let addr = NetworkAddress::from_str("/dns/example.com/tcp/6180").unwrap();
let addr = addr.append_prod_protos(pubkey, 0);
assert_eq!(
    addr.to_string(),
    "/dns/example.com/tcp/6180/ln-noise-ik/080e287879c918794170e258bfaddd75acac5b3e350419044655e4983a487120/ln-handshake/0",
);Sourcepub fn is_diemnet_addr(&self) -> bool
 
pub fn is_diemnet_addr(&self) -> bool
Check that a NetworkAddress looks like a typical DiemNet address with
associated protocols.
“typical” DiemNet addresses begin with a transport protocol:
"/ip4/<addr>/tcp/<port>" or
"/ip6/<addr>/tcp/<port>" or
"/dns4/<domain>/tcp/<port>" or
"/dns6/<domain>/tcp/<port>" or
"/dns/<domain>/tcp/<port>" or
cfg!(test) "/memory/<port>"
followed by transport upgrade handshake protocols:
"/ln-noise-ik/<pubkey>/ln-handshake/<version>"
§Example
use diem_types::network_address::NetworkAddress;
use std::str::FromStr;
let addr_str = "/ip4/1.2.3.4/tcp/6180/ln-noise-ik/080e287879c918794170e258bfaddd75acac5b3e350419044655e4983a487120/ln-handshake/0";
let addr = NetworkAddress::from_str(addr_str).unwrap();
assert!(addr.is_diemnet_addr());Sourcepub fn find_ip_addr(&self) -> Option<IpAddr>
 
pub fn find_ip_addr(&self) -> Option<IpAddr>
Retrieves the IP address from the network address
Sourcepub fn find_noise_proto(&self) -> Option<PublicKey>
 
pub fn find_noise_proto(&self) -> Option<PublicKey>
A temporary, hacky function to parse out the first
/ln-noise-ik/<pubkey> from a NetworkAddress. We can remove this
soon, when we move to the interim “monolithic” transport model.
Sourcepub fn rotate_noise_public_key(
    &mut self,
    to_replace: &PublicKey,
    new_public_key: &PublicKey,
)
 
pub fn rotate_noise_public_key( &mut self, to_replace: &PublicKey, new_public_key: &PublicKey, )
A function to rotate public keys for NoiseIK protocols
Trait Implementations§
Source§impl Clone for NetworkAddress
 
impl Clone for NetworkAddress
Source§fn clone(&self) -> NetworkAddress
 
fn clone(&self) -> NetworkAddress
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
 
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for NetworkAddress
 
impl Debug for NetworkAddress
Source§impl<'de> Deserialize<'de> for NetworkAddress
 
impl<'de> Deserialize<'de> for NetworkAddress
Source§fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
    D: Deserializer<'de>,
 
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
    D: Deserializer<'de>,
Source§impl Display for NetworkAddress
 
impl Display for NetworkAddress
Source§impl From<Protocol> for NetworkAddress
 
impl From<Protocol> for NetworkAddress
Source§fn from(proto: Protocol) -> NetworkAddress
 
fn from(proto: Protocol) -> NetworkAddress
Source§impl From<SocketAddr> for NetworkAddress
 
impl From<SocketAddr> for NetworkAddress
Source§fn from(sockaddr: SocketAddr) -> NetworkAddress
 
fn from(sockaddr: SocketAddr) -> NetworkAddress
Source§impl FromStr for NetworkAddress
 
impl FromStr for NetworkAddress
Source§impl Hash for NetworkAddress
 
impl Hash for NetworkAddress
Source§impl IntoIterator for NetworkAddress
 
impl IntoIterator for NetworkAddress
Source§impl PartialEq for NetworkAddress
 
impl PartialEq for NetworkAddress
Source§impl Serialize for NetworkAddress
 
impl Serialize for NetworkAddress
Source§impl ToSocketAddrs for NetworkAddress
 
impl ToSocketAddrs for NetworkAddress
Source§type Iter = IntoIter<SocketAddr>
 
type Iter = IntoIter<SocketAddr>
Source§fn to_socket_addrs(&self) -> Result<Self::Iter, Error>
 
fn to_socket_addrs(&self) -> Result<Self::Iter, Error>
SocketAddrs. Read moreimpl Eq for NetworkAddress
impl StructuralPartialEq for NetworkAddress
Auto Trait Implementations§
impl Freeze for NetworkAddress
impl RefUnwindSafe for NetworkAddress
impl Send for NetworkAddress
impl Sync for NetworkAddress
impl Unpin for NetworkAddress
impl UnwindSafe for NetworkAddress
Blanket Implementations§
§impl<I> BidiIterator for I
 
impl<I> BidiIterator for I
Source§impl<T> BorrowMut<T> for Twhere
    T: ?Sized,
 
impl<T> BorrowMut<T> for Twhere
    T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
 
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
    T: Clone,
 
impl<T> CloneToUninit for Twhere
    T: Clone,
§impl<T> Conv for T
 
impl<T> Conv for T
§impl<Q, K> Equivalent<K> for Q
 
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
 
fn equivalent(&self, key: &K) -> bool
§impl<Q, K> Equivalent<K> for Q
 
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
 
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.§impl<T> FmtForward for T
 
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
    Self: Binary,
 
fn fmt_binary(self) -> FmtBinary<Self>where
    Self: Binary,
self to use its Binary implementation when Debug-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
    Self: Display,
 
fn fmt_display(self) -> FmtDisplay<Self>where
    Self: Display,
self to use its Display implementation when
Debug-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
    Self: LowerExp,
 
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
    Self: LowerExp,
self to use its LowerExp implementation when
Debug-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
    Self: LowerHex,
 
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
    Self: LowerHex,
self to use its LowerHex implementation when
Debug-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
    Self: Octal,
 
fn fmt_octal(self) -> FmtOctal<Self>where
    Self: Octal,
self to use its Octal implementation when Debug-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
    Self: Pointer,
 
fn fmt_pointer(self) -> FmtPointer<Self>where
    Self: Pointer,
self to use its Pointer implementation when
Debug-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
    Self: UpperExp,
 
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
    Self: UpperExp,
self to use its UpperExp implementation when
Debug-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
    Self: UpperHex,
 
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
    Self: UpperHex,
self to use its UpperHex implementation when
Debug-formatted.§fn fmt_list(self) -> FmtList<Self>where
    &'a Self: for<'a> IntoIterator,
 
fn fmt_list(self) -> FmtList<Self>where
    &'a Self: for<'a> IntoIterator,
Source§impl<T> IntoEither for T
 
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
 
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
 
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> Pipe for Twhere
    T: ?Sized,
 
impl<T> Pipe for Twhere
    T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
    Self: Sized,
 
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
    Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
    R: 'a,
 
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
    R: 'a,
self and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
    R: 'a,
 
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
    R: 'a,
self and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
 
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
    &'a mut self,
    func: impl FnOnce(&'a mut B) -> R,
) -> R
 
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
 
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self, then passes self.as_ref() into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
 
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self, then passes self.as_mut() into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
 
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self, then passes self.deref() into the pipe function.§impl<T> Pointable for T
 
impl<T> Pointable for T
Source§impl<T> Serialize for T
 
impl<T> Serialize for T
fn erased_serialize(&self, serializer: &mut dyn Serializer) -> Result<Ok, Error>
§impl<T> Tap for T
 
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
 
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B> of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
 
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B> of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
 
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R> view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
 
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R> view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
 
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
 
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
 
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap() only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
 
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut() only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
 
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow() only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
 
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut() only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
 
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref() only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
 
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut() only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
 
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref() only in debug builds, and is erased in release
builds.