Struct holochain::prelude::MockHolochainP2pDnaT
source · pub struct MockHolochainP2pDnaT { /* private fields */ }
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.
Implementations§
source§impl MockHolochainP2pDnaT
impl MockHolochainP2pDnaT
sourcepub fn checkpoint(&mut self)
pub fn checkpoint(&mut self)
Validate that all current expectations for all methods have been satisfied, and discard them.
sourcepub fn new() -> MockHolochainP2pDnaT
pub fn new() -> MockHolochainP2pDnaT
Create a new mock object with no expectations.
This method will not be generated if the real struct
already has a new
method. However, it will be
generated if the struct implements a trait with a new
method. The trait’s new
method can still be called
like <MockX as TraitY>::new
source§impl MockHolochainP2pDnaT
impl MockHolochainP2pDnaT
sourcepub fn expect_dna_hash(&mut self) -> &mut Expectation
pub fn expect_dna_hash(&mut self) -> &mut Expectation
Create an Expectation
for mocking the dna_hash
method
sourcepub fn expect_join(&mut self) -> &mut Expectation
pub fn expect_join(&mut self) -> &mut Expectation
Create an Expectation
for mocking the join
method
sourcepub fn expect_leave(&mut self) -> &mut Expectation
pub fn expect_leave(&mut self) -> &mut Expectation
Create an Expectation
for mocking the leave
method
sourcepub fn expect_call_remote(&mut self) -> &mut Expectation
pub fn expect_call_remote(&mut self) -> &mut Expectation
Create an Expectation
for mocking the call_remote
method
sourcepub fn expect_remote_signal(&mut self) -> &mut Expectation
pub fn expect_remote_signal(&mut self) -> &mut Expectation
Create an Expectation
for mocking the remote_signal
method
sourcepub fn expect_publish(&mut self) -> &mut Expectation
pub fn expect_publish(&mut self) -> &mut Expectation
Create an Expectation
for mocking the publish
method
sourcepub fn expect_publish_countersign(&mut self) -> &mut Expectation
pub fn expect_publish_countersign(&mut self) -> &mut Expectation
Create an Expectation
for mocking the publish_countersign
method
sourcepub fn expect_get(&mut self) -> &mut Expectation
pub fn expect_get(&mut self) -> &mut Expectation
Create an Expectation
for mocking the get
method
sourcepub fn expect_get_meta(&mut self) -> &mut Expectation
pub fn expect_get_meta(&mut self) -> &mut Expectation
Create an Expectation
for mocking the get_meta
method
sourcepub fn expect_get_links(&mut self) -> &mut Expectation
pub fn expect_get_links(&mut self) -> &mut Expectation
Create an Expectation
for mocking the get_links
method
sourcepub fn expect_count_links(&mut self) -> &mut Expectation
pub fn expect_count_links(&mut self) -> &mut Expectation
Create an Expectation
for mocking the count_links
method
sourcepub fn expect_get_agent_activity(&mut self) -> &mut Expectation
pub fn expect_get_agent_activity(&mut self) -> &mut Expectation
Create an Expectation
for mocking the get_agent_activity
method
sourcepub fn expect_must_get_agent_activity(&mut self) -> &mut Expectation
pub fn expect_must_get_agent_activity(&mut self) -> &mut Expectation
Create an Expectation
for mocking the must_get_agent_activity
method
sourcepub fn expect_send_validation_receipt(&mut self) -> &mut Expectation
pub fn expect_send_validation_receipt(&mut self) -> &mut Expectation
Create an Expectation
for mocking the send_validation_receipt
method
Create an Expectation
for mocking the authority_for_hash
method
sourcepub fn expect_countersigning_session_negotiation(&mut self) -> &mut Expectation
pub fn expect_countersigning_session_negotiation(&mut self) -> &mut Expectation
Create an Expectation
for mocking the countersigning_session_negotiation
method
sourcepub fn expect_new_integrated_data(&mut self) -> &mut Expectation
pub fn expect_new_integrated_data(&mut self) -> &mut Expectation
Create an Expectation
for mocking the new_integrated_data
method
sourcepub fn expect_chc(&mut self) -> &mut Expectation
pub fn expect_chc(&mut self) -> &mut Expectation
Create an Expectation
for mocking the chc
method
Trait Implementations§
source§impl Debug for MockHolochainP2pDnaT
impl Debug for MockHolochainP2pDnaT
source§impl Default for MockHolochainP2pDnaT
impl Default for MockHolochainP2pDnaT
source§fn default() -> MockHolochainP2pDnaT
fn default() -> MockHolochainP2pDnaT
source§impl HolochainP2pDnaT for MockHolochainP2pDnaT
impl HolochainP2pDnaT for MockHolochainP2pDnaT
A wrapper around HolochainP2pSender that partially applies the dna_hash / agent_pub_key. I.e. a sender that is tied to a specific cell.
source§fn join<'life0, 'async_trait>(
&'life0 self,
agent: HoloHash<Agent>,
maybe_agent_info: Option<AgentInfoSigned>,
initial_arc: Option<DhtArc>
) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn join<'life0, 'async_trait>( &'life0 self, agent: HoloHash<Agent>, maybe_agent_info: Option<AgentInfoSigned>, initial_arc: Option<DhtArc> ) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
The p2p module must be informed at runtime which dna/agent pairs it should be tracking.
source§fn leave<'life0, 'async_trait>(
&'life0 self,
agent: HoloHash<Agent>
) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn leave<'life0, 'async_trait>( &'life0 self, agent: HoloHash<Agent> ) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
If a cell is disabled, we’ll need to "leave" the network module as well.
source§fn call_remote<'life0, 'async_trait>(
&'life0 self,
from_agent: HoloHash<Agent>,
from_signature: Signature,
to_agent: HoloHash<Agent>,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> Pin<Box<dyn Future<Output = Result<SerializedBytes, HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn call_remote<'life0, 'async_trait>( &'life0 self, from_agent: HoloHash<Agent>, from_signature: Signature, to_agent: HoloHash<Agent>, zome_name: ZomeName, fn_name: FunctionName, cap_secret: Option<CapSecret>, payload: ExternIO, nonce: Nonce256Bits, expires_at: Timestamp ) -> Pin<Box<dyn Future<Output = Result<SerializedBytes, HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Invoke a zome function on a remote node (if you have been granted the capability).
source§fn remote_signal<'life0, 'async_trait>(
&'life0 self,
from_agent: HoloHash<Agent>,
to_agent_list: Vec<(Signature, HoloHash<Agent>), Global>,
zome_name: ZomeName,
fn_name: FunctionName,
cap: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn remote_signal<'life0, 'async_trait>( &'life0 self, from_agent: HoloHash<Agent>, to_agent_list: Vec<(Signature, HoloHash<Agent>), Global>, zome_name: ZomeName, fn_name: FunctionName, cap: Option<CapSecret>, payload: ExternIO, nonce: Nonce256Bits, expires_at: Timestamp ) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
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.
source§fn publish<'life0, 'async_trait>(
&'life0 self,
request_validation_receipt: bool,
countersigning_session: bool,
basis_hash: HoloHash<AnyLinkable>,
source: HoloHash<Agent>,
op_hash_list: Vec<RoughSized<Arc<KitsuneOpHash, Global>>, Global>,
timeout_ms: Option<u64>,
reflect_ops: Option<Vec<DhtOp, Global>>
) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn publish<'life0, 'async_trait>( &'life0 self, request_validation_receipt: bool, countersigning_session: bool, basis_hash: HoloHash<AnyLinkable>, source: HoloHash<Agent>, op_hash_list: Vec<RoughSized<Arc<KitsuneOpHash, Global>>, Global>, timeout_ms: Option<u64>, reflect_ops: Option<Vec<DhtOp, Global>> ) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Publish data to the correct neighborhood.
source§fn publish_countersign<'life0, 'async_trait>(
&'life0 self,
flag: bool,
basis_hash: HoloHash<AnyLinkable>,
op: DhtOp
) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn publish_countersign<'life0, 'async_trait>( &'life0 self, flag: bool, basis_hash: HoloHash<AnyLinkable>, op: DhtOp ) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Publish a countersigning op.
source§fn get<'life0, 'async_trait>(
&'life0 self,
dht_hash: HoloHash<AnyDht>,
options: GetOptions
) -> Pin<Box<dyn Future<Output = Result<Vec<WireOps, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn get<'life0, 'async_trait>( &'life0 self, dht_hash: HoloHash<AnyDht>, options: GetOptions ) -> Pin<Box<dyn Future<Output = Result<Vec<WireOps, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Get an entry from the DHT.
source§fn get_meta<'life0, 'async_trait>(
&'life0 self,
dht_hash: HoloHash<AnyDht>,
options: GetMetaOptions
) -> Pin<Box<dyn Future<Output = Result<Vec<MetadataSet, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn get_meta<'life0, 'async_trait>( &'life0 self, dht_hash: HoloHash<AnyDht>, options: GetMetaOptions ) -> Pin<Box<dyn Future<Output = Result<Vec<MetadataSet, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Get metadata from the DHT.
source§fn get_links<'life0, 'async_trait>(
&'life0 self,
link_key: WireLinkKey,
options: GetLinksOptions
) -> Pin<Box<dyn Future<Output = Result<Vec<WireLinkOps, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn get_links<'life0, 'async_trait>( &'life0 self, link_key: WireLinkKey, options: GetLinksOptions ) -> Pin<Box<dyn Future<Output = Result<Vec<WireLinkOps, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Get links from the DHT.
source§fn count_links<'life0, 'async_trait>(
&'life0 self,
query: WireLinkQuery
) -> Pin<Box<dyn Future<Output = Result<CountLinksResponse, HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn count_links<'life0, 'async_trait>( &'life0 self, query: WireLinkQuery ) -> Pin<Box<dyn Future<Output = Result<CountLinksResponse, HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Get a count of links from the DHT.
source§fn get_agent_activity<'life0, 'async_trait>(
&'life0 self,
agent: HoloHash<Agent>,
query: ChainQueryFilter,
options: GetActivityOptions
) -> Pin<Box<dyn Future<Output = Result<Vec<AgentActivityResponse<HoloHash<Action>>, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn get_agent_activity<'life0, 'async_trait>( &'life0 self, agent: HoloHash<Agent>, query: ChainQueryFilter, options: GetActivityOptions ) -> Pin<Box<dyn Future<Output = Result<Vec<AgentActivityResponse<HoloHash<Action>>, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Get agent activity from the DHT.
source§fn must_get_agent_activity<'life0, 'async_trait>(
&'life0 self,
author: HoloHash<Agent>,
filter: ChainFilter<HoloHash<Action>>
) -> Pin<Box<dyn Future<Output = Result<Vec<MustGetAgentActivityResponse, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn must_get_agent_activity<'life0, 'async_trait>( &'life0 self, author: HoloHash<Agent>, filter: ChainFilter<HoloHash<Action>> ) -> Pin<Box<dyn Future<Output = Result<Vec<MustGetAgentActivityResponse, Global>, HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Get agent deterministic activity from the DHT.
source§fn send_validation_receipt<'life0, 'async_trait>(
&'life0 self,
to_agent: HoloHash<Agent>,
receipt: SerializedBytes
) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn send_validation_receipt<'life0, 'async_trait>( &'life0 self, to_agent: HoloHash<Agent>, receipt: SerializedBytes ) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Send a validation receipt to a remote node.
Check if an agent is an authority for a hash.
source§fn countersigning_session_negotiation<'life0, 'async_trait>(
&'life0 self,
agents: Vec<HoloHash<Agent>, Global>,
message: CountersigningSessionNegotiationMessage
) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn countersigning_session_negotiation<'life0, 'async_trait>( &'life0 self, agents: Vec<HoloHash<Agent>, Global>, message: CountersigningSessionNegotiationMessage ) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
Messages between agents driving a countersigning session.
source§fn new_integrated_data<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
MockHolochainP2pDnaT: 'async_trait,
fn new_integrated_data<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), HolochainP2pError>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, MockHolochainP2pDnaT: 'async_trait,
New data has been integrated and is ready for gossiping.
Auto Trait Implementations§
impl RefUnwindSafe for MockHolochainP2pDnaT
impl Send for MockHolochainP2pDnaT
impl Sync for MockHolochainP2pDnaT
impl Unpin for MockHolochainP2pDnaT
impl UnwindSafe for MockHolochainP2pDnaT
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata ) -> <T as Pointee>::Metadata
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<F, W, T, D> Deserialize<With<T, W>, D> for Fwhere
W: DeserializeWith<F, T, D>,
D: Fallible + ?Sized,
F: ?Sized,
impl<F, W, T, D> Deserialize<With<T, W>, D> for Fwhere W: DeserializeWith<F, T, D>, D: Fallible + ?Sized, F: ?Sized,
§fn deserialize(
&self,
deserializer: &mut D
) -> Result<With<T, W>, <D as Fallible>::Error>
fn deserialize( &self, deserializer: &mut D ) -> Result<With<T, W>, <D as Fallible>::Error>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
§impl<T> Pointable for T
impl<T> Pointable for T
§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere SS: SubsetOf<SP>,
§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
self
from the equivalent element of its
superset. Read more§fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
self
is actually part of its subset T
(and can be converted to it).§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
self.to_subset
but without any property checks. Always succeeds.§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
self
to the equivalent element of its superset.