Struct holochain_p2p::HolochainP2pCell [−][src]
pub struct HolochainP2pCell { /* fields omitted */ }
Expand description
A wrapper around HolochainP2pSender that partially applies the dna_hash / agent_pub_key. I.e. a sender that is tied to a specific cell.
Trait Implementations
owned getter
The p2p module must be informed at runtime which dna/agent pairs it should be tracking.
If a cell is disabled, we’ll need to "leave" the network module as well.
fn call_remote<'life0, 'async_trait>(
&'life0 self,
to_agent: AgentPubKey,
zome_name: ZomeName,
fn_name: FunctionName,
cap: Option<CapSecret>,
payload: ExternIO
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<SerializedBytes>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn call_remote<'life0, 'async_trait>(
&'life0 self,
to_agent: AgentPubKey,
zome_name: ZomeName,
fn_name: FunctionName,
cap: Option<CapSecret>,
payload: ExternIO
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<SerializedBytes>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Invoke a zome function on a remote node (if you have been granted the capability).
fn publish<'life0, 'async_trait>(
&'life0 self,
request_validation_receipt: bool,
countersigning_session: bool,
dht_hash: AnyDhtHash,
ops: Vec<(DhtOpHash, DhtOp)>,
timeout_ms: Option<u64>
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn publish<'life0, 'async_trait>(
&'life0 self,
request_validation_receipt: bool,
countersigning_session: bool,
dht_hash: AnyDhtHash,
ops: Vec<(DhtOpHash, DhtOp)>,
timeout_ms: Option<u64>
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Publish data to the correct neighborhood.
fn get_validation_package<'life0, 'async_trait>(
&'life0 self,
request_from: AgentPubKey,
header_hash: HeaderHash
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<ValidationPackageResponse>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get_validation_package<'life0, 'async_trait>(
&'life0 self,
request_from: AgentPubKey,
header_hash: HeaderHash
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<ValidationPackageResponse>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Request a validation package.
fn get<'life0, 'async_trait>(
&'life0 self,
dht_hash: AnyDhtHash,
options: GetOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<WireOps>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get<'life0, 'async_trait>(
&'life0 self,
dht_hash: AnyDhtHash,
options: GetOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<WireOps>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Get an entry from the DHT.
fn get_meta<'life0, 'async_trait>(
&'life0 self,
dht_hash: AnyDhtHash,
options: GetMetaOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<MetadataSet>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get_meta<'life0, 'async_trait>(
&'life0 self,
dht_hash: AnyDhtHash,
options: GetMetaOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<MetadataSet>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Get metadata from the DHT.
fn get_links<'life0, 'async_trait>(
&'life0 self,
link_key: WireLinkKey,
options: GetLinksOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<WireLinkOps>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get_links<'life0, 'async_trait>(
&'life0 self,
link_key: WireLinkKey,
options: GetLinksOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<WireLinkOps>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Get links from the DHT.
fn get_agent_activity<'life0, 'async_trait>(
&'life0 self,
agent: AgentPubKey,
query: ChainQueryFilter,
options: GetActivityOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<AgentActivityResponse<HeaderHash>>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get_agent_activity<'life0, 'async_trait>(
&'life0 self,
agent: AgentPubKey,
query: ChainQueryFilter,
options: GetActivityOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<AgentActivityResponse<HeaderHash>>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Get agent activity from the DHT.
fn send_validation_receipt<'life0, 'async_trait>(
&'life0 self,
to_agent: AgentPubKey,
receipt: SerializedBytes
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn send_validation_receipt<'life0, 'async_trait>(
&'life0 self,
to_agent: AgentPubKey,
receipt: SerializedBytes
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Send a validation receipt to a remote node.
Check if an agent is an authority for a hash.
Response from an authority to agents that are part of a session. Read more
fn new_integrated_data<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn new_integrated_data<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
New data has been integrated and is ready for gossiping.
Auto Trait Implementations
impl !RefUnwindSafe for HolochainP2pCell
impl Send for HolochainP2pCell
impl Sync for HolochainP2pCell
impl Unpin for HolochainP2pCell
impl !UnwindSafe for HolochainP2pCell
Blanket Implementations
fn type_id_compat(&self) -> TypeId
fn type_id_compat(&self) -> TypeId
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
Mutably borrows from an owned value. Read more
fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
pub fn vzip(self) -> V
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