Struct Oracle 

pub struct Oracle<P: PublicKey, E: Clock> { /* private fields */ }

Interface for modifying the simulated network.

At any point, peers can be added/removed and links between said peers can be modified.

Implementations

impl<P: PublicKey, E: Clock> Oracle<P, E>

pub fn control(&self, me: P) -> Control<P, E>

Create a new Control interface for some peer.

pub fn manager(&self) -> Manager<P, E>

Create a new Manager.

Useful for mocking crate::authenticated::discovery.

pub fn socket_manager(&self) -> SocketManager<P, E>

Create a new SocketManager.

Useful for mocking crate::authenticated::lookup.

pub async fn blocked(&mut self) -> Result<Vec<(P, P)>, Error>

Return a list of all blocked peers.

pub async fn limit_bandwidth( &mut self, public_key: P, egress_cap: Option<usize>, ingress_cap: Option<usize>, ) -> Result<(), Error>

Set bandwidth limits for a peer.

Bandwidth is specified for the peer’s egress (upload) and ingress (download) rates in bytes per second. Use None for unlimited bandwidth.

Bandwidth can be specified before a peer is registered or linked.

pub async fn add_link( &mut self, sender: P, receiver: P, config: Link, ) -> Result<(), Error>

Create a unidirectional link between two peers.

Link can be called multiple times for the same sender/receiver. The latest setting will be used.

Link can be called before a peer is registered or bandwidth is specified.

pub async fn remove_link(&mut self, sender: P, receiver: P) -> Result<(), Error>

Remove a unidirectional link between two peers.

If no link exists, this will return an error.

Trait Implementations

impl<P: PublicKey, E: Clock> Clone for Oracle<P, E>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<P: Debug + PublicKey, E: Debug + Clock> Debug for Oracle<P, E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.