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, Global>, 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, Global>
) -> Result<MustBoxFuture<'static, Result<Vec<u8, Global>, 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, Global>
) -> 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>, Global>,
    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>, Global>, 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>), Global>, 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.