Struct holochain_p2p::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() -> Self
pub fn new() -> Self
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_send_remote_signal(&mut self) -> &mut Expectation
pub fn expect_send_remote_signal(&mut self) -> &mut Expectation
Create an Expectation
for mocking the send_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_receipts(&mut self) -> &mut Expectation
pub fn expect_send_validation_receipts(&mut self) -> &mut Expectation
Create an Expectation
for mocking the send_validation_receipts
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§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: AgentPubKey,
maybe_agent_info: Option<AgentInfoSigned>,
initial_arq: Option<Arq>
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn join<'life0, 'async_trait>(
&'life0 self,
agent: AgentPubKey,
maybe_agent_info: Option<AgentInfoSigned>,
initial_arq: Option<Arq>
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: '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: AgentPubKey
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn leave<'life0, 'async_trait>(
&'life0 self,
agent: AgentPubKey
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: '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: AgentPubKey,
from_signature: Signature,
to_agent: AgentPubKey,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<SerializedBytes>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn call_remote<'life0, 'async_trait>(
&'life0 self,
from_agent: AgentPubKey,
from_signature: Signature,
to_agent: AgentPubKey,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<SerializedBytes>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Invoke a zome function on a remote node (if you have been granted the capability).
source§fn send_remote_signal<'life0, 'async_trait>(
&'life0 self,
from_agent: AgentPubKey,
to_agent_list: Vec<(Signature, AgentPubKey)>,
zome_name: ZomeName,
fn_name: FunctionName,
cap: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_remote_signal<'life0, 'async_trait>(
&'life0 self,
from_agent: AgentPubKey,
to_agent_list: Vec<(Signature, AgentPubKey)>,
zome_name: ZomeName,
fn_name: FunctionName,
cap: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: '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: OpBasis,
source: AgentPubKey,
op_hash_list: Vec<OpHashSized>,
timeout_ms: Option<u64>,
reflect_ops: Option<Vec<DhtOp>>
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn publish<'life0, 'async_trait>(
&'life0 self,
request_validation_receipt: bool,
countersigning_session: bool,
basis_hash: OpBasis,
source: AgentPubKey,
op_hash_list: Vec<OpHashSized>,
timeout_ms: Option<u64>,
reflect_ops: Option<Vec<DhtOp>>
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Publish data to the correct neighborhood.
source§fn publish_countersign<'life0, 'async_trait>(
&'life0 self,
flag: bool,
basis_hash: OpBasis,
op: DhtOp
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn publish_countersign<'life0, 'async_trait>(
&'life0 self,
flag: bool,
basis_hash: OpBasis,
op: DhtOp
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Publish a countersigning op.
source§fn get<'life0, 'async_trait>(
&'life0 self,
dht_hash: AnyDhtHash,
options: GetOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<WireOps>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: '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
Self: 'async_trait,
'life0: 'async_trait,
Get an entry from the DHT.
source§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
Self: 'async_trait,
'life0: '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
Self: 'async_trait,
'life0: '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 = HolochainP2pResult<Vec<WireLinkOps>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: '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
Self: 'async_trait,
'life0: 'async_trait,
Get links from the DHT.
source§fn count_links<'life0, 'async_trait>(
&'life0 self,
query: WireLinkQuery
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<CountLinksResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn count_links<'life0, 'async_trait>(
&'life0 self,
query: WireLinkQuery
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<CountLinksResponse>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a count of links from the DHT.
source§fn get_agent_activity<'life0, 'async_trait>(
&'life0 self,
agent: AgentPubKey,
query: ChainQueryFilter,
options: GetActivityOptions
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<AgentActivityResponse<ActionHash>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: '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<ActionHash>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get agent activity from the DHT.
source§fn must_get_agent_activity<'life0, 'async_trait>(
&'life0 self,
author: AgentPubKey,
filter: ChainFilter
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<MustGetAgentActivityResponse>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn must_get_agent_activity<'life0, 'async_trait>(
&'life0 self,
author: AgentPubKey,
filter: ChainFilter
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<Vec<MustGetAgentActivityResponse>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get agent activity deterministically from the DHT.
source§fn send_validation_receipts<'life0, 'async_trait>(
&'life0 self,
to_agent: AgentPubKey,
receipts: ValidationReceiptBundle
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send_validation_receipts<'life0, 'async_trait>(
&'life0 self,
to_agent: AgentPubKey,
receipts: ValidationReceiptBundle
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: '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<AgentPubKey>,
message: CountersigningSessionNegotiationMessage
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn countersigning_session_negotiation<'life0, 'async_trait>(
&'life0 self,
agents: Vec<AgentPubKey>,
message: CountersigningSessionNegotiationMessage
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Messages between agents driving a countersigning session.
source§fn new_integrated_data<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn new_integrated_data<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = HolochainP2pResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
New data has been integrated and is ready for gossiping.
Auto Trait Implementations§
impl Freeze for MockHolochainP2pDnaT
impl RefUnwindSafe for MockHolochainP2pDnaT
impl Send for MockHolochainP2pDnaT
impl Sync for MockHolochainP2pDnaT
impl Unpin for MockHolochainP2pDnaT
impl UnwindSafe for MockHolochainP2pDnaT
Blanket Implementations§
source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
source§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
source§impl<F, W, T, D> Deserialize<With<T, W>, D> for F
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<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>
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> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
source§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
self
from the equivalent element of its
superset. Read moresource§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).source§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
self.to_subset
but without any property checks. Always succeeds.source§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
self
to the equivalent element of its superset.