Enum holochain_p2p::actor::HolochainP2p

pub enum HolochainP2p {
    Join {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        agent_pub_key: AgentPubKey,
    },
    Leave {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        agent_pub_key: AgentPubKey,
    },
    CallRemote {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<SerializedBytes>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        to_agent: AgentPubKey,
        zome_name: ZomeName,
        fn_name: FunctionName,
        cap_secret: Option<CapSecret>,
        payload: ExternIO,
    },
    RemoteSignal {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        to_agent_list: Vec<AgentPubKey>,
        zome_name: ZomeName,
        fn_name: FunctionName,
        cap: Option<CapSecret>,
        payload: ExternIO,
    },
    Publish {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        request_validation_receipt: bool,
        countersigning_session: bool,
        dht_hash: AnyDhtHash,
        ops: Vec<(DhtOpHash, DhtOp)>,
        timeout_ms: Option<u64>,
    },
    GetValidationPackage {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<ValidationPackageResponse>>,
        input: GetValidationPackage,
    },
    Get {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<WireOps>>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        dht_hash: AnyDhtHash,
        options: GetOptions,
    },
    GetMeta {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<MetadataSet>>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        dht_hash: AnyDhtHash,
        options: GetMetaOptions,
    },
    GetLinks {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<WireLinkOps>>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        link_key: WireLinkKey,
        options: GetLinksOptions,
    },
    GetAgentActivity {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<AgentActivityResponse<HeaderHash>>>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        agent: AgentPubKey,
        query: ChainQueryFilter,
        options: GetActivityOptions,
    },
    SendValidationReceipt {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        to_agent: AgentPubKey,
        from_agent: AgentPubKey,
        receipt: SerializedBytes,
    },
    NewIntegratedData {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
    },
    AuthorityForHash {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<bool>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        dht_hash: AnyDhtHash,
    },
    CountersigningAuthorityResponse {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        from_agent: AgentPubKey,
        agents: Vec<AgentPubKey>,
        signed_headers: Vec<SignedHeader>,
    },
}

The HolochainP2pSender struct allows controlling the HolochainP2p actor instance.

Variants

Join

The p2p module must be informed at runtime which dna/agent pairs it should be tracking.

Fields of Join

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

agent_pub_key: AgentPubKey

Input parameter.

Leave

If a cell is disabled, we’ll need to "leave" the network module as well.

Fields of Leave

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

agent_pub_key: AgentPubKey

Input parameter.

CallRemote

Invoke a zome function on a remote node (if you have been granted the capability).

Fields of CallRemote

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<SerializedBytes>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

to_agent: AgentPubKey

Input parameter.

zome_name: ZomeName

Input parameter.

fn_name: FunctionName

Input parameter.

cap_secret: Option<CapSecret>

Input parameter.

payload: ExternIO

Input parameter.

RemoteSignal

Invoke a zome function on a remote node (if you have been granted the capability). This is a fire-and-forget operation, a best effort will be made to forward the signal, but if the conductor network is overworked it may decide not to deliver some of the signals.

Fields of RemoteSignal

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

to_agent_list: Vec<AgentPubKey>

Input parameter.

zome_name: ZomeName

Input parameter.

fn_name: FunctionName

Input parameter.

cap: Option<CapSecret>

Input parameter.

payload: ExternIO

Input parameter.

Publish

Publish data to the correct neighborhood.

Fields of Publish

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

request_validation_receipt: bool

Input parameter.

countersigning_session: bool

Input parameter.

dht_hash: AnyDhtHash

Input parameter.

ops: Vec<(DhtOpHash, DhtOp)>

Input parameter.

timeout_ms: Option<u64>

Input parameter.

GetValidationPackage

Request a validation package.

Fields of GetValidationPackage

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<ValidationPackageResponse>>

Response callback - respond to the request.

input: GetValidationPackage

Input parameter.

Get

Get an entry from the DHT.

Fields of Get

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<Vec<WireOps>>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

dht_hash: AnyDhtHash

Input parameter.

options: GetOptions

Input parameter.

GetMeta

Get metadata from the DHT.

Fields of GetMeta

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<Vec<MetadataSet>>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

dht_hash: AnyDhtHash

Input parameter.

options: GetMetaOptions

Input parameter.

GetLinks

Get links from the DHT.

Fields of GetLinks

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<Vec<WireLinkOps>>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

link_key: WireLinkKey

Input parameter.

options: GetLinksOptions

Input parameter.

GetAgentActivity

Get agent activity from the DHT.

Fields of GetAgentActivity

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<Vec<AgentActivityResponse<HeaderHash>>>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

agent: AgentPubKey

Input parameter.

query: ChainQueryFilter

Input parameter.

options: GetActivityOptions

Input parameter.

SendValidationReceipt

Send a validation receipt to a remote node.

Fields of SendValidationReceipt

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

to_agent: AgentPubKey

Input parameter.

from_agent: AgentPubKey

Input parameter.

receipt: SerializedBytes

Input parameter.

NewIntegratedData

New data has been integrated and is ready for gossiping.

Fields of NewIntegratedData

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

AuthorityForHash

Check if an agent is an authority for a hash.

Fields of AuthorityForHash

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<bool>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

dht_hash: AnyDhtHash

Input parameter.

CountersigningAuthorityResponse

Response from an authority to agents that are part of a session.

Fields of CountersigningAuthorityResponse

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

from_agent: AgentPubKey

Input parameter.

agents: Vec<AgentPubKey>

Input parameter.

signed_headers: Vec<SignedHeader>

Input parameter.

Trait Implementations

impl Debug for HolochainP2p

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

Formats the value using the given formatter.

impl<H: HolochainP2pHandler> GhostDispatch<H> for HolochainP2p

fn ghost_actor_dispatch(self, h: &mut H)

Process a dispatch event with a given GhostHandler.

impl GhostEvent for HolochainP2p