Enum holochain_p2p::actor::HolochainP2p

source · [−]
pub enum HolochainP2p {

Show 15 variants    Join {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        agent_pub_key: AgentPubKey,
        initial_arc: Option<DhtArc>,
    },
    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<usize>>,
        dna_hash: DnaHash,
        request_validation_receipt: bool,
        countersigning_session: bool,
        dht_hash: AnyDhtHash,
        ops: Vec<DhtOp>,
        timeout_ms: Option<u64>,
    },
    Get {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<WireOps>>>,
        dna_hash: DnaHash,
        dht_hash: AnyDhtHash,
        options: GetOptions,
    },
    GetMeta {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<MetadataSet>>>,
        dna_hash: DnaHash,
        dht_hash: AnyDhtHash,
        options: GetMetaOptions,
    },
    GetLinks {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<WireLinkOps>>>,
        dna_hash: DnaHash,
        link_key: WireLinkKey,
        options: GetLinksOptions,
    },
    GetAgentActivity {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<AgentActivityResponse<ActionHash>>>>,
        dna_hash: DnaHash,
        agent: AgentPubKey,
        query: ChainQueryFilter,
        options: GetActivityOptions,
    },
    MustGetAgentActivity {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<Vec<MustGetAgentActivityResponse>>>,
        dna_hash: DnaHash,
        author: AgentPubKey,
        filter: ChainFilter,
    },
    SendValidationReceipt {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        to_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,
        dht_hash: AnyDhtHash,
    },
    CountersigningSessionNegotiation {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<()>>,
        dna_hash: DnaHash,
        agents: Vec<AgentPubKey>,
        message: CountersigningSessionNegotiationMessage,
    },
    DumpNetworkMetrics {
        span_context: Context,
        respond: GhostRespond<HolochainP2pHandlerResult<String>>,
        dna_hash: Option<DnaHash>,
    },

}
Expand description

The HolochainP2pSender struct allows controlling the HolochainP2p actor instance.

Variants

Join

Fields

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.

initial_arc: Option<DhtArc>

Input parameter.

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

Leave

Fields

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.

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

CallRemote

Fields

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.

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

RemoteSignal

Fields

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.

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.

Publish

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<usize>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

request_validation_receipt: bool

Input parameter.

countersigning_session: bool

Input parameter.

dht_hash: AnyDhtHash

Input parameter.

ops: Vec<DhtOp>

Input parameter.

timeout_ms: Option<u64>

Input parameter.

Publish data to the correct neighborhood.

Get

Fields

span_context: Context

Tracing span from request invocation.

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

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

dht_hash: AnyDhtHash

Input parameter.

options: GetOptions

Input parameter.

Get an entry from the DHT.

GetMeta

Fields

span_context: Context

Tracing span from request invocation.

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

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

dht_hash: AnyDhtHash

Input parameter.

options: GetMetaOptions

Input parameter.

Get metadata from the DHT.

Fields

span_context: Context

Tracing span from request invocation.

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

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

link_key: WireLinkKey

Input parameter.

options: GetLinksOptions

Input parameter.

Get links from the DHT.

GetAgentActivity

Fields

span_context: Context

Tracing span from request invocation.

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

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

agent: AgentPubKey

Input parameter.

query: ChainQueryFilter

Input parameter.

options: GetActivityOptions

Input parameter.

Get agent activity from the DHT.

MustGetAgentActivity

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<Vec<MustGetAgentActivityResponse>>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

author: AgentPubKey

Input parameter.

filter: ChainFilter

Input parameter.

A remote node is requesting agent activity from us.

SendValidationReceipt

Fields

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.

receipt: SerializedBytes

Input parameter.

Send a validation receipt to a remote node.

NewIntegratedData

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

New data has been integrated and is ready for gossiping.

AuthorityForHash

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<bool>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

dht_hash: AnyDhtHash

Input parameter.

Check if any local agent in this space is an authority for a hash.

CountersigningSessionNegotiation

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<()>>

Response callback - respond to the request.

dna_hash: DnaHash

Input parameter.

agents: Vec<AgentPubKey>

Input parameter.

message: CountersigningSessionNegotiationMessage

Input parameter.

Messages between agents negotiation a countersigning session.

DumpNetworkMetrics

Fields

span_context: Context

Tracing span from request invocation.

respond: GhostRespond<HolochainP2pHandlerResult<String>>

Response callback - respond to the request.

dna_hash: Option<DnaHash>

Input parameter.

Dump network metrics.

Trait Implementations

Formats the value using the given formatter. Read more
Process a dispatch event with a given GhostHandler.

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more
TODO: once 1.33.0 is the minimum supported compiler version, remove Any::type_id_compat and use StdAny::type_id instead. https://github.com/rust-lang/rust/issues/27745 Read more
The archived version of the pointer metadata for this type.
Converts some archived metadata to the pointer metadata for itself.
Immutably borrows from an owned value. Read more
Mutably borrows from an owned value. Read more
Deserializes using the given deserializer

Returns the argument unchanged.

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Attaches the current Context to this type, returning a WithContext wrapper. Read more
Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

The alignment of pointer.
The type for initializers.
Initializes a with the given initializer. Read more
Dereferences the given pointer. Read more
Mutably dereferences the given pointer. Read more
Drops the object pointed to by the given pointer. Read more
The type for metadata in pointers and references to Self.
Should always be Self
The inverse inclusion map: attempts to construct self from the equivalent element of its superset. Read more
Checks if self is actually part of its subset T (and can be converted to it).
Use with care! Same as self.to_subset but without any property checks. Always succeeds.
The inclusion map: converts self to the equivalent element of its superset.
The type returned in the event of a conversion error.
Performs the conversion.
The type returned in the event of a conversion error.
Performs the conversion.
Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more