Trait holochain::prelude::kitsune_p2p::event::KitsuneP2pEventSender

source · 
pub trait KitsuneP2pEventSender: GhostChannelSender<KitsuneP2pEvent> {
    fn put_agent_info_signed(
        &self,
        input: PutAgentInfoSignedEvt
    ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ { ... }
    fn query_agents(
        &self,
        input: QueryAgentsEvt
    ) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, KitsuneP2pError>> ⓘ { ... }
    fn query_peer_density(
        &self,
        space: Arc<KitsuneSpace>,
        dht_arc: DhtArc
    ) -> MustBoxFuture<'static, Result<PeerView, KitsuneP2pError>> ⓘ { ... }
    fn call(
        &self,
        space: Arc<KitsuneSpace>,
        to_agent: Arc<KitsuneAgent>,
        payload: Vec<u8, Global>
    ) -> MustBoxFuture<'static, Result<Vec<u8, Global>, KitsuneP2pError>> ⓘ { ... }
    fn notify(
        &self,
        space: Arc<KitsuneSpace>,
        to_agent: Arc<KitsuneAgent>,
        payload: Vec<u8, Global>
    ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ { ... }
    fn receive_ops(
        &self,
        space: Arc<KitsuneSpace>,
        ops: Vec<Arc<KitsuneOpData>, Global>,
        context: Option<FetchContext>
    ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ { ... }
    fn query_op_hashes(
        &self,
        input: QueryOpHashesEvt
    ) -> MustBoxFuture<'static, Result<Option<(Vec<Arc<KitsuneOpHash>, Global>, RangeInclusive<Timestamp>)>, KitsuneP2pError>> ⓘ { ... }
    fn fetch_op_data(
        &self,
        input: FetchOpDataEvt
    ) -> MustBoxFuture<'static, Result<Vec<(Arc<KitsuneOpHash>, Arc<KitsuneOpData>), Global>, KitsuneP2pError>> ⓘ { ... }
    fn sign_network_data(
        &self,
        input: SignNetworkDataEvt
    ) -> MustBoxFuture<'static, Result<KitsuneSignature, KitsuneP2pError>> ⓘ { ... }
}
Expand description

The KitsuneP2pEvent stream allows handling events generated from the KitsuneP2p actor.

Provided Methods§

We need to store signed agent info.

We need to get previously stored agent info.

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

We are receiving a request from a remote node.

We are receiving a notification from a remote node.

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

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.

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

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

Implementors§