Struct holochain::prelude::MockKitsuneP2pEventHandler

pub struct MockKitsuneP2pEventHandler { /* private fields */ }

Implementations

impl MockKitsuneP2pEventHandler

pub fn checkpoint(&mut self)

Validate that all current expectations for all methods have been satisfied, and discard them.

pub fn new() -> MockKitsuneP2pEventHandler

Create a new mock object with no expectations.

This method will not be generated if the real struct already has a new method. However, it will be generated if the struct implements a trait with a new method. The trait’s new method can still be called like <MockX as TraitY>::new

impl MockKitsuneP2pEventHandler

pub fn expect_handle_put_agent_info_signed(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_put_agent_info_signed method

pub fn expect_handle_query_agents(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_query_agents method

pub fn expect_handle_query_peer_density(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_query_peer_density method

pub fn expect_handle_call(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_call method

pub fn expect_handle_notify(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_notify method

pub fn expect_handle_receive_ops(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_receive_ops method

pub fn expect_handle_query_op_hashes(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_query_op_hashes method

pub fn expect_handle_fetch_op_data(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_fetch_op_data method

pub fn expect_handle_sign_network_data(&mut self) -> &mut Expectation

Create an Expectation for mocking the handle_sign_network_data method

Trait Implementations

impl Default for MockKitsuneP2pEventHandler

fn default() -> MockKitsuneP2pEventHandler

Returns the “default value” for a type.

impl GhostControlHandler for MockKitsuneP2pEventHandler

fn handle_ghost_actor_shutdown(self) -> MustBoxFuture<'static, ()>

Called when the actor task loops ends. Allows for any needed cleanup / triggers.

impl GhostHandler<KitsuneP2pEvent> for MockKitsuneP2pEventHandler

fn ghost_actor_dispatch(&mut self, d: D)

Process a dispatch event with this GhostHandler.

impl KitsuneP2pEventHandler for MockKitsuneP2pEventHandler

fn handle_put_agent_info_signed( &mut self, input: PutAgentInfoSignedEvt ) -> Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>

We need to store signed agent info.

fn handle_query_agents( &mut self, input: QueryAgentsEvt ) -> Result<MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, KitsuneP2pError>>, KitsuneP2pError>

We need to get previously stored agent info.

fn handle_query_peer_density( &mut self, space: Arc<KitsuneSpace>, dht_arc: DhtArc ) -> Result<MustBoxFuture<'static, Result<PeerView, KitsuneP2pError>>, KitsuneP2pError>

Query the peer density of a space for a given [DhtArc].

fn handle_call( &mut self, space: Arc<KitsuneSpace>, to_agent: Arc<KitsuneAgent>, payload: Vec<u8> ) -> Result<MustBoxFuture<'static, Result<Vec<u8>, KitsuneP2pError>>, KitsuneP2pError>

We are receiving a request from a remote node.

fn handle_notify( &mut self, space: Arc<KitsuneSpace>, to_agent: Arc<KitsuneAgent>, payload: Vec<u8> ) -> Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>

We are receiving a notification from a remote node.

fn handle_receive_ops( &mut self, space: Arc<KitsuneSpace>, ops: Vec<Arc<KitsuneOpData>>, context: Option<FetchContext> ) -> Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>

We have received ops to be integrated, either through gossip or publish.

fn handle_query_op_hashes( &mut self, input: QueryOpHashesEvt ) -> Result<MustBoxFuture<'static, Result<Option<(Vec<Arc<KitsuneOpHash>>, RangeInclusive<Timestamp>)>, KitsuneP2pError>>, KitsuneP2pError>

Gather a list of op-hashes from our implementor that meet criteria. Get the oldest and newest times for ops within a time window and max number of ops.

fn handle_fetch_op_data( &mut self, input: FetchOpDataEvt ) -> Result<MustBoxFuture<'static, Result<Vec<(Arc<KitsuneOpHash>, Arc<KitsuneOpData>)>, KitsuneP2pError>>, KitsuneP2pError>

Gather all op-hash data for a list of op-hashes from our implementor.

fn handle_sign_network_data( &mut self, input: SignNetworkDataEvt ) -> Result<MustBoxFuture<'static, Result<KitsuneSignature, KitsuneP2pError>>, KitsuneP2pError>

Request that our implementor sign some data on behalf of an agent.