Struct MockNetwork

pub struct MockNetwork {
    listening: Mutex<HashMap<SocketAddr, AddrBehavior>>,
}

A simulated Internet, for testing.

We simulate TCP streams only, and skip all the details. Connection are implemented using LocalStream. The MockNetwork object is shared by a large set of MockNetworkProviders, each of which has its own view of its address(es) on the network.

Fields

listening: Mutex<HashMap<SocketAddr, AddrBehavior>>

A map from address to the entries about listeners there.

Implementations

impl MockNetwork

pub fn new() -> Arc<Self>

Make a new MockNetwork with no active listeners.

pub fn builder(self: &Arc<Self>) -> ProviderBuilder

Return a ProviderBuilder for creating a MockNetProvider

Examples

let client_net = mock_network.builder()
      .add_address("198.51.100.6".parse().unwrap())
      .add_address("2001:db8::7".parse().unwrap())
      .provider();

pub fn add_blackhole(&self, address: SocketAddr) -> IoResult<()>

Add a “black hole” at the given address, where all traffic will time out.

async fn send_connection( &self, source_addr: SocketAddr, target_addr: SocketAddr, peer_stream: LocalStream, ) -> IoResult<Option<Vec<u8>>>

Tell the listener at target_addr (if any) about an incoming connection from source_addr at peer_stream.

If the listener is a TLS listener, returns its certificate. Note: Callers should check whether the presence or absence of a certificate matches their expectations.

Returns an error if there isn’t any such listener.

fn add_listener( &self, addr: SocketAddr, tls_cert: Option<Vec<u8>>, ) -> IoResult<Receiver<(LocalStream, SocketAddr)>>

Register a listener at addr and return the ConnReceiver that it should use for connections.

If tls_cert is provided, then the listener is a TLS listener and any only TLS connection attempts should succeed.

Returns an error if the address is already in use.

Trait Implementations

impl Default for MockNetwork

fn default() -> MockNetwork

Returns the “default value” for a type.