Struct holochain::prelude::kitsune_p2p::test_util::switchboard_state::SwitchboardState

pub struct SwitchboardState { /* private fields */ }

The state of the switchboard, which represents the persisted state of all nodes in a space. These methods may be called directly in your test, after getting a lock on the state via Switchboard::share. This same state is modified directly by an actively running GossipModule which is processing messages from other nodes.

Implementations

impl SwitchboardState

pub fn add_local_agent(
    &mut self,
    node_ep: &Tx2EpHnd<Wire>,
    agent: &SwitchboardAgent
)

Add a local agent to the specified node.

pub fn print_ascii_arcs(&self, width: usize, with_ops: bool)

Helpful ascii visualization of each agent’s storage arc coverage across all nodes.

pub fn print_peer_lists(&self)

Print the list of peers recorded in each node

pub fn all_peers(&mut self, node: &Tx2EpHnd<Wire>) -> Vec<Loc8, Global>

List all peer info (local and remote agents) that this node knows about.

pub fn inject_peer_info<L, A>(&mut self, node: &Tx2EpHnd<Wire>, agents: A)where
    L: AsRef<Loc8>,
    A: IntoIterator<Item = L>,

Inject the agent info from the specified agents into the specified node’s remote agent store.

This is used to set up arbitrary situations where not every peer knows about every other peer.

pub fn exchange_all_peer_info(&mut self)

Let every node know about every other agent.

This is not realistic, but useful as a convenience when not needing to explicitly test peer gossip.

pub fn add_ops_timed<L, O>(
    &mut self,
    node_ep: &Tx2EpHnd<Wire>,
    is_integrated: bool,
    ops: O
)where
    L: Into<Loc8>,
    O: IntoIterator<Item = (L, Timestamp)>,

Add ops by Loc8 location, specifying the Timestamp that each was created. Each Loc8 becomes a new Op added to an agent’s op store.

pub fn add_ops_now<L, O>(
    &mut self,
    node_ep: &Tx2EpHnd<Wire>,
    is_integrated: bool,
    ops: O
)where
    L: Into<Loc8>,
    O: IntoIterator<Item = L>,

Convenient counterpart to add_ops_timed, causes each op to be added at the current system time.

pub fn get_ops_loc8(
    &mut self,
    node_ep: &Tx2EpHnd<Wire>
) -> BTreeSet<Loc8, Global>

Get all ops held by a node in terms of their Loc8 location.

Use this to make assertions about what ops are held after gossip has run.

Trait Implementations

impl Default for SwitchboardState

fn default() -> SwitchboardState

Returns the “default value” for a type.