Enum holochain::prelude::kitsune_p2p::event::KitsuneP2pEvent

pub enum KitsuneP2pEvent {
    PutAgentInfoSigned {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>>,
        input: PutAgentInfoSignedEvt,
    },
    QueryAgents {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, KitsuneP2pError>>, KitsuneP2pError>>,
        input: QueryAgentsEvt,
    },
    QueryPeerDensity {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<PeerView, KitsuneP2pError>>, KitsuneP2pError>>,
        space: Arc<KitsuneSpace>,
        dht_arc: DhtArc,
    },
    Call {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<Vec<u8, Global>, KitsuneP2pError>>, KitsuneP2pError>>,
        space: Arc<KitsuneSpace>,
        to_agent: Arc<KitsuneAgent>,
        payload: Vec<u8, Global>,
    },
    Notify {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>>,
        space: Arc<KitsuneSpace>,
        to_agent: Arc<KitsuneAgent>,
        payload: Vec<u8, Global>,
    },
    ReceiveOps {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>>,
        space: Arc<KitsuneSpace>,
        ops: Vec<Arc<KitsuneOpData>, Global>,
        context: Option<FetchContext>,
    },
    QueryOpHashes {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<Option<(Vec<Arc<KitsuneOpHash>, Global>, RangeInclusive<Timestamp>)>, KitsuneP2pError>>, KitsuneP2pError>>,
        input: QueryOpHashesEvt,
    },
    FetchOpData {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<Vec<(Arc<KitsuneOpHash>, Arc<KitsuneOpData>), Global>, KitsuneP2pError>>, KitsuneP2pError>>,
        input: FetchOpDataEvt,
    },
    SignNetworkData {
        span_context: Context,
        respond: GhostRespond<Result<MustBoxFuture<'static, Result<KitsuneSignature, KitsuneP2pError>>, KitsuneP2pError>>,
        input: SignNetworkDataEvt,
    },
}

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

Variants

PutAgentInfoSigned

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

input: PutAgentInfoSignedEvt

Input parameter.

We need to store signed agent info.

QueryAgents

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

input: QueryAgentsEvt

Input parameter.

We need to get previously stored agent info.

QueryPeerDensity

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<PeerView, KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

space: Arc<KitsuneSpace>

Input parameter.

dht_arc: DhtArc

Input parameter.

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

Call

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<Vec<u8, Global>, KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

space: Arc<KitsuneSpace>

Input parameter.

to_agent: Arc<KitsuneAgent>

Input parameter.

payload: Vec<u8, Global>

Input parameter.

We are receiving a request from a remote node.

Notify

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

space: Arc<KitsuneSpace>

Input parameter.

to_agent: Arc<KitsuneAgent>

Input parameter.

payload: Vec<u8, Global>

Input parameter.

We are receiving a notification from a remote node.

ReceiveOps

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<(), KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

space: Arc<KitsuneSpace>

Input parameter.

ops: Vec<Arc<KitsuneOpData>, Global>

Input parameter.

context: Option<FetchContext>

Input parameter.

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

QueryOpHashes

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<Option<(Vec<Arc<KitsuneOpHash>, Global>, RangeInclusive<Timestamp>)>, KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

input: QueryOpHashesEvt

Input parameter.

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.

FetchOpData

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<Vec<(Arc<KitsuneOpHash>, Arc<KitsuneOpData>), Global>, KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

input: FetchOpDataEvt

Input parameter.

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

SignNetworkData

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<Result<MustBoxFuture<'static, Result<KitsuneSignature, KitsuneP2pError>>, KitsuneP2pError>>

Response callback - respond to the request.

input: SignNetworkDataEvt

Input parameter.

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

Trait Implementations

impl Debug for KitsuneP2pEvent

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

Formats the value using the given formatter.

impl<H> GhostDispatch<H> for KitsuneP2pEventwhere
    H: KitsuneP2pEventHandler,

fn ghost_actor_dispatch(self, h: &mut H)

Process a dispatch event with a given GhostHandler.

impl GhostHandler<KitsuneP2pEvent> for MockKitsuneP2pEventHandler

fn ghost_actor_dispatch(&mut self, d: D)

Process a dispatch event with this GhostHandler.

impl GhostHandler<KitsuneP2pEvent> for MockKitsuneP2pEventHandler

fn ghost_actor_dispatch(&mut self, d: D)

Process a dispatch event with this GhostHandler.

impl GhostHandler<KitsuneP2pEvent> for SwitchboardEventHandler

fn ghost_actor_dispatch(&mut self, d: D)

Process a dispatch event with this GhostHandler.

impl GhostEvent for KitsuneP2pEvent